commit
22b0ba9ee6
|
@ -7,7 +7,7 @@ import org.junit.Test;
|
||||||
import java.sql.*;
|
import java.sql.*;
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
public class DatabaseMetaDataTest extends BaseTest {
|
public class DatabaseMetaDataTest {
|
||||||
static Connection connection = null;
|
static Connection connection = null;
|
||||||
static PreparedStatement statement = null;
|
static PreparedStatement statement = null;
|
||||||
static String dbName = "test";
|
static String dbName = "test";
|
||||||
|
@ -23,20 +23,21 @@ public class DatabaseMetaDataTest extends BaseTest {
|
||||||
}
|
}
|
||||||
Properties properties = new Properties();
|
Properties properties = new Properties();
|
||||||
properties.setProperty(TSDBDriver.PROPERTY_KEY_HOST, host);
|
properties.setProperty(TSDBDriver.PROPERTY_KEY_HOST, host);
|
||||||
|
properties.setProperty(TSDBDriver.PROPERTY_KEY_USER, "root");
|
||||||
|
properties.setProperty(TSDBDriver.PROPERTY_KEY_PASSWORD, "taosdata");
|
||||||
properties.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
|
properties.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
|
||||||
properties.setProperty(TSDBDriver.PROPERTY_KEY_LOCALE, "en_US.UTF-8");
|
properties.setProperty(TSDBDriver.PROPERTY_KEY_LOCALE, "en_US.UTF-8");
|
||||||
properties.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
|
properties.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
|
||||||
connection = DriverManager.getConnection("jdbc:TAOS://" + host + ":0/", properties);
|
connection = DriverManager.getConnection("jdbc:TAOS://" + host + ":0/", properties);
|
||||||
|
|
||||||
String sql = "drop database if exists " + dbName;
|
String sql = "drop database if exists " + dbName;
|
||||||
statement = (TSDBPreparedStatement) connection.prepareStatement(sql);
|
statement = connection.prepareStatement(sql);
|
||||||
statement.executeUpdate("create database if not exists " + dbName);
|
statement.executeUpdate("create database if not exists " + dbName);
|
||||||
statement.executeUpdate("create table if not exists " + dbName + "." + tName + " (ts timestamp, k int, v int)");
|
statement.executeUpdate("create table if not exists " + dbName + "." + tName + " (ts timestamp, k int, v int)");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testMetaDataTest() throws SQLException {
|
public void testMetaDataTest() throws SQLException {
|
||||||
|
|
||||||
DatabaseMetaData databaseMetaData = connection.getMetaData();
|
DatabaseMetaData databaseMetaData = connection.getMetaData();
|
||||||
ResultSet resultSet = databaseMetaData.getTables(dbName, "t*", "t*", new String[]{"t"});
|
ResultSet resultSet = databaseMetaData.getTables(dbName, "t*", "t*", new String[]{"t"});
|
||||||
while (resultSet.next()) {
|
while (resultSet.next()) {
|
||||||
|
@ -180,7 +181,7 @@ public class DatabaseMetaDataTest extends BaseTest {
|
||||||
databaseMetaData.getCatalogs();
|
databaseMetaData.getCatalogs();
|
||||||
// databaseMetaData.getTableTypes();
|
// databaseMetaData.getTableTypes();
|
||||||
|
|
||||||
databaseMetaData.getColumns("", "", "", "");
|
databaseMetaData.getColumns(dbName, "", tName, "");
|
||||||
databaseMetaData.getColumnPrivileges("", "", "", "");
|
databaseMetaData.getColumnPrivileges("", "", "", "");
|
||||||
databaseMetaData.getTablePrivileges("", "", "");
|
databaseMetaData.getTablePrivileges("", "", "");
|
||||||
databaseMetaData.getBestRowIdentifier("", "", "", 0, false);
|
databaseMetaData.getBestRowIdentifier("", "", "", 0, false);
|
||||||
|
|
|
@ -19,7 +19,7 @@ public class AppMemoryLeakTest {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test(expected = Exception.class)
|
||||||
public void testCreateTooManyStatement() throws ClassNotFoundException, SQLException {
|
public void testCreateTooManyStatement() throws ClassNotFoundException, SQLException {
|
||||||
Class.forName("com.taosdata.jdbc.TSDBDriver");
|
Class.forName("com.taosdata.jdbc.TSDBDriver");
|
||||||
int stmtCnt = 0;
|
int stmtCnt = 0;
|
||||||
|
@ -30,15 +30,4 @@ public class AppMemoryLeakTest {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void main(String[] args) throws ClassNotFoundException, SQLException {
|
|
||||||
Class.forName("com.taosdata.jdbc.TSDBDriver");
|
|
||||||
int stmtCnt = 0;
|
|
||||||
Connection conn = DriverManager.getConnection("jdbc:TAOS://localhost:6030/?user=root&password=taosdata");
|
|
||||||
while (true) {
|
|
||||||
Statement stmt = conn.createStatement();
|
|
||||||
System.out.println(++stmtCnt + " : " + stmt);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -5,10 +5,6 @@ import org.junit.Test;
|
||||||
|
|
||||||
public class SqlSyntaxValidatorTest {
|
public class SqlSyntaxValidatorTest {
|
||||||
|
|
||||||
@Test
|
|
||||||
public void validateSqlSyntax() {
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void isSelectSQL() {
|
public void isSelectSQL() {
|
||||||
Assert.assertTrue(SqlSyntaxValidator.isSelectSql("select * from test.weather"));
|
Assert.assertTrue(SqlSyntaxValidator.isSelectSql("select * from test.weather"));
|
||||||
|
|
Loading…
Reference in New Issue