File tree Expand file tree Collapse file tree 1 file changed +24
-21
lines changed Expand file tree Collapse file tree 1 file changed +24
-21
lines changed Original file line number Diff line number Diff line change @@ -19,29 +19,32 @@ using rewrite_plan = mysqlx::abe::rewrite_plan;
19
19
using abe_crypto = mysqlx::abe::abe_crypto;
20
20
21
21
RowResult abe_query::execute (){
22
- parse_and_rewrite ();
23
-
24
- field_name_list = get_field_name_list ();
25
-
26
- RowResult res = sess->sql (real_sql).execute ();
27
-
28
- auto it = res.getColumns ().begin ();
29
- auto end = res.getColumns ().end ();
30
- unsigned int i=0 ;
31
- for (;it != end;++it){
32
- std::string field_name = (*it).getColumnName ();
33
- auto temp = std::find (field_name_list.begin (), field_name_list.end (), field_name);
34
- if (temp != field_name_list.end ()){
35
- // 该列是使用了abe_dec的列
36
- f_flag.push_back (1 );
37
- field_num_list.push_back (i);
38
- }else {
39
- // 普通列
40
- f_flag.push_back (0 );
22
+ try {
23
+ parse_and_rewrite ();
24
+
25
+ field_name_list = get_field_name_list ();
26
+
27
+ RowResult res = sess->sql (real_sql).execute ();
28
+
29
+ auto it = res.getColumns ().begin ();
30
+ auto end = res.getColumns ().end ();
31
+ unsigned int i=0 ;
32
+ for (;it != end;++it){
33
+ std::string field_name = (*it).getColumnName ();
34
+ auto temp = std::find (field_name_list.begin (), field_name_list.end (), field_name);
35
+ if (temp != field_name_list.end ()){
36
+ // 该列是使用了abe_dec的列
37
+ f_flag.push_back (1 );
38
+ field_num_list.push_back (i);
39
+ }else {
40
+ // 普通列
41
+ f_flag.push_back (0 );
42
+ }
43
+ i++;
41
44
}
42
- i++ ;
45
+ return res ;
43
46
}
44
- return res;
47
+ CATCH_AND_WRAP
45
48
}
46
49
47
50
std::string abe_query::recover (const std::string &ct){
You can’t perform that action at this time.
0 commit comments