85
85
check_key ,
86
86
greeting_decode ,
87
87
version_id ,
88
- string_types ,
89
88
ENCODING_DEFAULT ,
90
89
)
91
90
@@ -640,7 +639,7 @@ def replace(self, space_name, values):
640
639
641
640
:rtype: `Response` instance
642
641
'''
643
- if isinstance (space_name , string_types ):
642
+ if isinstance (space_name , str ):
644
643
space_name = self .schema .get_space (space_name ).sid
645
644
request = RequestReplace (self , space_name , values )
646
645
return self ._send_request (request )
@@ -697,7 +696,7 @@ class JoinState:
697
696
def _ops_process (self , space , update_ops ):
698
697
new_ops = []
699
698
for op in update_ops :
700
- if isinstance (op [1 ], string_types ):
699
+ if isinstance (op [1 ], str ):
701
700
op = list (op )
702
701
op [1 ] = self .schema .get_field (space , op [1 ])['id' ]
703
702
new_ops .append (op )
@@ -733,7 +732,7 @@ def insert(self, space_name, values):
733
732
734
733
:rtype: `Response` instance
735
734
'''
736
- if isinstance (space_name , string_types ):
735
+ if isinstance (space_name , str ):
737
736
space_name = self .schema .get_space (space_name ).sid
738
737
request = RequestInsert (self , space_name , values )
739
738
return self ._send_request (request )
@@ -754,9 +753,9 @@ def delete(self, space_name, key, **kwargs):
754
753
index_name = kwargs .get ("index" , 0 )
755
754
756
755
key = check_key (key )
757
- if isinstance (space_name , string_types ):
756
+ if isinstance (space_name , str ):
758
757
space_name = self .schema .get_space (space_name ).sid
759
- if isinstance (index_name , string_types ):
758
+ if isinstance (index_name , str ):
760
759
index_name = self .schema .get_index (space_name , index_name ).iid
761
760
request = RequestDelete (self , space_name , index_name , key )
762
761
return self ._send_request (request )
@@ -826,9 +825,9 @@ def upsert(self, space_name, tuple_value, op_list, **kwargs):
826
825
'''
827
826
index_name = kwargs .get ("index" , 0 )
828
827
829
- if isinstance (space_name , string_types ):
828
+ if isinstance (space_name , str ):
830
829
space_name = self .schema .get_space (space_name ).sid
831
- if isinstance (index_name , string_types ):
830
+ if isinstance (index_name , str ):
832
831
index_name = self .schema .get_index (space_name , index_name ).iid
833
832
op_list = self ._ops_process (space_name , op_list )
834
833
request = RequestUpsert (self , space_name , index_name , tuple_value ,
@@ -902,9 +901,9 @@ def update(self, space_name, key, op_list, **kwargs):
902
901
index_name = kwargs .get ("index" , 0 )
903
902
904
903
key = check_key (key )
905
- if isinstance (space_name , string_types ):
904
+ if isinstance (space_name , str ):
906
905
space_name = self .schema .get_space (space_name ).sid
907
- if isinstance (index_name , string_types ):
906
+ if isinstance (index_name , str ):
908
907
index_name = self .schema .get_index (space_name , index_name ).iid
909
908
op_list = self ._ops_process (space_name , op_list )
910
909
request = RequestUpdate (self , space_name , index_name , key , op_list )
@@ -985,9 +984,9 @@ def select(self, space_name, key=None, **kwargs):
985
984
# tuples)
986
985
key = check_key (key , select = True )
987
986
988
- if isinstance (space_name , string_types ):
987
+ if isinstance (space_name , str ):
989
988
space_name = self .schema .get_space (space_name ).sid
990
- if isinstance (index_name , string_types ):
989
+ if isinstance (index_name , str ):
991
990
index_name = self .schema .get_index (space_name , index_name ).iid
992
991
request = RequestSelect (self , space_name , index_name , key , offset ,
993
992
limit , iterator_type )
0 commit comments