19
19
import com .alibaba .fastjson .serializer .SerializerFeature ;
20
20
import com .alibaba .fastjson .serializer .ValueFilter ;
21
21
import com .fasterxml .jackson .databind .util .LRUMap ;
22
- import com .vesoft .nebula .Date ;
23
- import com .vesoft .nebula .DateTime ;
24
- import com .vesoft .nebula .Duration ;
25
- import com .vesoft .nebula .Edge ;
26
- import com .vesoft .nebula .NullType ;
27
- import com .vesoft .nebula .Tag ;
28
- import com .vesoft .nebula .Time ;
29
- import com .vesoft .nebula .Value ;
30
- import com .vesoft .nebula .Vertex ;
31
- import com .vesoft .nebula .client .graph .data .DateTimeWrapper ;
32
- import com .vesoft .nebula .client .graph .data .DateWrapper ;
33
- import com .vesoft .nebula .client .graph .data .DurationWrapper ;
34
- import com .vesoft .nebula .client .graph .data .TimeWrapper ;
35
- import com .vesoft .nebula .client .graph .data .ValueWrapper ;
22
+ // import com.vesoft.nebula.Date;
23
+ // import com.vesoft.nebula.DateTime;
24
+ // import com.vesoft.nebula.Duration;
25
+ // import com.vesoft.nebula.Edge;
26
+ // import com.vesoft.nebula.NullType;
27
+ // import com.vesoft.nebula.Tag;
28
+ // import com.vesoft.nebula.Time;
29
+ // import com.vesoft.nebula.Value;
30
+ // import com.vesoft.nebula.Vertex;
31
+ // import com.vesoft.nebula.client.graph.data.DateTimeWrapper;
32
+ // import com.vesoft.nebula.client.graph.data.DateWrapper;
33
+ // import com.vesoft.nebula.client.graph.data.DurationWrapper;
34
+ // import com.vesoft.nebula.client.graph.data.TimeWrapper;
35
+ // import com.vesoft.nebula.client.graph.data.ValueWrapper;
36
36
37
37
import org .springframework .beans .factory .annotation .Autowired ;
38
38
import org .springframework .http .*;
@@ -1865,7 +1865,7 @@ public String execute(@RequestBody String request, HttpSession session) {
1865
1865
prefix = prefix .substring (mid + 1 );
1866
1866
}
1867
1867
1868
- if (DemoSQLConfig .DATABASE_INFLUXDB .equalsIgnoreCase (prefix ) || DemoSQLExecutor .DATABASE_CASSANDRA .equalsIgnoreCase (prefix )) {
1868
+ if (DemoSQLConfig .DATABASE_INFLUXDB .equalsIgnoreCase (prefix ) || DemoSQLConfig .DATABASE_CASSANDRA .equalsIgnoreCase (prefix )) {
1869
1869
database = prefix .toUpperCase ();
1870
1870
1871
1871
int end = uri .lastIndexOf ("/" );
@@ -1882,7 +1882,7 @@ public String execute(@RequestBody String request, HttpSession session) {
1882
1882
// password = "apijson@123";
1883
1883
// }
1884
1884
1885
- if (DemoSQLExecutor .DATABASE_CASSANDRA .equalsIgnoreCase (prefix )) { // unknown protocol: jdbc
1885
+ if (DemoSQLConfig .DATABASE_CASSANDRA .equalsIgnoreCase (prefix )) { // unknown protocol: jdbc
1886
1886
account = "test" ; // "peter";
1887
1887
password = "test" ; // null;
1888
1888
}
@@ -1919,7 +1919,7 @@ public String execute(@RequestBody String request, HttpSession session) {
1919
1919
long rsDuration = 0 ;
1920
1920
long executeStartTime = System .currentTimeMillis ();
1921
1921
1922
- if (DemoSQLConfig .DATABASE_INFLUXDB .equals (database ) || DemoSQLExecutor .DATABASE_CASSANDRA .equals (database )) {
1922
+ if (DemoSQLConfig .DATABASE_INFLUXDB .equals (database ) || DemoSQLConfig .DATABASE_CASSANDRA .equals (database )) {
1923
1923
JSONObject result = executor .execute (config , false );
1924
1924
executeDuration = System .currentTimeMillis () - executeStartTime ;
1925
1925
@@ -2017,116 +2017,116 @@ public String execute(@RequestBody String request, HttpSession session) {
2017
2017
return com .alibaba .fastjson .JSON .toJSONString (result , new ValueFilter () {
2018
2018
@ Override
2019
2019
public Object process (Object o , String key , Object val ) {
2020
- if (val instanceof ValueWrapper ) {
2021
- return process (o , key , ((ValueWrapper ) val ).getValue ());
2022
- }
2023
-
2024
- if (val instanceof Value ) {
2025
- return process (o , key , ((Value ) val ).getFieldValue ());
2026
- }
2027
-
2028
- if (val instanceof Vertex ) {
2029
- JSONObject obj = new JSONObject (true );
2030
- obj .put ("vid" , new String (((Vertex ) val ).getVid ().getSVal ()));
2031
- obj .put ("str" , val .toString ());
2032
-
2033
- List <Tag > tags = ((Vertex ) val ).getTags ();
2034
-
2035
- if (tags != null ) {
2036
- JSONArray arr = new JSONArray ();
2037
- for (int i = 0 ; i < tags .size (); i ++) {
2038
- arr .add (process (o , String .valueOf (i ), tags .get (i )));
2039
- }
2040
- obj .put ("tags" , arr );
2041
- }
2042
-
2043
- return obj ;
2044
- }
2045
-
2046
- if (val instanceof Tag ) {
2047
- JSONObject obj = new JSONObject (true );
2048
- obj .put ("name" , new String (((Tag ) val ).getName ()));
2049
- obj .put ("str" , val .toString ());
2050
-
2051
- Map <byte [], Value > props = ((Tag ) val ).getProps ();
2052
-
2053
- if (props != null ) {
2054
- JSONObject propsObj = new JSONObject (true );
2055
- props .forEach (new BiConsumer <byte [], Value >() {
2056
- @ Override
2057
- public void accept (byte [] bytes , Value value ) {
2058
- String k = new String (bytes );
2059
- propsObj .put (k , process (propsObj , k , value ));
2060
- }
2061
- });
2062
- obj .put ("props" , propsObj );
2063
- }
2064
-
2065
- return obj ;
2066
- }
2067
-
2068
- if (val instanceof Edge ) {
2069
- JSONObject obj = new JSONObject (true );
2070
- obj .put ("name" , new String (((Edge ) val ).getName ()));
2071
- obj .put ("str" , val .toString ());
2072
-
2073
- Map <byte [], Value > props = ((Edge ) val ).getProps ();
2074
-
2075
- if (props != null ) {
2076
- JSONObject propsObj = new JSONObject (true );
2077
- props .forEach (new BiConsumer <byte [], Value >() {
2078
- @ Override
2079
- public void accept (byte [] bytes , Value value ) {
2080
- String k = new String (bytes );
2081
- propsObj .put (k , process (propsObj , k , value ));
2082
- }
2083
- });
2084
- obj .put ("props" , propsObj );
2085
- }
2086
-
2087
- return obj ;
2088
- }
2089
-
2090
- if (val instanceof NullType ) {
2091
- return null ;
2092
- }
2093
-
2094
- if (val instanceof DateWrapper ) {
2095
- return ((DateWrapper ) val ).toString ();
2096
- }
2097
-
2098
- if (val instanceof TimeWrapper ) {
2099
- return ((TimeWrapper ) val ).getLocalTimeStr ();
2100
- }
2101
-
2102
- if (val instanceof DateTimeWrapper ) {
2103
- return ((DateTimeWrapper ) val ).getLocalDateTimeStr ();
2104
- }
2105
-
2106
- if (val instanceof DurationWrapper ) {
2107
- return ((DurationWrapper ) val ).getMicroseconds ();
2108
- }
2109
-
2110
- if (val instanceof Date ) {
2111
- Date d = (Date ) val ;
2112
- return new java .sql .Date (d .getYear () - 1900 , d .getMonth (), d .getDay ()).toString ();
2113
- }
2114
-
2115
- if (val instanceof Time ) {
2116
- Time t = (Time ) val ;
2117
- return new java .sql .Time (t .getHour (), t .getMinute (), t .getSec ()).toString ();
2118
- }
2119
-
2120
- if (val instanceof DateTime ) {
2121
- DateTime dt = (DateTime ) val ;
2122
- // return new java.util.Date(dt.getYear(), dt.getNonth(), dt.getDayO, dt.getHour(), dt.getMinute(), dt.getSec0).toGnTString();
2123
- return new java .sql .Date (dt .getYear () - 1988 , dt .getMonth (), dt .getDay ())
2124
- + " " + new java .sql .Time (dt .getHour (), dt .getMinute (), dt .getSec ());
2125
- }
2126
-
2127
- if (val instanceof Duration ) {
2128
- return ((Duration ) val ).getMicroseconds ();
2129
- }
2020
+ // if (val instanceof ValueWrapper) {
2021
+ // return process(o, key, ((ValueWrapper) val).getValue());
2022
+ // }
2023
+ //
2024
+ // if (val instanceof Value) {
2025
+ // return process(o, key, ((Value) val).getFieldValue());
2026
+ // }
2027
+ //
2028
+ // if (val instanceof Vertex) {
2029
+ // JSONObject obj = new JSONObject(true);
2030
+ // obj.put("vid", new String(((Vertex) val).getVid().getSVal()));
2031
+ // obj.put("str", val.toString());
2032
+ //
2033
+ // List<Tag> tags = ((Vertex) val).getTags();
2034
+ //
2035
+ // if (tags != null) {
2036
+ // JSONArray arr = new JSONArray();
2037
+ // for (int i = 0; i < tags.size(); i++) {
2038
+ // arr.add(process(o, String.valueOf(i), tags.get(i)));
2039
+ // }
2040
+ // obj.put("tags", arr);
2041
+ // }
2042
+ //
2043
+ // return obj;
2044
+ // }
2045
+ //
2046
+ // if (val instanceof Tag) {
2047
+ // JSONObject obj = new JSONObject(true);
2048
+ // obj.put("name", new String(((Tag) val).getName()));
2049
+ // obj.put("str", val.toString());
2050
+ //
2051
+ // Map<byte[], Value> props = ((Tag) val).getProps();
2052
+ //
2053
+ // if (props != null) {
2054
+ // JSONObject propsObj = new JSONObject(true);
2055
+ // props.forEach(new BiConsumer<byte[], Value>() {
2056
+ // @Override
2057
+ // public void accept(byte[] bytes, Value value) {
2058
+ // String k = new String(bytes);
2059
+ // propsObj.put(k, process(propsObj, k, value));
2060
+ // }
2061
+ // });
2062
+ // obj.put("props", propsObj);
2063
+ // }
2064
+ //
2065
+ // return obj;
2066
+ // }
2067
+ //
2068
+ // if (val instanceof Edge) {
2069
+ // JSONObject obj = new JSONObject(true);
2070
+ // obj.put("name", new String(((Edge) val).getName()));
2071
+ // obj.put("str", val.toString());
2072
+ //
2073
+ // Map<byte[], Value> props = ((Edge) val).getProps();
2074
+ //
2075
+ // if (props != null) {
2076
+ // JSONObject propsObj = new JSONObject(true);
2077
+ // props.forEach(new BiConsumer<byte[], Value>() {
2078
+ // @Override
2079
+ // public void accept(byte[] bytes, Value value) {
2080
+ // String k = new String(bytes);
2081
+ // propsObj.put(k, process(propsObj, k, value));
2082
+ // }
2083
+ // });
2084
+ // obj.put("props", propsObj);
2085
+ // }
2086
+ //
2087
+ // return obj;
2088
+ // }
2089
+ //
2090
+ // if (val instanceof NullType) {
2091
+ // return null;
2092
+ // }
2093
+ //
2094
+ // if (val instanceof DateWrapper) {
2095
+ // return ((DateWrapper) val).toString();
2096
+ // }
2097
+ //
2098
+ // if (val instanceof TimeWrapper) {
2099
+ // return ((TimeWrapper) val).getLocalTimeStr();
2100
+ // }
2101
+ //
2102
+ // if (val instanceof DateTimeWrapper) {
2103
+ // return ((DateTimeWrapper) val).getLocalDateTimeStr();
2104
+ // }
2105
+ //
2106
+ // if (val instanceof DurationWrapper) {
2107
+ // return ((DurationWrapper) val).getMicroseconds();
2108
+ // }
2109
+ //
2110
+ // if (val instanceof Date) {
2111
+ // Date d = (Date) val;
2112
+ // return new java.sql.Date(d.getYear() - 1900, d.getMonth(), d.getDay()).toString();
2113
+ // }
2114
+ //
2115
+ // if (val instanceof Time) {
2116
+ // Time t = (Time) val;
2117
+ // return new java.sql.Time(t.getHour(), t.getMinute(), t.getSec()).toString();
2118
+ // }
2119
+ //
2120
+ // if (val instanceof DateTime) {
2121
+ // DateTime dt = (DateTime) val;
2122
+ // // return new java.util.Date(dt.getYear(), dt.getNonth(), dt.getDayO, dt.getHour(), dt.getMinute(), dt.getSec0).toGnTString();
2123
+ // return new java.sql.Date(dt.getYear() - 1988, dt.getMonth(), dt.getDay())
2124
+ // + " " + new java.sql.Time(dt.getHour(), dt.getMinute(), dt.getSec());
2125
+ // }
2126
+ //
2127
+ // if (val instanceof Duration) {
2128
+ // return ((Duration) val).getMicroseconds();
2129
+ // }
2130
2130
2131
2131
return val ;
2132
2132
}
0 commit comments