File tree 1 file changed +44
-0
lines changed
1 file changed +44
-0
lines changed Original file line number Diff line number Diff line change
1
+ var MongoClient = require ( 'mongodb' ) . MongoClient
2
+
3
+ MongoClient . connect ( 'mongodb://127.0.0.1:27017/weather' , function ( err , db ) {
4
+ if ( err ) throw err
5
+
6
+ var query = { }
7
+ var operator = { '$set' : { 'month_high' :true } }
8
+ // var options = { 'new': 1 }
9
+ var sort = [ [ 'State' , 1 ] , [ 'Temperature' , - 1 ] ]
10
+
11
+ // var options = {
12
+ // 'limit': 5,
13
+ // 'sort': [['State', 1], ['Temperature', -1]]
14
+ // }
15
+
16
+ var cursor = db . collection ( 'data' ) . find ( ) . sort ( sort )
17
+ var currentState = ''
18
+ var prevState = ''
19
+
20
+ cursor . each ( function ( err , doc ) {
21
+ if ( err ) throw err
22
+
23
+ var query = { }
24
+
25
+ if ( doc == null ) return db . close ( )
26
+
27
+ if ( doc && doc . State !== currentState ) {
28
+ prevState = currentState
29
+ currentState = doc . State
30
+ console . log ( 'change state from ' + prevState + ' to ' + currentState )
31
+
32
+ query [ '_id' ] = doc [ '_id' ]
33
+ doc [ 'month_high' ] = true
34
+ console . log ( query , doc )
35
+ db . collection ( 'data' ) . update ( query , doc , function ( err , doc ) {
36
+ if ( err ) throw err
37
+ console . log ( doc )
38
+ // return db.close()
39
+ } )
40
+ }
41
+
42
+ // console.log(doc)
43
+ } )
44
+ } )
You can’t perform that action at this time.
0 commit comments