14
14
* limitations under the License.
15
15
*/
16
16
17
- package com ._4paradigm .hybridsql . fedb .sdk .impl ;
17
+ package com ._4paradigm .openmldb .sdk .impl ;
18
18
19
- import com ._4paradigm .hybridsql . fedb .*;
19
+ import com ._4paradigm .openmldb .*;
20
20
21
- import com ._4paradigm .hybridsql .fedb .jdbc .CallablePreparedStatement ;
22
- import com ._4paradigm .hybridsql .fedb .jdbc .SQLResultSet ;
21
+ import com ._4paradigm .openmldb .jdbc .CallablePreparedStatement ;
22
+ import com ._4paradigm .openmldb .jdbc .SQLResultSet ;
23
+ import com ._4paradigm .openmldb .sdk .QueryFuture ;
23
24
24
25
import java .sql .SQLException ;
25
26
import java .util .concurrent .TimeUnit ;
@@ -43,7 +44,7 @@ public BatchCallablePreparedStatementImpl(String db, String spName, SQLRouter ro
43
44
public SQLResultSet executeQuery () throws SQLException {
44
45
checkClosed ();
45
46
Status status = new Status ();
46
- com ._4paradigm .hybridsql . fedb .ResultSet resultSet = router .ExecuteSQLBatchRequest (
47
+ com ._4paradigm .openmldb .ResultSet resultSet = router .ExecuteSQLBatchRequest (
47
48
db , currentSql , currentRowBatch , status );
48
49
if (status .getCode () != 0 || resultSet == null ) {
49
50
String msg = status .getMsg ();
@@ -62,10 +63,10 @@ public SQLResultSet executeQuery() throws SQLException {
62
63
}
63
64
64
65
@ Override
65
- public com . _4paradigm . hybridsql . fedb . sdk . QueryFuture executeQueryAsync (long timeOut , TimeUnit unit ) throws SQLException {
66
+ public QueryFuture executeQueryAsync (long timeOut , TimeUnit unit ) throws SQLException {
66
67
checkClosed ();
67
68
Status status = new Status ();
68
- QueryFuture queryFuture = router .CallSQLBatchRequestProcedure (db , spName , unit .toMillis (timeOut ), currentRowBatch , status );
69
+ com . _4paradigm . openmldb . QueryFuture queryFuture = router .CallSQLBatchRequestProcedure (db , spName , unit .toMillis (timeOut ), currentRowBatch , status );
69
70
if (status .getCode () != 0 || queryFuture == null ) {
70
71
String msg = status .getMsg ();
71
72
status .delete ();
@@ -75,7 +76,7 @@ public com._4paradigm.hybridsql.fedb.sdk.QueryFuture executeQueryAsync(long time
75
76
throw new SQLException ("call procedure fail, msg: " + msg );
76
77
}
77
78
status .delete ();
78
- return new com . _4paradigm . hybridsql . fedb . sdk . QueryFuture (queryFuture );
79
+ return new QueryFuture (queryFuture );
79
80
}
80
81
81
82
@ Override
0 commit comments