提交 b8e5487c 编写于 作者: Z zyyang

change JNI method name

上级 65b358d4
...@@ -57,13 +57,17 @@ public class TSDBJNIConnector { ...@@ -57,13 +57,17 @@ public class TSDBJNIConnector {
} }
} }
public static native void initImp(String configDir); private static native void initImp(String configDir);
public static native int setOptions(int optionIndex, String optionValue); private static native int setOptions(int optionIndex, String optionValue);
public static native String getTsCharset(); private static native String getTsCharset();
public static native int setConfig(String config); public static void setConfig(String config) {
setConfigImp(config);
}
private static native int setConfigImp(String config);
public boolean connect(String host, int port, String dbName, String user, String password) throws SQLException { public boolean connect(String host, int port, String dbName, String user, String password) throws SQLException {
if (this.taos != TSDBConstants.JNI_NULL_POINTER) { if (this.taos != TSDBConstants.JNI_NULL_POINTER) {
......
package com.taosdata.jdbc; package com.taosdata.jdbc;
import org.junit.After; import org.junit.After;
import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import java.sql.Connection; import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.SQLException; import java.sql.SQLException;
import java.sql.Statement; import java.sql.Statement;
import java.util.Arrays;
import static org.junit.Assert.*;
public class SetConfigurationInJNITest { public class SetConfigurationInJNITest {
private String host = "127.0.0.1"; private String host = "127.0.0.1";
private String dbname = "test_jni"; private String dbname = "test_jni";
private long maxSQLLength = 1024000;
private String debugFlagJSON = "{ \"debugFlag\": \"135\"}"; private String debugFlagJSON = "{ \"debugFlag\": \"135\"}";
private long maxSQLLength = 1024000;
private String maxSqlLengthJSON = "{ \"maxSQLLength\": " + maxSQLLength + "}"; private String maxSqlLengthJSON = "{ \"maxSQLLength\": " + maxSQLLength + "}";
@Test @Test
public void testDebugFlag() { public void setConfigBeforeConnectIsValid() {
try { try {
// when
TSDBJNIConnector.setConfig(debugFlagJSON); TSDBJNIConnector.setConfig(debugFlagJSON);
// init Connection conn = DriverManager.getConnection("jdbc:TAOS://" + host + ":0/?user=root&password=taosdata");
TSDBJNIConnector.initImp(null); Statement stmt = conn.createStatement();
TSDBJNIConnector.setOptions(0, null);
TSDBJNIConnector.setOptions(1, null);
TSDBJNIConnector.setOptions(2, null);
String tsCharset = TSDBJNIConnector.getTsCharset();
assertEquals("", tsCharset);
// connect
TSDBJNIConnector jniConnector = new TSDBJNIConnector();
boolean connected = jniConnector.connect(host, 0, null, "root", "taosdata");
assertTrue(connected);
String[] setupSqls = {
"drop database if exists " + dbname,
"create database if not exists " + dbname,
"use " + dbname,
"create table weather(ts timestamp, f1 int) tags(loc nchar(10))",
"insert into t1 using weather tags('beijing') values(now, 1)",
"drop database if exists " + dbname
};
Arrays.asList(setupSqls).forEach(sql -> { stmt.execute("drop database if exists " + dbname);
try { stmt.execute("create database if not exists " + dbname);
long setupSql = jniConnector.executeQuery(sql); stmt.execute("use " + dbname);
if (jniConnector.isUpdateQuery(setupSql)) { stmt.execute("create table weather(ts timestamp, f1 int) tags(loc nchar(10))");
jniConnector.freeResultSet(setupSql);
}
} catch (SQLException e) {
e.printStackTrace();
}
});
stmt.close();
conn.close();
} catch (SQLException e) { } catch (SQLException e) {
e.printStackTrace(); e.printStackTrace();
} }
} }
@Test @Test
public void testMaxSQLLength() { public void setConfigAfterConnectIsInvalid() {
}
@Test
public void setConfigAfterConnect() {
try { try {
Connection conn = DriverManager.getConnection("jdbc:TAOS:/" + host + ":0/?user=root&password"); Connection conn = DriverManager.getConnection("jdbc:TAOS://" + host + ":0/?user=root&password=taosdata");
TSDBJNIConnector.setConfig(debugFlagJSON); TSDBJNIConnector.setConfig(debugFlagJSON);
Statement stmt = conn.createStatement(); Statement stmt = conn.createStatement();
stmt.execute("drop database if exists " + dbname); stmt.execute("drop database if exists " + dbname);
...@@ -90,19 +57,4 @@ public class SetConfigurationInJNITest { ...@@ -90,19 +57,4 @@ public class SetConfigurationInJNITest {
e.printStackTrace(); e.printStackTrace();
} }
} }
@After
public void after() {
// try {
// Connection conn = DriverManager.getConnection("jdbc:TAOS:/" + host + ":0/?user=root&password");
// Statement stmt = conn.createStatement();
//
//// stmt.execute("drop database if exists " + dbname);
//
// stmt.close();
// conn.close();
// } catch (SQLException e) {
// e.printStackTrace();
// }
}
} }
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册