@@ -1168,13 +1168,14 @@ def test_append_frame_column_oriented(self):
11681168
11691169 # selection on the non-indexable
11701170 result = store .select (
1171- 'df1' , ('columns=A' , Term ( 'index=df.index[0:4]' ) ))
1171+ 'df1' , ('columns=A' , 'index=df.index[0:4]' ))
11721172 expected = df .reindex (columns = ['A' ], index = df .index [0 :4 ])
11731173 tm .assert_frame_equal (expected , result )
11741174
11751175 # this isn't supported
1176- self .assertRaises (TypeError , store .select , 'df1' , (
1177- 'columns=A' , Term ('index>df.index[4]' )))
1176+ with pytest .raises (TypeError ):
1177+ store .select ('df1' ,
1178+ 'columns=A and index>df.index[4]' )
11781179
11791180 def test_append_with_different_block_ordering (self ):
11801181
@@ -1275,15 +1276,15 @@ def check_indexers(key, indexers):
12751276 assert_panel4d_equal (result , expected )
12761277
12771278 # partial selection2
1278- result = store .select ('p4d' , [ Term (
1279- 'labels=l1' ), Term ( ' items=ItemA'), Term ( ' minor_axis=B' )] )
1279+ result = store .select (
1280+ 'p4d' , " labels=' l1' and items=' ItemA' and minor_axis='B'" )
12801281 expected = p4d .reindex (
12811282 labels = ['l1' ], items = ['ItemA' ], minor_axis = ['B' ])
12821283 assert_panel4d_equal (result , expected )
12831284
12841285 # non-existant partial selection
1285- result = store .select ('p4d' , [ Term (
1286- 'labels=l1' ), Term ( ' items=Item1'), Term ( ' minor_axis=B' )] )
1286+ result = store .select (
1287+ 'p4d' , " labels=' l1' and items=' Item1' and minor_axis='B'" )
12871288 expected = p4d .reindex (labels = ['l1' ], items = [],
12881289 minor_axis = ['B' ])
12891290 assert_panel4d_equal (result , expected )
@@ -1465,13 +1466,13 @@ def test_append_with_data_columns(self):
14651466 assert (store ._handle .root .df .table .cols .B .is_indexed is True )
14661467
14671468 # data column searching
1468- result = store .select ('df' , [ Term ( 'B>0' )] )
1469+ result = store .select ('df' , 'B>0' )
14691470 expected = df [df .B > 0 ]
14701471 tm .assert_frame_equal (result , expected )
14711472
14721473 # data column searching (with an indexable and a data_columns)
14731474 result = store .select (
1474- 'df' , [ Term ( 'B>0' ), Term ( ' index>df.index[3]')] )
1475+ 'df' , 'B>0 and index>df.index[3]' )
14751476 df_new = df .reindex (index = df .index [4 :])
14761477 expected = df_new [df_new .B > 0 ]
14771478 tm .assert_frame_equal (result , expected )
@@ -1483,7 +1484,7 @@ def test_append_with_data_columns(self):
14831484 df_new .loc [5 :6 , 'string' ] = 'bar'
14841485 _maybe_remove (store , 'df' )
14851486 store .append ('df' , df_new , data_columns = ['string' ])
1486- result = store .select ('df' , [ Term ( ' string=foo')] )
1487+ result = store .select ('df' , " string=' foo'" )
14871488 expected = df_new [df_new .string == 'foo' ]
14881489 tm .assert_frame_equal (result , expected )
14891490
@@ -1536,15 +1537,15 @@ def check_col(key, name, size):
15361537 _maybe_remove (store , 'df' )
15371538 store .append (
15381539 'df' , df_new , data_columns = ['A' , 'B' , 'string' , 'string2' ])
1539- result = store .select ('df' , [Term ('string=foo' ), Term (
1540- 'string2=foo' ), Term ('A>0' ), Term ('B<0' )])
1540+ result = store .select ('df' ,
1541+ "string='foo' and string2='foo'"
1542+ " and A>0 and B<0" )
15411543 expected = df_new [(df_new .string == 'foo' ) & (
15421544 df_new .string2 == 'foo' ) & (df_new .A > 0 ) & (df_new .B < 0 )]
15431545 tm .assert_frame_equal (result , expected , check_index_type = False )
15441546
15451547 # yield an empty frame
1546- result = store .select ('df' , [Term ('string=foo' ), Term (
1547- 'string2=cool' )])
1548+ result = store .select ('df' , "string='foo' and string2='cool'" )
15481549 expected = df_new [(df_new .string == 'foo' ) & (
15491550 df_new .string2 == 'cool' )]
15501551 tm .assert_frame_equal (result , expected , check_index_type = False )
@@ -1564,7 +1565,7 @@ def check_col(key, name, size):
15641565 store .append ('df_dc' , df_dc ,
15651566 data_columns = ['B' , 'C' , 'string' ,
15661567 'string2' , 'datetime' ])
1567- result = store .select ('df_dc' , [ Term ( 'B>0' )] )
1568+ result = store .select ('df_dc' , 'B>0' )
15681569
15691570 expected = df_dc [df_dc .B > 0 ]
15701571 tm .assert_frame_equal (result , expected , check_index_type = False )
@@ -1591,7 +1592,7 @@ def check_col(key, name, size):
15911592 store .append ('df_dc' , df_dc , data_columns = [
15921593 'B' , 'C' , 'string' , 'string2' ])
15931594
1594- result = store .select ('df_dc' , [ Term ( 'B>0' )] )
1595+ result = store .select ('df_dc' , 'B>0' )
15951596 expected = df_dc [df_dc .B > 0 ]
15961597 tm .assert_frame_equal (result , expected )
15971598
@@ -2259,7 +2260,7 @@ def test_remove_where(self):
22592260 with catch_warnings (record = True ):
22602261
22612262 # non-existance
2262- crit1 = Term ( 'index>foo' )
2263+ crit1 = 'index>foo'
22632264 self .assertRaises (KeyError , store .remove , 'a' , [crit1 ])
22642265
22652266 # try to remove non-table (with crit)
@@ -2352,7 +2353,7 @@ def test_remove_startstop(self):
23522353 # TODO: unused?
23532354 date = wp .major_axis .take (np .arange (0 , 30 , 3 )) # noqa
23542355
2355- crit = Term ( 'major_axis=date' )
2356+ crit = 'major_axis=date'
23562357 store .put ('wp7' , wp , format = 't' )
23572358 n = store .remove ('wp7' , where = [crit ], stop = 80 )
23582359 self .assertTrue (n == 28 )
@@ -2371,7 +2372,7 @@ def test_remove_crit(self):
23712372 # group row removal
23722373 _maybe_remove (store , 'wp3' )
23732374 date4 = wp .major_axis .take ([0 , 1 , 2 , 4 , 5 , 6 , 8 , 9 , 10 ])
2374- crit4 = Term ( 'major_axis=date4' )
2375+ crit4 = 'major_axis=date4'
23752376 store .put ('wp3' , wp , format = 't' )
23762377 n = store .remove ('wp3' , where = [crit4 ])
23772378 self .assertTrue (n == 36 )
@@ -2386,8 +2387,8 @@ def test_remove_crit(self):
23862387 store .put ('wp' , wp , format = 'table' )
23872388 date = wp .major_axis [len (wp .major_axis ) // 2 ]
23882389
2389- crit1 = Term ( 'major_axis>date' )
2390- crit2 = Term ( "minor_axis=['A', 'D']" )
2390+ crit1 = 'major_axis>date'
2391+ crit2 = "minor_axis=['A', 'D']"
23912392 n = store .remove ('wp' , where = [crit1 ])
23922393 self .assertTrue (n == 56 )
23932394
@@ -2403,15 +2404,15 @@ def test_remove_crit(self):
24032404 store .put ('wp2' , wp , format = 'table' )
24042405
24052406 date1 = wp .major_axis [1 :3 ]
2406- crit1 = Term ( 'major_axis=date1' )
2407+ crit1 = 'major_axis=date1'
24072408 store .remove ('wp2' , where = [crit1 ])
24082409 result = store .select ('wp2' )
24092410 expected = wp .reindex (
24102411 major_axis = wp .major_axis .difference (date1 ))
24112412 assert_panel_equal (result , expected )
24122413
24132414 date2 = wp .major_axis [5 ]
2414- crit2 = Term ( 'major_axis=date2' )
2415+ crit2 = 'major_axis=date2'
24152416 store .remove ('wp2' , where = [crit2 ])
24162417 result = store ['wp2' ]
24172418 expected = wp .reindex (
@@ -2422,7 +2423,7 @@ def test_remove_crit(self):
24222423 assert_panel_equal (result , expected )
24232424
24242425 date3 = [wp .major_axis [7 ], wp .major_axis [9 ]]
2425- crit3 = Term ( 'major_axis=date3' )
2426+ crit3 = 'major_axis=date3'
24262427 store .remove ('wp2' , where = [crit3 ])
24272428 result = store ['wp2' ]
24282429 expected = wp .reindex (major_axis = wp .major_axis
@@ -2435,7 +2436,7 @@ def test_remove_crit(self):
24352436 _maybe_remove (store , 'wp4' )
24362437 store .put ('wp4' , wp , format = 'table' )
24372438 n = store .remove (
2438- 'wp4' , where = [ Term ( ' major_axis>wp.major_axis[-1]' )] )
2439+ 'wp4' , where = " major_axis>wp.major_axis[-1]" )
24392440 result = store .select ('wp4' )
24402441 assert_panel_equal (result , wp )
24412442
@@ -2508,8 +2509,9 @@ def test_terms(self):
25082509 store .put ('wpneg' , wpneg , format = 'table' )
25092510
25102511 # panel
2511- result = store .select ('wp' , [Term (
2512- 'major_axis<"20000108"' ), Term ("minor_axis=['A', 'B']" )])
2512+ result = store .select (
2513+ 'wp' ,
2514+ "major_axis<'20000108' and minor_axis=['A', 'B']" )
25132515 expected = wp .truncate (
25142516 after = '20000108' ).reindex (minor = ['A' , 'B' ])
25152517 assert_panel_equal (result , expected )
@@ -2555,27 +2557,25 @@ def test_terms(self):
25552557 store .select ('p4d' , t )
25562558
25572559 # valid for p4d only
2558- terms = [(("labels=['l1', 'l2']" ),),
2559- Term ("labels=['l1', 'l2']" ),
2560- ]
2561-
2560+ terms = ["labels=['l1', 'l2']" ]
25622561 for t in terms :
25632562 store .select ('p4d' , t )
25642563
2565- with tm .assertRaisesRegexp (TypeError ,
2566- 'Only named functions are supported' ):
2567- store .select ('wp' , Term (
2568- 'major_axis == (lambda x: x)("20130101")' ))
2564+ with tm .assertRaisesRegexp (
2565+ TypeError , 'Only named functions are supported' ):
2566+ store .select (
2567+ 'wp' ,
2568+ 'major_axis == (lambda x: x)("20130101")' )
25692569
25702570 with catch_warnings (record = True ):
25712571 # check USub node parsing
2572- res = store .select ('wpneg' , Term ( 'items == -1' ) )
2572+ res = store .select ('wpneg' , 'items == -1' )
25732573 expected = Panel ({- 1 : wpneg [- 1 ]})
25742574 tm .assert_panel_equal (res , expected )
25752575
25762576 with tm .assertRaisesRegexp (NotImplementedError ,
25772577 'Unary addition not supported' ):
2578- store .select ('wpneg' , Term ( 'items == +1' ) )
2578+ store .select ('wpneg' , 'items == +1' )
25792579
25802580 def test_term_compat (self ):
25812581 with ensure_clean_store (self .path ) as store :
@@ -2593,7 +2593,7 @@ def test_term_compat(self):
25932593 Timestamp ('20000102' ), ['A' , 'B' ]]
25942594 assert_panel_equal (result , expected )
25952595
2596- store .remove ('wp' , Term ( 'major_axis>20000103' ) )
2596+ store .remove ('wp' , 'major_axis>20000103' )
25972597 result = store .select ('wp' )
25982598 expected = wp .loc [:, wp .major_axis <= Timestamp ('20000103' ), :]
25992599 assert_panel_equal (result , expected )
@@ -2609,27 +2609,25 @@ def test_term_compat(self):
26092609
26102610 # stringified datetimes
26112611 result = store .select (
2612- 'wp' , [Term ('major_axis' , '>' ,
2613- datetime .datetime (2000 , 1 , 2 ))])
2612+ 'wp' , 'major_axis>datetime.datetime(2000, 1, 2)' )
26142613 expected = wp .loc [:, wp .major_axis > Timestamp ('20000102' )]
26152614 assert_panel_equal (result , expected )
26162615
26172616 result = store .select (
2618- 'wp' , [Term ('major_axis' , '>' ,
2619- datetime .datetime (2000 , 1 , 2 , 0 , 0 ))])
2617+ 'wp' , 'major_axis>datetime.datetime(2000, 1, 2)' )
26202618 expected = wp .loc [:, wp .major_axis > Timestamp ('20000102' )]
26212619 assert_panel_equal (result , expected )
26222620
26232621 result = store .select (
2624- 'wp' , [ Term ( 'major_axis' , '=' ,
2625- [datetime .datetime (2000 , 1 , 2 , 0 , 0 ),
2626- datetime .datetime (2000 , 1 , 3 , 0 , 0 )])] )
2622+ 'wp' ,
2623+ "major_axis= [datetime.datetime(2000, 1, 2, 0, 0), "
2624+ " datetime.datetime(2000, 1, 3, 0, 0)]" )
26272625 expected = wp .loc [:, [Timestamp ('20000102' ),
26282626 Timestamp ('20000103' )]]
26292627 assert_panel_equal (result , expected )
26302628
26312629 result = store .select (
2632- 'wp' , [ Term ( ' minor_axis' , '=' , ['A' , 'B' ])] )
2630+ 'wp' , " minor_axis= ['A', 'B']" )
26332631 expected = wp .loc [:, :, ['A' , 'B' ]]
26342632 assert_panel_equal (result , expected )
26352633
@@ -3091,7 +3089,7 @@ def test_select(self):
30913089 _maybe_remove (store , 'wp' )
30923090 store .append ('wp' , wp )
30933091 items = ['Item%03d' % i for i in range (80 )]
3094- result = store .select ('wp' , Term ( 'items=items' ) )
3092+ result = store .select ('wp' , 'items=items' )
30953093 expected = wp .reindex (items = items )
30963094 assert_panel_equal (expected , result )
30973095
@@ -3143,7 +3141,7 @@ def test_select_dtypes(self):
31433141 _maybe_remove (store , 'df' )
31443142 store .append ('df' , df , data_columns = ['ts' , 'A' ])
31453143
3146- result = store .select ('df' , [ Term ( "ts>=Timestamp('2012-02-01')" )] )
3144+ result = store .select ('df' , "ts>=Timestamp('2012-02-01')" )
31473145 expected = df [df .ts >= Timestamp ('2012-02-01' )]
31483146 tm .assert_frame_equal (expected , result )
31493147
@@ -3158,23 +3156,23 @@ def test_select_dtypes(self):
31583156 expected = (df [df .boolv == True ] # noqa
31593157 .reindex (columns = ['A' , 'boolv' ]))
31603158 for v in [True , 'true' , 1 ]:
3161- result = store .select ('df' , Term (
3162- 'boolv == %s' % str ( v )), columns = ['A' , 'boolv' ])
3159+ result = store .select ('df' , 'boolv == %s' % str ( v ),
3160+ columns = ['A' , 'boolv' ])
31633161 tm .assert_frame_equal (expected , result )
31643162
31653163 expected = (df [df .boolv == False ] # noqa
31663164 .reindex (columns = ['A' , 'boolv' ]))
31673165 for v in [False , 'false' , 0 ]:
3168- result = store .select ('df' , Term (
3169- 'boolv == %s' % str (v ) ), columns = ['A' , 'boolv' ])
3166+ result = store .select (
3167+ 'df' , ' boolv == %s' % str (v ), columns = ['A' , 'boolv' ])
31703168 tm .assert_frame_equal (expected , result )
31713169
31723170 # integer index
31733171 df = DataFrame (dict (A = np .random .rand (20 ), B = np .random .rand (20 )))
31743172 _maybe_remove (store , 'df_int' )
31753173 store .append ('df_int' , df )
31763174 result = store .select (
3177- 'df_int' , [ Term ( "index<10" ), Term ( " columns=['A']")] )
3175+ 'df_int' , "index<10 and columns=['A']" )
31783176 expected = df .reindex (index = list (df .index )[0 :10 ], columns = ['A' ])
31793177 tm .assert_frame_equal (expected , result )
31803178
@@ -3184,7 +3182,7 @@ def test_select_dtypes(self):
31843182 _maybe_remove (store , 'df_float' )
31853183 store .append ('df_float' , df )
31863184 result = store .select (
3187- 'df_float' , [ Term ( "index<10.0" ), Term ( " columns=['A']")] )
3185+ 'df_float' , "index<10.0 and columns=['A']" )
31883186 expected = df .reindex (index = list (df .index )[0 :10 ], columns = ['A' ])
31893187 tm .assert_frame_equal (expected , result )
31903188
@@ -3255,36 +3253,36 @@ def test_select_with_many_inputs(self):
32553253 store .append ('df' , df , data_columns = ['ts' , 'A' , 'B' , 'users' ])
32563254
32573255 # regular select
3258- result = store .select ('df' , [ Term ( "ts>=Timestamp('2012-02-01')" )] )
3256+ result = store .select ('df' , "ts>=Timestamp('2012-02-01')" )
32593257 expected = df [df .ts >= Timestamp ('2012-02-01' )]
32603258 tm .assert_frame_equal (expected , result )
32613259
32623260 # small selector
32633261 result = store .select (
3264- 'df' , [ Term ( "ts>=Timestamp('2012-02-01') & "
3265- " users=['a','b','c']")] )
3262+ 'df' ,
3263+ "ts>=Timestamp('2012-02-01') & users=['a','b','c']" )
32663264 expected = df [(df .ts >= Timestamp ('2012-02-01' )) &
32673265 df .users .isin (['a' , 'b' , 'c' ])]
32683266 tm .assert_frame_equal (expected , result )
32693267
32703268 # big selector along the columns
32713269 selector = ['a' , 'b' , 'c' ] + ['a%03d' % i for i in range (60 )]
32723270 result = store .select (
3273- 'df' , [ Term ( "ts>=Timestamp('2012-02-01')" ),
3274- Term ( ' users=selector' )] )
3271+ 'df' ,
3272+ "ts>=Timestamp('2012-02-01') and users=selector" )
32753273 expected = df [(df .ts >= Timestamp ('2012-02-01' )) &
32763274 df .users .isin (selector )]
32773275 tm .assert_frame_equal (expected , result )
32783276
32793277 selector = range (100 , 200 )
3280- result = store .select ('df' , [ Term ( 'B=selector' )] )
3278+ result = store .select ('df' , 'B=selector' )
32813279 expected = df [df .B .isin (selector )]
32823280 tm .assert_frame_equal (expected , result )
32833281 self .assertEqual (len (result ), 100 )
32843282
32853283 # big selector along the index
32863284 selector = Index (df .ts [0 :100 ].values )
3287- result = store .select ('df' , [ Term ( 'ts=selector' )] )
3285+ result = store .select ('df' , 'ts=selector' )
32883286 expected = df [df .ts .isin (selector .values )]
32893287 tm .assert_frame_equal (expected , result )
32903288 self .assertEqual (len (result ), 100 )
@@ -3355,17 +3353,6 @@ def test_select_iterator(self):
33553353 result = concat (results )
33563354 tm .assert_frame_equal (expected , result )
33573355
3358- # where selection
3359- # expected = store.select_as_multiple(
3360- # ['df1', 'df2'], where= Term('A>0'), selector='df1')
3361- # results = []
3362- # for s in store.select_as_multiple(
3363- # ['df1', 'df2'], where= Term('A>0'), selector='df1',
3364- # chunksize=25):
3365- # results.append(s)
3366- # result = concat(results)
3367- # tm.assert_frame_equal(expected, result)
3368-
33693356 def test_select_iterator_complete_8014 (self ):
33703357
33713358 # GH 8014
@@ -3682,7 +3669,7 @@ def test_frame_select(self):
36823669 df = tm .makeTimeDataFrame ()
36833670 store .append ('df_time' , df )
36843671 self .assertRaises (
3685- ValueError , store .select , 'df_time' , [ Term ( "index>0" )] )
3672+ ValueError , store .select , 'df_time' , "index>0" )
36863673
36873674 # can't select if not written as table
36883675 # store['frame'] = df
0 commit comments