diff --git a/cmake/install.inc b/cmake/install.inc
index f8b3b7c3c62c16df537a941d7f14ccb74bc64217..63764348d339d992e8ff3be1036c1c9921fd7b99 100755
--- a/cmake/install.inc
+++ b/cmake/install.inc
@@ -32,7 +32,7 @@ ELSEIF (TD_WINDOWS)
#INSTALL(TARGETS taos RUNTIME DESTINATION driver)
#INSTALL(TARGETS shell RUNTIME DESTINATION .)
IF (TD_MVN_INSTALLED)
- INSTALL(FILES ${LIBRARY_OUTPUT_PATH}/taos-jdbcdriver-2.0.29.jar DESTINATION connector/jdbc)
+ INSTALL(FILES ${LIBRARY_OUTPUT_PATH}/taos-jdbcdriver-2.0.30.jar DESTINATION connector/jdbc)
ENDIF ()
ELSEIF (TD_DARWIN)
SET(TD_MAKE_INSTALL_SH "${TD_COMMUNITY_DIR}/packaging/tools/make_install.sh")
diff --git a/src/connector/jdbc/CMakeLists.txt b/src/connector/jdbc/CMakeLists.txt
index 61e976cb184d3240bdc8917a5b2e5f3182d55fcc..a04902a422deadf590fa9f6172b1a58c739be19a 100644
--- a/src/connector/jdbc/CMakeLists.txt
+++ b/src/connector/jdbc/CMakeLists.txt
@@ -8,10 +8,9 @@ IF (TD_MVN_INSTALLED)
ADD_CUSTOM_COMMAND(OUTPUT ${JDBC_CMD_NAME}
POST_BUILD
COMMAND mvn -Dmaven.test.skip=true install -f ${CMAKE_CURRENT_SOURCE_DIR}/pom.xml
- COMMAND ${CMAKE_COMMAND} -E copy ${CMAKE_CURRENT_SOURCE_DIR}/target/taos-jdbcdriver-2.0.29.jar ${LIBRARY_OUTPUT_PATH}
+ COMMAND ${CMAKE_COMMAND} -E copy ${CMAKE_CURRENT_SOURCE_DIR}/target/taos-jdbcdriver-2.0.30.jar ${LIBRARY_OUTPUT_PATH}
COMMAND mvn -Dmaven.test.skip=true clean -f ${CMAKE_CURRENT_SOURCE_DIR}/pom.xml
COMMENT "build jdbc driver")
ADD_CUSTOM_TARGET(${JDBC_TARGET_NAME} ALL WORKING_DIRECTORY ${EXECUTABLE_OUTPUT_PATH} DEPENDS ${JDBC_CMD_NAME})
ENDIF ()
-
diff --git a/src/connector/jdbc/deploy-pom.xml b/src/connector/jdbc/deploy-pom.xml
index 968a9bf470ddde1996467467fa24cfd2fbf355e0..657645d46c00d6b7554c931a6dacca4695e34383 100755
--- a/src/connector/jdbc/deploy-pom.xml
+++ b/src/connector/jdbc/deploy-pom.xml
@@ -5,7 +5,7 @@
com.taosdata.jdbc
taos-jdbcdriver
- 2.0.29
+ 2.0.30
jar
JDBCDriver
diff --git a/src/connector/jdbc/pom.xml b/src/connector/jdbc/pom.xml
index e350e9738e9a15be58a3d288ddc2af564fbf3fbe..96e17bcd9b0eedc2116c2a8358e46d7b6e696b4e 100644
--- a/src/connector/jdbc/pom.xml
+++ b/src/connector/jdbc/pom.xml
@@ -3,7 +3,7 @@
4.0.0
com.taosdata.jdbc
taos-jdbcdriver
- 2.0.29
+ 2.0.30
jar
JDBCDriver
https://github.com/taosdata/TDengine/tree/master/src/connector/jdbc
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractDatabaseMetaData.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractDatabaseMetaData.java
index 5dcaa77ebd4a15087785a6a9b642b85f160f5287..48811d30a6903c077a9c0fb55176b0bc2ca9ba75 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractDatabaseMetaData.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractDatabaseMetaData.java
@@ -12,6 +12,9 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
private final static int DRIVER_MAJAR_VERSION = 2;
private final static int DRIVER_MINOR_VERSION = 0;
+ private String precision = "ms";
+ private String database;
+
public boolean allProceduresAreCallable() throws SQLException {
return false;
}
@@ -493,102 +496,105 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
public abstract ResultSet getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types) throws SQLException;
- protected ResultSet getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types, Connection connection) throws SQLException {
- try (Statement stmt = connection.createStatement()) {
- if (catalog == null || catalog.isEmpty())
- return null;
-
- ResultSet databases = stmt.executeQuery("show databases");
- String dbname = null;
- while (databases.next()) {
- dbname = databases.getString("name");
- if (dbname.equalsIgnoreCase(catalog))
- break;
- }
- databases.close();
- if (dbname == null)
- return null;
+ private List buildGetTablesColumnMetaDataList() {
+ List columnMetaDataList = new ArrayList<>();
+ columnMetaDataList.add(buildTableCatalogMeta(1)); // 1. TABLE_CAT
+ columnMetaDataList.add(buildTableSchemaMeta(2)); // 2. TABLE_SCHEM
+ columnMetaDataList.add(buildTableNameMeta(3)); // 3. TABLE_NAME
+ columnMetaDataList.add(buildTableTypeMeta(4)); // 4. TABLE_TYPE
+ columnMetaDataList.add(buildRemarksMeta(5)); // 5. remarks
+ columnMetaDataList.add(buildTypeCatMeta(6)); // 6. TYPE_CAT
+ columnMetaDataList.add(buildTypeSchemaMeta(7)); // 7. TYPE_SCHEM
+ columnMetaDataList.add(buildTypeNameMeta(8)); // 8. TYPE_NAME
+ columnMetaDataList.add(buildSelfReferencingColName(9)); // 9. SELF_REFERENCING_COL_NAME
+ columnMetaDataList.add(buildRefGenerationMeta(10)); // 10. REF_GENERATION
+ return columnMetaDataList;
+ }
+
+ private ColumnMetaData buildTypeCatMeta(int colIndex) {
+ ColumnMetaData col6 = new ColumnMetaData();
+ col6.setColIndex(colIndex);
+ col6.setColName("TYPE_CAT");
+ col6.setColType(Types.NCHAR);
+ return col6;
+ }
+
+ private ColumnMetaData buildTypeSchemaMeta(int colIndex) {
+ ColumnMetaData col7 = new ColumnMetaData();
+ col7.setColIndex(colIndex);
+ col7.setColName("TYPE_SCHEM");
+ col7.setColType(Types.NCHAR);
+ return col7;
+ }
+
+ private ColumnMetaData buildTypeNameMeta(int colIndex) {
+ ColumnMetaData col8 = new ColumnMetaData();
+ col8.setColIndex(colIndex);
+ col8.setColName("TYPE_NAME");
+ col8.setColType(Types.NCHAR);
+ return col8;
+ }
+
+ private ColumnMetaData buildSelfReferencingColName(int colIndex) {
+ ColumnMetaData col9 = new ColumnMetaData();
+ col9.setColIndex(colIndex);
+ col9.setColName("SELF_REFERENCING_COL_NAME");
+ col9.setColType(Types.NCHAR);
+ return col9;
+ }
+
+ private ColumnMetaData buildRefGenerationMeta(int colIndex) {
+ ColumnMetaData col10 = new ColumnMetaData();
+ col10.setColIndex(colIndex);
+ col10.setColName("REF_GENERATION");
+ col10.setColType(Types.NCHAR);
+ return col10;
+ }
- stmt.execute("use " + dbname);
- DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
- List columnMetaDataList = new ArrayList<>();
- ColumnMetaData col1 = new ColumnMetaData();
- col1.setColIndex(1);
- col1.setColName("TABLE_CAT");
- col1.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col1);
- ColumnMetaData col2 = new ColumnMetaData();
- col2.setColIndex(2);
- col2.setColName("TABLE_SCHEM");
- col2.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col2);
- ColumnMetaData col3 = new ColumnMetaData();
- col3.setColIndex(3);
- col3.setColName("TABLE_NAME");
- col3.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col3);
- ColumnMetaData col4 = new ColumnMetaData();
- col4.setColIndex(4);
- col4.setColName("TABLE_TYPE");
- col4.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col4);
- ColumnMetaData col5 = new ColumnMetaData();
- col5.setColIndex(5);
- col5.setColName("REMARKS");
- col5.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col5);
- ColumnMetaData col6 = new ColumnMetaData();
- col6.setColIndex(6);
- col6.setColName("TYPE_CAT");
- col6.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col6);
- ColumnMetaData col7 = new ColumnMetaData();
- col7.setColIndex(7);
- col7.setColName("TYPE_SCHEM");
- col7.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col7);
- ColumnMetaData col8 = new ColumnMetaData();
- col8.setColIndex(8);
- col8.setColName("TYPE_NAME");
- col8.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col8);
- ColumnMetaData col9 = new ColumnMetaData();
- col9.setColIndex(9);
- col9.setColName("SELF_REFERENCING_COL_NAME");
- col9.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col9);
- ColumnMetaData col10 = new ColumnMetaData();
- col10.setColIndex(10);
- col10.setColName("REF_GENERATION");
- col10.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col10);
- resultSet.setColumnMetaDataList(columnMetaDataList);
+ protected ResultSet getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types, Connection connection) throws SQLException {
+ if (catalog == null || catalog.isEmpty())
+ return null;
+ if (!isAvailableCatalog(connection, catalog))
+ return new EmptyResultSet();
- List rowDataList = new ArrayList<>();
+ DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
+ // set column metadata list
+ resultSet.setColumnMetaDataList(buildGetTablesColumnMetaDataList());
+ // set row data
+ List rowDataList = new ArrayList<>();
+ try (Statement stmt = connection.createStatement()) {
+ stmt.execute("use " + catalog);
ResultSet tables = stmt.executeQuery("show tables");
while (tables.next()) {
TSDBResultSetRowData rowData = new TSDBResultSetRowData(10);
- rowData.setString(0, dbname); //table_cat
- rowData.setString(1, null); //TABLE_SCHEM
- rowData.setString(2, tables.getString("table_name")); //TABLE_NAME
- rowData.setString(3, "TABLE"); //TABLE_TYPE
- rowData.setString(4, ""); //REMARKS
+ rowData.setStringValue(1, catalog); //TABLE_CAT
+ rowData.setStringValue(2, null); //TABLE_SCHEM
+ rowData.setStringValue(3, tables.getString("table_name")); //TABLE_NAME
+ rowData.setStringValue(4, "TABLE"); //TABLE_TYPE
+ rowData.setStringValue(5, ""); //REMARKS
rowDataList.add(rowData);
}
-
ResultSet stables = stmt.executeQuery("show stables");
while (stables.next()) {
TSDBResultSetRowData rowData = new TSDBResultSetRowData(10);
- rowData.setString(0, dbname); //TABLE_CAT
- rowData.setString(1, null); //TABLE_SCHEM
- rowData.setString(2, stables.getString("name")); //TABLE_NAME
- rowData.setString(3, "TABLE"); //TABLE_TYPE
- rowData.setString(4, "STABLE"); //REMARKS
+ rowData.setStringValue(1, catalog); //TABLE_CAT
+ rowData.setStringValue(2, null); //TABLE_SCHEM
+ rowData.setStringValue(3, stables.getString("name")); //TABLE_NAME
+ rowData.setStringValue(4, "TABLE"); //TABLE_TYPE
+ rowData.setStringValue(5, "STABLE"); //REMARKS
rowDataList.add(rowData);
}
resultSet.setRowDataList(rowDataList);
- return resultSet;
}
+ return resultSet;
+ }
+
+ private ColumnMetaData buildTableTypeMeta(int colIndex) {
+ ColumnMetaData col4 = new ColumnMetaData();
+ col4.setColIndex(colIndex);
+ col4.setColName("TABLE_TYPE");
+ col4.setColType(Types.NCHAR);
+ return col4;
}
public ResultSet getSchemas() throws SQLException {
@@ -597,25 +603,24 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
public abstract ResultSet getCatalogs() throws SQLException;
+ private List buildTableTypesColumnMetadataList() {
+ List columnMetaDataList = new ArrayList<>();
+ columnMetaDataList.add(buildTableTypeMeta(1));
+ return columnMetaDataList;
+ }
+
public ResultSet getTableTypes() throws SQLException {
DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
// set up ColumnMetaDataList
- List columnMetaDataList = new ArrayList<>();
- ColumnMetaData colMetaData = new ColumnMetaData();
- colMetaData.setColIndex(0);
- colMetaData.setColName("TABLE_TYPE");
- colMetaData.setColSize(10);
- colMetaData.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(colMetaData);
- resultSet.setColumnMetaDataList(columnMetaDataList);
+ resultSet.setColumnMetaDataList(buildTableTypesColumnMetadataList());
// set up rowDataList
List rowDataList = new ArrayList<>();
TSDBResultSetRowData rowData = new TSDBResultSetRowData(1);
- rowData.setString(0, "TABLE");
+ rowData.setStringValue(1, "TABLE");
rowDataList.add(rowData);
rowData = new TSDBResultSetRowData(1);
- rowData.setString(0, "STABLE");
+ rowData.setStringValue(1, "STABLE");
rowDataList.add(rowData);
resultSet.setRowDataList(rowDataList);
@@ -625,278 +630,330 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
public abstract ResultSet getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) throws SQLException;
protected ResultSet getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern, Connection conn) {
- try (Statement stmt = conn.createStatement()) {
- if (catalog == null || catalog.isEmpty())
- return null;
-
- ResultSet databases = stmt.executeQuery("show databases");
- String dbname = null;
- while (databases.next()) {
- dbname = databases.getString("name");
- if (dbname.equalsIgnoreCase(catalog))
- break;
- }
- databases.close();
- if (dbname == null)
- return null;
+ if (catalog == null || catalog.isEmpty())
+ return null;
+ if (!isAvailableCatalog(conn, catalog))
+ return new EmptyResultSet();
- stmt.execute("use " + dbname);
- DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
- // set up ColumnMetaDataList
-
- List columnMetaDataList = new ArrayList<>();
- // TABLE_CAT
- ColumnMetaData col1 = new ColumnMetaData();
- col1.setColIndex(1);
- col1.setColName("TABLE_CAT");
- col1.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col1);
- // TABLE_SCHEM
- ColumnMetaData col2 = new ColumnMetaData();
- col2.setColIndex(2);
- col2.setColName("TABLE_SCHEM");
- col2.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col2);
- // TABLE_NAME
- ColumnMetaData col3 = new ColumnMetaData();
- col3.setColIndex(3);
- col3.setColName("TABLE_NAME");
- col3.setColSize(193);
- col3.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col3);
- // COLUMN_NAME
- ColumnMetaData col4 = new ColumnMetaData();
- col4.setColIndex(4);
- col4.setColName("COLUMN_NAME");
- col4.setColSize(65);
- col4.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col4);
- // DATA_TYPE
- ColumnMetaData col5 = new ColumnMetaData();
- col5.setColIndex(5);
- col5.setColName("DATA_TYPE");
- col5.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col5);
- // TYPE_NAME
- ColumnMetaData col6 = new ColumnMetaData();
- col6.setColIndex(6);
- col6.setColName("TYPE_NAME");
- col6.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col6);
- // COLUMN_SIZE
- ColumnMetaData col7 = new ColumnMetaData();
- col7.setColIndex(7);
- col7.setColName("COLUMN_SIZE");
- col7.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col7);
- // BUFFER_LENGTH, not used
- ColumnMetaData col8 = new ColumnMetaData();
- col8.setColIndex(8);
- col8.setColName("BUFFER_LENGTH");
- columnMetaDataList.add(col8);
- // DECIMAL_DIGITS
- ColumnMetaData col9 = new ColumnMetaData();
- col9.setColIndex(9);
- col9.setColName("DECIMAL_DIGITS");
- col9.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col9);
- // add NUM_PREC_RADIX
- ColumnMetaData col10 = new ColumnMetaData();
- col10.setColIndex(10);
- col10.setColName("NUM_PREC_RADIX");
- col10.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col10);
- // NULLABLE
- ColumnMetaData col11 = new ColumnMetaData();
- col11.setColIndex(11);
- col11.setColName("NULLABLE");
- col11.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col11);
- // REMARKS
- ColumnMetaData col12 = new ColumnMetaData();
- col12.setColIndex(12);
- col12.setColName("REMARKS");
- col12.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col12);
- // COLUMN_DEF
- ColumnMetaData col13 = new ColumnMetaData();
- col13.setColIndex(13);
- col13.setColName("COLUMN_DEF");
- col13.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col13);
- //SQL_DATA_TYPE
- ColumnMetaData col14 = new ColumnMetaData();
- col14.setColIndex(14);
- col14.setColName("SQL_DATA_TYPE");
- col14.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col14);
- //SQL_DATETIME_SUB
- ColumnMetaData col15 = new ColumnMetaData();
- col15.setColIndex(15);
- col15.setColName("SQL_DATETIME_SUB");
- col15.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col15);
- //CHAR_OCTET_LENGTH
- ColumnMetaData col16 = new ColumnMetaData();
- col16.setColIndex(16);
- col16.setColName("CHAR_OCTET_LENGTH");
- col16.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col16);
- //ORDINAL_POSITION
- ColumnMetaData col17 = new ColumnMetaData();
- col17.setColIndex(17);
- col17.setColName("ORDINAL_POSITION");
- col17.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col17);
- // IS_NULLABLE
- ColumnMetaData col18 = new ColumnMetaData();
- col18.setColIndex(18);
- col18.setColName("IS_NULLABLE");
- col18.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col18);
- //SCOPE_CATALOG
- ColumnMetaData col19 = new ColumnMetaData();
- col19.setColIndex(19);
- col19.setColName("SCOPE_CATALOG");
- col19.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col19);
- //SCOPE_SCHEMA
- ColumnMetaData col20 = new ColumnMetaData();
- col20.setColIndex(20);
- col20.setColName("SCOPE_SCHEMA");
- col20.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col20);
- //SCOPE_TABLE
- ColumnMetaData col21 = new ColumnMetaData();
- col21.setColIndex(21);
- col21.setColName("SCOPE_TABLE");
- col21.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col21);
- //SOURCE_DATA_TYPE
- ColumnMetaData col22 = new ColumnMetaData();
- col22.setColIndex(22);
- col22.setColName("SOURCE_DATA_TYPE");
- col22.setColType(TSDBConstants.TSDB_DATA_TYPE_SMALLINT);
- columnMetaDataList.add(col22);
- //IS_AUTOINCREMENT
- ColumnMetaData col23 = new ColumnMetaData();
- col23.setColIndex(23);
- col23.setColName("IS_AUTOINCREMENT");
- col23.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col23);
- //IS_GENERATEDCOLUMN
- ColumnMetaData col24 = new ColumnMetaData();
- col24.setColIndex(24);
- col24.setColName("IS_GENERATEDCOLUMN");
- col24.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col24);
-
- resultSet.setColumnMetaDataList(columnMetaDataList);
- // set up rowDataList
- ResultSet rs = stmt.executeQuery("describe " + dbname + "." + tableNamePattern);
- List rowDataList = new ArrayList<>();
- int index = 0;
+ DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
+ // set up ColumnMetaDataList
+ resultSet.setColumnMetaDataList(buildGetColumnsColumnMetaDataList());
+ // set up rowDataList
+ List rowDataList = new ArrayList<>();
+ try (Statement stmt = conn.createStatement()) {
+ ResultSet rs = stmt.executeQuery("describe " + catalog + "." + tableNamePattern);
+ int rowIndex = 0;
while (rs.next()) {
TSDBResultSetRowData rowData = new TSDBResultSetRowData(24);
// set TABLE_CAT
- rowData.setString(0, dbname);
+ rowData.setStringValue(1, catalog);
+ // set TABLE_SCHEM
+ rowData.setStringValue(2, null);
// set TABLE_NAME
- rowData.setString(2, tableNamePattern);
+ rowData.setStringValue(3, tableNamePattern);
// set COLUMN_NAME
- rowData.setString(3, rs.getString("Field"));
+ rowData.setStringValue(4, rs.getString("Field"));
// set DATA_TYPE
String typeName = rs.getString("Type");
- rowData.setInt(4, getDataType(typeName));
+ rowData.setIntValue(5, TSDBConstants.typeName2JdbcType(typeName));
// set TYPE_NAME
- rowData.setString(5, typeName);
+ rowData.setStringValue(6, typeName);
// set COLUMN_SIZE
int length = rs.getInt("Length");
- rowData.setInt(6, getColumnSize(typeName, length));
+ rowData.setIntValue(7, calculateColumnSize(typeName, precision, length));
+ // set BUFFER LENGTH
+ rowData.setStringValue(8, null);
// set DECIMAL_DIGITS
- rowData.setInt(8, getDecimalDigits(typeName));
+ Integer decimalDigits = calculateDecimalDigits(typeName);
+ if (decimalDigits != null) {
+ rowData.setIntValue(9, decimalDigits);
+ } else {
+ rowData.setStringValue(9, null);
+ }
// set NUM_PREC_RADIX
- rowData.setInt(9, 10);
+ rowData.setIntValue(10, 10);
// set NULLABLE
- rowData.setInt(10, getNullable(index, typeName));
+ rowData.setIntValue(11, isNullable(rowIndex, typeName));
// set REMARKS
- rowData.setString(11, rs.getString("Note"));
+ String note = rs.getString("Note");
+ rowData.setStringValue(12, note.trim().isEmpty() ? null : note);
rowDataList.add(rowData);
- index++;
+ rowIndex++;
}
resultSet.setRowDataList(rowDataList);
- return resultSet;
-
} catch (SQLException e) {
e.printStackTrace();
}
- return null;
+ return resultSet;
}
- protected int getNullable(int index, String typeName) {
+ private int isNullable(int index, String typeName) {
if (index == 0 && "TIMESTAMP".equals(typeName))
return DatabaseMetaData.columnNoNulls;
return DatabaseMetaData.columnNullable;
}
- protected int getColumnSize(String typeName, int length) {
+ private Integer calculateColumnSize(String typeName, String precisionType, int length) {
switch (typeName) {
case "TIMESTAMP":
- return 23;
- default:
- return 0;
- }
- }
-
- protected int getDecimalDigits(String typeName) {
- switch (typeName) {
+ return precisionType.equals("ms") ? TSDBConstants.TIMESTAMP_MS_PRECISION : TSDBConstants.TIMESTAMP_US_PRECISION;
+ case "BOOL":
+ return TSDBConstants.BOOLEAN_PRECISION;
+ case "TINYINT":
+ return TSDBConstants.TINYINT_PRECISION;
+ case "SMALLINT":
+ return TSDBConstants.SMALLINT_PRECISION;
+ case "INT":
+ return TSDBConstants.INT_PRECISION;
+ case "BIGINT":
+ return TSDBConstants.BIGINT_PRECISION;
case "FLOAT":
- return 5;
+ return TSDBConstants.FLOAT_PRECISION;
case "DOUBLE":
- return 9;
+ return TSDBConstants.DOUBLE_PRECISION;
+ case "NCHAR":
+ case "BINARY":
+ return length;
default:
- return 0;
+ return null;
}
}
- protected int getDataType(String typeName) {
+ private Integer calculateDecimalDigits(String typeName) {
switch (typeName) {
- case "TIMESTAMP":
- return Types.TIMESTAMP;
+ case "TINYINT":
+ case "SMALLINT":
case "INT":
- return Types.INTEGER;
case "BIGINT":
- return Types.BIGINT;
- case "FLOAT":
- return Types.FLOAT;
- case "DOUBLE":
- return Types.DOUBLE;
- case "BINARY":
- return Types.BINARY;
- case "SMALLINT":
- return Types.SMALLINT;
- case "TINYINT":
- return Types.TINYINT;
- case "BOOL":
- return Types.BOOLEAN;
- case "NCHAR":
- return Types.NCHAR;
+ return 0;
default:
- return Types.NULL;
+ return null;
}
}
- public ResultSet getColumnPrivileges(String catalog, String schema, String table, String columnNamePattern)
- throws SQLException {
+ private ColumnMetaData buildTableCatalogMeta(int colIndex) {
+ ColumnMetaData col1 = new ColumnMetaData();
+ col1.setColIndex(colIndex);
+ col1.setColName("TABLE_CAT");
+ col1.setColType(Types.NCHAR);
+ return col1;
+ }
+
+ private ColumnMetaData buildTableSchemaMeta(int colIndex) {
+ ColumnMetaData col2 = new ColumnMetaData();
+ col2.setColIndex(colIndex);
+ col2.setColName("TABLE_SCHEM");
+ col2.setColType(Types.NCHAR);
+ return col2;
+ }
+
+ private ColumnMetaData buildTableNameMeta(int colIndex) {
+ ColumnMetaData col3 = new ColumnMetaData();
+ col3.setColIndex(colIndex);
+ col3.setColName("TABLE_NAME");
+ col3.setColSize(193);
+ col3.setColType(Types.NCHAR);
+ return col3;
+ }
+
+ private ColumnMetaData buildColumnNameMeta(int colIndex) {
+ ColumnMetaData col4 = new ColumnMetaData();
+ col4.setColIndex(colIndex);
+ col4.setColName("COLUMN_NAME");
+ col4.setColSize(65);
+ col4.setColType(Types.NCHAR);
+ return col4;
+ }
+
+ private ColumnMetaData buildDataTypeMeta(int colIndex) {
+ ColumnMetaData col5 = new ColumnMetaData();
+ col5.setColIndex(colIndex);
+ col5.setColName("DATA_TYPE");
+ col5.setColType(Types.INTEGER);
+ return col5;
+ }
+
+ private ColumnMetaData buildColumnSizeMeta() {
+ ColumnMetaData col7 = new ColumnMetaData();
+ col7.setColIndex(7);
+ col7.setColName("COLUMN_SIZE");
+ col7.setColType(Types.INTEGER);
+ return col7;
+ }
+
+ private ColumnMetaData buildBufferLengthMeta() {
+ ColumnMetaData col8 = new ColumnMetaData();
+ col8.setColIndex(8);
+ col8.setColName("BUFFER_LENGTH");
+ return col8;
+ }
+
+ private ColumnMetaData buildDecimalDigitsMeta() {
+ ColumnMetaData col9 = new ColumnMetaData();
+ col9.setColIndex(9);
+ col9.setColName("DECIMAL_DIGITS");
+ col9.setColType(Types.INTEGER);
+ return col9;
+ }
+
+ private ColumnMetaData buildNumPrecRadixMeta() {
+ ColumnMetaData col10 = new ColumnMetaData();
+ col10.setColIndex(10);
+ col10.setColName("NUM_PREC_RADIX");
+ col10.setColType(Types.INTEGER);
+ return col10;
+ }
+
+ private ColumnMetaData buildNullableMeta() {
+ ColumnMetaData col11 = new ColumnMetaData();
+ col11.setColIndex(11);
+ col11.setColName("NULLABLE");
+ col11.setColType(Types.INTEGER);
+ return col11;
+ }
+
+ private ColumnMetaData buildRemarksMeta(int colIndex) {
+ ColumnMetaData col12 = new ColumnMetaData();
+ col12.setColIndex(colIndex);
+ col12.setColName("REMARKS");
+ col12.setColType(Types.NCHAR);
+ return col12;
+ }
+
+ private ColumnMetaData buildColumnDefMeta() {
+ ColumnMetaData col13 = new ColumnMetaData();
+ col13.setColIndex(13);
+ col13.setColName("COLUMN_DEF");
+ col13.setColType(Types.NCHAR);
+ return col13;
+ }
+
+ private ColumnMetaData buildSqlDataTypeMeta() {
+ ColumnMetaData col14 = new ColumnMetaData();
+ col14.setColIndex(14);
+ col14.setColName("SQL_DATA_TYPE");
+ col14.setColType(Types.INTEGER);
+ return col14;
+ }
+
+ private ColumnMetaData buildSqlDatetimeSubMeta() {
+ ColumnMetaData col15 = new ColumnMetaData();
+ col15.setColIndex(15);
+ col15.setColName("SQL_DATETIME_SUB");
+ col15.setColType(Types.INTEGER);
+ return col15;
+ }
+
+ private ColumnMetaData buildCharOctetLengthMeta() {
+ ColumnMetaData col16 = new ColumnMetaData();
+ col16.setColIndex(16);
+ col16.setColName("CHAR_OCTET_LENGTH");
+ col16.setColType(Types.INTEGER);
+ return col16;
+ }
+
+ private ColumnMetaData buildOrdinalPositionMeta() {
+ ColumnMetaData col17 = new ColumnMetaData();
+ col17.setColIndex(17);
+ col17.setColName("ORDINAL_POSITION");
+ col17.setColType(Types.INTEGER);
+ return col17;
+ }
+
+ private ColumnMetaData buildIsNullableMeta() {
+ ColumnMetaData col18 = new ColumnMetaData();
+ col18.setColIndex(18);
+ col18.setColName("IS_NULLABLE");
+ col18.setColType(Types.NCHAR);
+ return col18;
+ }
+
+ private ColumnMetaData buildScopeCatalogMeta() {
+ ColumnMetaData col19 = new ColumnMetaData();
+ col19.setColIndex(19);
+ col19.setColName("SCOPE_CATALOG");
+ col19.setColType(Types.NCHAR);
+ return col19;
+ }
+
+ private ColumnMetaData buildScopeSchemaMeta() {
+ ColumnMetaData col20 = new ColumnMetaData();
+ col20.setColIndex(20);
+ col20.setColName("SCOPE_SCHEMA");
+ col20.setColType(Types.NCHAR);
+ return col20;
+ }
+
+ private ColumnMetaData buildScopeTableMeta() {
+ ColumnMetaData col21 = new ColumnMetaData();
+ col21.setColIndex(21);
+ col21.setColName("SCOPE_TABLE");
+ col21.setColType(Types.NCHAR);
+ return col21;
+ }
+
+ private ColumnMetaData buildSourceDataTypeMeta() {
+ ColumnMetaData col22 = new ColumnMetaData();
+ col22.setColIndex(22);
+ col22.setColName("SOURCE_DATA_TYPE");
+ col22.setColType(TSDBConstants.TSDB_DATA_TYPE_SMALLINT);
+ return col22;
+ }
+
+ private ColumnMetaData buildIsAutoIncrementMeta() {
+ ColumnMetaData col23 = new ColumnMetaData();
+ col23.setColIndex(23);
+ col23.setColName("IS_AUTOINCREMENT");
+ col23.setColType(Types.NCHAR);
+ return col23;
+ }
+
+ private ColumnMetaData buildIsGeneratedColumnMeta() {
+ ColumnMetaData col24 = new ColumnMetaData();
+ col24.setColIndex(24);
+ col24.setColName("IS_GENERATEDCOLUMN");
+ col24.setColType(Types.NCHAR);
+ return col24;
+ }
+
+ private List buildGetColumnsColumnMetaDataList() {
+ List columnMetaDataList = new ArrayList<>();
+ columnMetaDataList.add(buildTableCatalogMeta(1)); //1. TABLE_CAT
+ columnMetaDataList.add(buildTableSchemaMeta(2)); //2. TABLE_SCHEMA
+ columnMetaDataList.add(buildTableNameMeta(3)); //3. TABLE_NAME
+ columnMetaDataList.add(buildColumnNameMeta(4)); //4. COLUMN_NAME
+ columnMetaDataList.add(buildDataTypeMeta(5)); //5. DATA_TYPE
+ columnMetaDataList.add(buildTypeNameMeta(6)); //6. TYPE_NAME
+ columnMetaDataList.add(buildColumnSizeMeta()); //7. COLUMN_SIZE
+ columnMetaDataList.add(buildBufferLengthMeta()); //8. BUFFER_LENGTH, not used
+ columnMetaDataList.add(buildDecimalDigitsMeta()); //9. DECIMAL_DIGITS
+ columnMetaDataList.add(buildNumPrecRadixMeta()); //10. NUM_PREC_RADIX
+ columnMetaDataList.add(buildNullableMeta()); //11. NULLABLE
+ columnMetaDataList.add(buildRemarksMeta(12)); //12. REMARKS
+ columnMetaDataList.add(buildColumnDefMeta()); //13. COLUMN_DEF
+ columnMetaDataList.add(buildSqlDataTypeMeta()); //14. SQL_DATA_TYPE
+ columnMetaDataList.add(buildSqlDatetimeSubMeta()); //15. SQL_DATETIME_SUB
+ columnMetaDataList.add(buildCharOctetLengthMeta()); //16. CHAR_OCTET_LENGTH
+ columnMetaDataList.add(buildOrdinalPositionMeta()); //17. ORDINAL_POSITION
+ columnMetaDataList.add(buildIsNullableMeta()); //18. IS_NULLABLE
+ columnMetaDataList.add(buildScopeCatalogMeta()); //19. SCOPE_CATALOG
+ columnMetaDataList.add(buildScopeSchemaMeta()); //20. SCOPE_SCHEMA
+ columnMetaDataList.add(buildScopeTableMeta()); //21. SCOPE_TABLE
+ columnMetaDataList.add(buildSourceDataTypeMeta()); //22. SOURCE_DATA_TYPE
+ columnMetaDataList.add(buildIsAutoIncrementMeta()); //23. IS_AUTOINCREMENT
+ columnMetaDataList.add(buildIsGeneratedColumnMeta()); //24. IS_GENERATEDCOLUMN
+ return columnMetaDataList;
+ }
+
+ public ResultSet getColumnPrivileges(String catalog, String schema, String table, String columnNamePattern) throws SQLException {
return getEmptyResultSet();
}
- public ResultSet getTablePrivileges(String catalog, String schemaPattern, String tableNamePattern)
- throws SQLException {
+ public ResultSet getTablePrivileges(String catalog, String schemaPattern, String tableNamePattern) throws SQLException {
return getEmptyResultSet();
}
- public ResultSet getBestRowIdentifier(String catalog, String schema, String table, int scope, boolean nullable)
- throws SQLException {
+ public ResultSet getBestRowIdentifier(String catalog, String schema, String table, int scope, boolean nullable) throws SQLException {
return getEmptyResultSet();
}
@@ -914,8 +971,7 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
return getEmptyResultSet();
}
- public ResultSet getCrossReference(String parentCatalog, String parentSchema, String parentTable,
- String foreignCatalog, String foreignSchema, String foreignTable) throws SQLException {
+ public ResultSet getCrossReference(String parentCatalog, String parentSchema, String parentTable, String foreignCatalog, String foreignSchema, String foreignTable) throws SQLException {
return getEmptyResultSet();
}
@@ -923,8 +979,7 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
return getEmptyResultSet();
}
- public ResultSet getIndexInfo(String catalog, String schema, String table, boolean unique, boolean approximate)
- throws SQLException {
+ public ResultSet getIndexInfo(String catalog, String schema, String table, boolean unique, boolean approximate) throws SQLException {
return getEmptyResultSet();
}
@@ -976,8 +1031,7 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
return false;
}
- public ResultSet getUDTs(String catalog, String schemaPattern, String typeNamePattern, int[] types)
- throws SQLException {
+ public ResultSet getUDTs(String catalog, String schemaPattern, String typeNamePattern, int[] types) throws SQLException {
return getEmptyResultSet();
}
@@ -1005,8 +1059,7 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
public abstract ResultSet getSuperTables(String catalog, String schemaPattern, String tableNamePattern) throws SQLException;
- public ResultSet getAttributes(String catalog, String schemaPattern, String typeNamePattern,
- String attributeNamePattern) throws SQLException {
+ public ResultSet getAttributes(String catalog, String schemaPattern, String typeNamePattern, String attributeNamePattern) throws SQLException {
return getEmptyResultSet();
}
@@ -1069,18 +1122,15 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
return getEmptyResultSet();
}
- public ResultSet getFunctions(String catalog, String schemaPattern, String functionNamePattern)
- throws SQLException {
+ public ResultSet getFunctions(String catalog, String schemaPattern, String functionNamePattern) throws SQLException {
return getEmptyResultSet();
}
- public ResultSet getFunctionColumns(String catalog, String schemaPattern, String functionNamePattern,
- String columnNamePattern) throws SQLException {
+ public ResultSet getFunctionColumns(String catalog, String schemaPattern, String functionNamePattern, String columnNamePattern) throws SQLException {
return getEmptyResultSet();
}
- public ResultSet getPseudoColumns(String catalog, String schemaPattern, String tableNamePattern,
- String columnNamePattern) throws SQLException {
+ public ResultSet getPseudoColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) throws SQLException {
return getEmptyResultSet();
}
@@ -1093,164 +1143,142 @@ public abstract class AbstractDatabaseMetaData extends WrapperImpl implements Da
}
protected ResultSet getCatalogs(Connection conn) throws SQLException {
- try (Statement stmt = conn.createStatement()) {
- DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
- // set up ColumnMetaDataList
- List columnMetaDataList = new ArrayList<>();
- // TABLE_CAT
- ColumnMetaData col1 = new ColumnMetaData();
- col1.setColIndex(1);
- col1.setColName("TABLE_CAT");
- col1.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col1);
-
- resultSet.setColumnMetaDataList(columnMetaDataList);
+ DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
+ // set up ColumnMetaDataList
+ List columnMetaDataList = new ArrayList<>();
+ columnMetaDataList.add(buildTableCatalogMeta(1)); // 1. TABLE_CAT
+ resultSet.setColumnMetaDataList(columnMetaDataList);
+ try (Statement stmt = conn.createStatement()) {
List rowDataList = new ArrayList<>();
ResultSet rs = stmt.executeQuery("show databases");
while (rs.next()) {
TSDBResultSetRowData rowData = new TSDBResultSetRowData(1);
- rowData.setString(0, rs.getString("name"));
+ rowData.setStringValue(1, rs.getString("name"));
rowDataList.add(rowData);
}
resultSet.setRowDataList(rowDataList);
- return resultSet;
}
+ return resultSet;
}
protected ResultSet getPrimaryKeys(String catalog, String schema, String table, Connection conn) throws SQLException {
- try (Statement stmt = conn.createStatement()) {
- if (catalog == null || catalog.isEmpty())
- return null;
+ if (catalog == null || catalog.isEmpty())
+ return null;
+ if (!isAvailableCatalog(conn, catalog))
+ return new EmptyResultSet();
- ResultSet databases = stmt.executeQuery("show databases");
- String dbname = null;
- while (databases.next()) {
- dbname = databases.getString("name");
- if (dbname.equalsIgnoreCase(catalog))
- break;
- }
- databases.close();
- if (dbname == null)
- return null;
-
- stmt.execute("use " + dbname);
- DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
+ DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
+ try (Statement stmt = conn.createStatement()) {
// set up ColumnMetaDataList
- List columnMetaDataList = new ArrayList<>();
- // TABLE_CAT
- ColumnMetaData col1 = new ColumnMetaData();
- col1.setColIndex(0);
- col1.setColName("TABLE_CAT");
- col1.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col1);
- // TABLE_SCHEM
- ColumnMetaData col2 = new ColumnMetaData();
- col2.setColIndex(1);
- col2.setColName("TABLE_SCHEM");
- col2.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col2);
- // TABLE_NAME
- ColumnMetaData col3 = new ColumnMetaData();
- col3.setColIndex(2);
- col3.setColName("TABLE_NAME");
- col3.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col3);
- // COLUMN_NAME
- ColumnMetaData col4 = new ColumnMetaData();
- col4.setColIndex(3);
- col4.setColName("COLUMN_NAME");
- col4.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col4);
- // KEY_SEQ
- ColumnMetaData col5 = new ColumnMetaData();
- col5.setColIndex(4);
- col5.setColName("KEY_SEQ");
- col5.setColType(TSDBConstants.TSDB_DATA_TYPE_INT);
- columnMetaDataList.add(col5);
- // PK_NAME
- ColumnMetaData col6 = new ColumnMetaData();
- col6.setColIndex(5);
- col6.setColName("PK_NAME");
- col6.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col6);
- resultSet.setColumnMetaDataList(columnMetaDataList);
-
+ resultSet.setColumnMetaDataList(buildGetPrimaryKeysMetadataList());
// set rowData
List rowDataList = new ArrayList<>();
- ResultSet rs = stmt.executeQuery("describe " + dbname + "." + table);
+ ResultSet rs = stmt.executeQuery("describe " + catalog + "." + table);
rs.next();
TSDBResultSetRowData rowData = new TSDBResultSetRowData(6);
- rowData.setString(0, null);
- rowData.setString(1, null);
- rowData.setString(2, table);
- String pkName = rs.getString(1);
- rowData.setString(3, pkName);
- rowData.setInt(4, 1);
- rowData.setString(5, pkName);
+ rowData.setStringValue(1, catalog);
+ rowData.setStringValue(2, null);
+ rowData.setStringValue(3, table);
+ String primaryKey = rs.getString("Field");
+ rowData.setStringValue(4, primaryKey);
+ rowData.setShortValue(5, (short) 1);
+ rowData.setStringValue(6, primaryKey);
rowDataList.add(rowData);
resultSet.setRowDataList(rowDataList);
- return resultSet;
}
+ return resultSet;
}
- protected ResultSet getSuperTables(String catalog, String schemaPattern, String tableNamePattern, Connection conn) throws SQLException {
- try (Statement stmt = conn.createStatement()) {
- if (catalog == null || catalog.isEmpty())
- return null;
+ private List buildGetPrimaryKeysMetadataList() {
+ List columnMetaDataList = new ArrayList<>();
+ columnMetaDataList.add(buildTableCatalogMeta(1)); // 1. TABLE_CAT
+ columnMetaDataList.add(buildTableSchemaMeta(2)); // 2. TABLE_SCHEM
+ columnMetaDataList.add(buildTableNameMeta(3)); // 3. TABLE_NAME
+ columnMetaDataList.add(buildColumnNameMeta(4)); // 4. COLUMN_NAME
+ columnMetaDataList.add(buildKeySeqMeta(5)); // 5. KEY_SEQ
+ columnMetaDataList.add(buildPrimaryKeyNameMeta(6)); // 6. PK_NAME
+ return columnMetaDataList;
+ }
+
+ private ColumnMetaData buildKeySeqMeta(int colIndex) {
+ ColumnMetaData col5 = new ColumnMetaData();
+ col5.setColIndex(colIndex);
+ col5.setColName("KEY_SEQ");
+ col5.setColType(Types.SMALLINT);
+ return col5;
+ }
+
+ private ColumnMetaData buildPrimaryKeyNameMeta(int colIndex) {
+ ColumnMetaData col6 = new ColumnMetaData();
+ col6.setColIndex(colIndex);
+ col6.setColName("PK_NAME");
+ col6.setColType(Types.NCHAR);
+ return col6;
+ }
+ private boolean isAvailableCatalog(Connection connection, String catalog) {
+ try (Statement stmt = connection.createStatement()) {
ResultSet databases = stmt.executeQuery("show databases");
- String dbname = null;
while (databases.next()) {
- dbname = databases.getString("name");
+ String dbname = databases.getString("name");
+ this.database = dbname;
+ this.precision = databases.getString("precision");
if (dbname.equalsIgnoreCase(catalog))
- break;
+ return true;
}
databases.close();
- if (dbname == null)
- return null;
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ return false;
+ }
- stmt.execute("use " + dbname);
- DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
- // set up ColumnMetaDataList
- List columnMetaDataList = new ArrayList<>();
- // TABLE_CAT
- ColumnMetaData col1 = new ColumnMetaData();
- col1.setColIndex(0);
- col1.setColName("TABLE_CAT");
- col1.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col1);
- // TABLE_SCHEM
- ColumnMetaData col2 = new ColumnMetaData();
- col2.setColIndex(1);
- col2.setColName("TABLE_SCHEM");
- col2.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col2);
- // TABLE_NAME
- ColumnMetaData col3 = new ColumnMetaData();
- col3.setColIndex(2);
- col3.setColName("TABLE_NAME");
- col3.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col3);
- // SUPERTABLE_NAME
- ColumnMetaData col4 = new ColumnMetaData();
- col4.setColIndex(3);
- col4.setColName("SUPERTABLE_NAME");
- col4.setColType(TSDBConstants.TSDB_DATA_TYPE_NCHAR);
- columnMetaDataList.add(col4);
- resultSet.setColumnMetaDataList(columnMetaDataList);
+ protected ResultSet getSuperTables(String catalog, String schemaPattern, String tableNamePattern, Connection conn) throws SQLException {
+ if (catalog == null || catalog.isEmpty())
+ return null;
+
+ if (!isAvailableCatalog(conn, catalog)) {
+ return new EmptyResultSet();
+ }
+ DatabaseMetaDataResultSet resultSet = new DatabaseMetaDataResultSet();
+ try (Statement stmt = conn.createStatement()) {
+ // set up ColumnMetaDataList
+ resultSet.setColumnMetaDataList(buildGetSuperTablesColumnMetaDataList());
+ // set result set row data
+ stmt.execute("use " + catalog);
ResultSet rs = stmt.executeQuery("show tables like '" + tableNamePattern + "'");
List rowDataList = new ArrayList<>();
while (rs.next()) {
TSDBResultSetRowData rowData = new TSDBResultSetRowData(4);
- rowData.setString(2, rs.getString(1));
- rowData.setString(3, rs.getString(4));
+ rowData.setStringValue(1, catalog);
+ rowData.setStringValue(2, null);
+ rowData.setStringValue(3, rs.getString("table_name"));
+ rowData.setStringValue(4, rs.getString("stable_name"));
rowDataList.add(rowData);
}
resultSet.setRowDataList(rowDataList);
- return resultSet;
}
+ return resultSet;
+ }
+
+ private List buildGetSuperTablesColumnMetaDataList() {
+ List columnMetaDataList = new ArrayList<>();
+ columnMetaDataList.add(buildTableCatalogMeta(1)); // 1. TABLE_CAT
+ columnMetaDataList.add(buildTableSchemaMeta(2)); // 2. TABLE_SCHEM
+ columnMetaDataList.add(buildTableNameMeta(3)); // 3. TABLE_NAME
+ columnMetaDataList.add(buildSuperTableNameMeta(4)); // 4. SUPERTABLE_NAME
+ return columnMetaDataList;
}
+
+ private ColumnMetaData buildSuperTableNameMeta(int colIndex) {
+ ColumnMetaData col4 = new ColumnMetaData();
+ col4.setColIndex(colIndex);
+ col4.setColName("SUPERTABLE_NAME");
+ col4.setColType(Types.NCHAR);
+ return col4;
+ }
+
}
\ No newline at end of file
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractParameterMetaData.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractParameterMetaData.java
index 7df7252ae2010b5aa5e8f74de2cca55844e25b83..cb6c7d40ad1f1e12324043d78cb423fcfd46dca8 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractParameterMetaData.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractParameterMetaData.java
@@ -1,5 +1,7 @@
package com.taosdata.jdbc;
+import com.sun.org.apache.xpath.internal.operations.Bool;
+
import java.sql.ParameterMetaData;
import java.sql.SQLException;
import java.sql.Timestamp;
@@ -49,6 +51,22 @@ public abstract class AbstractParameterMetaData extends WrapperImpl implements P
if (param < 1 && param >= parameters.length)
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_PARAMETER_INDEX_OUT_RANGE);
+ if (parameters[param - 1] instanceof Boolean)
+ return TSDBConstants.BOOLEAN_PRECISION;
+ if (parameters[param - 1] instanceof Byte)
+ return TSDBConstants.TINYINT_PRECISION;
+ if (parameters[param - 1] instanceof Short)
+ return TSDBConstants.SMALLINT_PRECISION;
+ if (parameters[param - 1] instanceof Integer)
+ return TSDBConstants.INT_PRECISION;
+ if (parameters[param - 1] instanceof Long)
+ return TSDBConstants.BIGINT_PRECISION;
+ if (parameters[param - 1] instanceof Timestamp)
+ return TSDBConstants.TIMESTAMP_MS_PRECISION;
+ if (parameters[param - 1] instanceof Float)
+ return TSDBConstants.FLOAT_PRECISION;
+ if (parameters[param - 1] instanceof Double)
+ return TSDBConstants.DOUBLE_PRECISION;
if (parameters[param - 1] instanceof String)
return ((String) parameters[param - 1]).length();
if (parameters[param - 1] instanceof byte[])
@@ -60,6 +78,11 @@ public abstract class AbstractParameterMetaData extends WrapperImpl implements P
public int getScale(int param) throws SQLException {
if (param < 1 && param >= parameters.length)
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_PARAMETER_INDEX_OUT_RANGE);
+
+ if (parameters[param - 1] instanceof Float)
+ return TSDBConstants.FLOAT_SCALE;
+ if (parameters[param - 1] instanceof Double)
+ return TSDBConstants.DOUBLE_SCALE;
return 0;
}
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractResultSet.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractResultSet.java
index f8ea9af4230e9584197f1141dc5a4f7c1621b3ff..e17548055c792e900a1e2fb5b510de8bf65de7a7 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractResultSet.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/AbstractResultSet.java
@@ -66,10 +66,16 @@ public abstract class AbstractResultSet extends WrapperImpl implements ResultSet
public abstract byte[] getBytes(int columnIndex) throws SQLException;
@Override
- public abstract Date getDate(int columnIndex) throws SQLException;
+ public Date getDate(int columnIndex) throws SQLException {
+ Timestamp timestamp = getTimestamp(columnIndex);
+ return timestamp == null ? null : new Date(timestamp.getTime());
+ }
@Override
- public abstract Time getTime(int columnIndex) throws SQLException;
+ public Time getTime(int columnIndex) throws SQLException {
+ Timestamp timestamp = getTimestamp(columnIndex);
+ return timestamp == null ? null : new Time(timestamp.getTime());
+ }
@Override
public abstract Timestamp getTimestamp(int columnIndex) throws SQLException;
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/DatabaseMetaDataResultSet.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/DatabaseMetaDataResultSet.java
index f6a0fcca316cb07d28c71a4e1d51d9405de083ba..cd266529f34c0693a9891af33c12705b90132800 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/DatabaseMetaDataResultSet.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/DatabaseMetaDataResultSet.java
@@ -14,76 +14,42 @@
*****************************************************************************/
package com.taosdata.jdbc;
-import java.io.InputStream;
-import java.io.Reader;
import java.math.BigDecimal;
-import java.net.URL;
-import java.sql.Date;
import java.sql.*;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Iterator;
+import java.util.List;
/*
- * TDengine only supports a subset of the standard SQL, thus this implemetation of the
+ * TDengine only supports a subset of the standard SQL, thus this implementation of the
* standard JDBC API contains more or less some adjustments customized for certain
* compatibility needs.
*/
-public class DatabaseMetaDataResultSet implements ResultSet {
+public class DatabaseMetaDataResultSet extends AbstractResultSet {
- private List columnMetaDataList;
- private List rowDataList;
+ private List columnMetaDataList = new ArrayList<>();
+ private List rowDataList = new ArrayList<>();
private TSDBResultSetRowData rowCursor;
// position of cursor, starts from 0 as beforeFirst, increases as next() is called
private int cursorRowNumber = 0;
- public DatabaseMetaDataResultSet() {
- rowDataList = new ArrayList();
- columnMetaDataList = new ArrayList();
- }
-
- public List getRowDataList() {
- return rowDataList;
- }
-
public void setRowDataList(List rowDataList) {
this.rowDataList = rowDataList;
}
- public List getColumnMetaDataList() {
- return columnMetaDataList;
- }
-
public void setColumnMetaDataList(List columnMetaDataList) {
this.columnMetaDataList = columnMetaDataList;
}
- public TSDBResultSetRowData getRowCursor() {
- return rowCursor;
- }
-
- public void setRowCursor(TSDBResultSetRowData rowCursor) {
- this.rowCursor = rowCursor;
- }
-
@Override
public boolean next() throws SQLException {
-// boolean ret = false;
-// if (rowDataList.size() > 0) {
-// ret = rowDataList.iterator().hasNext();
-// if (ret) {
-// rowCursor = rowDataList.iterator().next();
-// cursorRowNumber++;
-// }
-// }
-// return ret;
-
- /**** add by zyyang 2020-09-29 ****************/
boolean ret = false;
if (!rowDataList.isEmpty() && cursorRowNumber < rowDataList.size()) {
rowCursor = rowDataList.get(cursorRowNumber++);
ret = true;
}
-
return ret;
}
@@ -99,189 +65,72 @@ public class DatabaseMetaDataResultSet implements ResultSet {
@Override
public String getString(int columnIndex) throws SQLException {
- columnIndex--;
- int colType = columnMetaDataList.get(columnIndex).getColType();
- return rowCursor.getString(columnIndex, colType);
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getString(columnIndex, nativeType);
}
@Override
public boolean getBoolean(int columnIndex) throws SQLException {
- columnIndex--;
- return rowCursor.getBoolean(columnIndex, columnMetaDataList.get(columnIndex).getColType());
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getBoolean(columnIndex, nativeType);
}
@Override
public byte getByte(int columnIndex) throws SQLException {
- columnIndex--;
- return (byte) rowCursor.getInt(columnIndex, columnMetaDataList.get(columnIndex).getColType());
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return (byte) rowCursor.getInt(columnIndex, nativeType);
}
@Override
public short getShort(int columnIndex) throws SQLException {
- columnIndex--;
- return (short) rowCursor.getInt(columnIndex, columnMetaDataList.get(columnIndex).getColType());
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return (short) rowCursor.getInt(columnIndex, nativeType);
}
@Override
public int getInt(int columnIndex) throws SQLException {
- columnIndex--;
- return rowCursor.getInt(columnIndex, columnMetaDataList.get(columnIndex).getColType());
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getInt(columnIndex, nativeType);
}
@Override
public long getLong(int columnIndex) throws SQLException {
- columnIndex--;
- return rowCursor.getLong(columnIndex, columnMetaDataList.get(columnIndex).getColType());
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getLong(columnIndex, nativeType);
}
@Override
public float getFloat(int columnIndex) throws SQLException {
- columnIndex--;
- return rowCursor.getFloat(columnIndex, columnMetaDataList.get(columnIndex).getColType());
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getFloat(columnIndex, nativeType);
}
@Override
public double getDouble(int columnIndex) throws SQLException {
- columnIndex--;
- return rowCursor.getDouble(columnIndex, columnMetaDataList.get(columnIndex).getColType());
- }
-
- @Override
- public BigDecimal getBigDecimal(int columnIndex, int scale) throws SQLException {
- columnIndex--;
- return new BigDecimal(rowCursor.getDouble(columnIndex, columnMetaDataList.get(columnIndex).getColType()));
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getDouble(columnIndex, nativeType);
}
@Override
public byte[] getBytes(int columnIndex) throws SQLException {
- columnIndex--;
- return (rowCursor.getString(columnIndex, columnMetaDataList.get(columnIndex).getColType())).getBytes();
- }
-
- @Override
- public Date getDate(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public Time getTime(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return (rowCursor.getString(columnIndex, nativeType)).getBytes();
}
@Override
public Timestamp getTimestamp(int columnIndex) throws SQLException {
- columnIndex--;
- return rowCursor.getTimestamp(columnIndex);
- }
-
- @Override
- public InputStream getAsciiStream(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public InputStream getUnicodeStream(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public InputStream getBinaryStream(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public String getString(String columnLabel) throws SQLException {
- return getString(findColumn(columnLabel));
- }
-
- @Override
- public boolean getBoolean(String columnLabel) throws SQLException {
- return getBoolean(findColumn(columnLabel));
- }
-
- @Override
- public byte getByte(String columnLabel) throws SQLException {
- return getByte(findColumn(columnLabel));
- }
-
- @Override
- public short getShort(String columnLabel) throws SQLException {
- return getShort(findColumn(columnLabel));
- }
-
- @Override
- public int getInt(String columnLabel) throws SQLException {
- return getInt(findColumn(columnLabel));
- }
-
- @Override
- public long getLong(String columnLabel) throws SQLException {
- return getLong(findColumn(columnLabel));
- }
-
- @Override
- public float getFloat(String columnLabel) throws SQLException {
- return getFloat(findColumn(columnLabel));
- }
-
- @Override
- public double getDouble(String columnLabel) throws SQLException {
- return getDouble(findColumn(columnLabel));
- }
-
- @Override
- public BigDecimal getBigDecimal(String columnLabel, int scale) throws SQLException {
- return getBigDecimal(findColumn(columnLabel));
- }
-
- @Override
- public byte[] getBytes(String columnLabel) throws SQLException {
- return getBytes(findColumn(columnLabel));
- }
-
- @Override
- public Date getDate(String columnLabel) throws SQLException {
- return getDate(findColumn(columnLabel));
- }
-
- @Override
- public Time getTime(String columnLabel) throws SQLException {
- return getTime(findColumn(columnLabel));
- }
-
- @Override
- public Timestamp getTimestamp(String columnLabel) throws SQLException {
- return getTimestamp(findColumn(columnLabel));
- }
-
- @Override
- public InputStream getAsciiStream(String columnLabel) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public InputStream getUnicodeStream(String columnLabel) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public InputStream getBinaryStream(String columnLabel) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public SQLWarning getWarnings() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void clearWarnings() throws SQLException {
-
- }
-
- @Override
- public String getCursorName() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ return rowCursor.getTimestamp(columnIndex,nativeType);
}
@Override
@@ -291,12 +140,7 @@ public class DatabaseMetaDataResultSet implements ResultSet {
@Override
public Object getObject(int columnIndex) throws SQLException {
- return rowCursor.get(columnIndex);
- }
-
- @Override
- public Object getObject(String columnLabel) throws SQLException {
- return rowCursor.get(findColumn(columnLabel));
+ return rowCursor.getObject(columnIndex);
}
@Override
@@ -304,31 +148,19 @@ public class DatabaseMetaDataResultSet implements ResultSet {
Iterator colMetaDataIt = this.columnMetaDataList.iterator();
while (colMetaDataIt.hasNext()) {
ColumnMetaData colMetaData = colMetaDataIt.next();
- if (colMetaData.getColName() != null && colMetaData.getColName().equalsIgnoreCase(columnLabel)) {
- return colMetaData.getColIndex() + 1;
+ if (colMetaData.getColName() != null && colMetaData.getColName().equals(columnLabel)) {
+ return colMetaData.getColIndex();
}
}
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_INVALID_VARIABLE);
}
- @Override
- public Reader getCharacterStream(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public Reader getCharacterStream(String columnLabel) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
@Override
public BigDecimal getBigDecimal(int columnIndex) throws SQLException {
- return new BigDecimal(rowCursor.getDouble(columnIndex, columnMetaDataList.get(columnIndex).getColType()));
- }
-
- @Override
- public BigDecimal getBigDecimal(String columnLabel) throws SQLException {
- return getBigDecimal(findColumn(columnLabel));
+ int colType = columnMetaDataList.get(columnIndex - 1).getColType();
+ int nativeType = TSDBConstants.jdbcType2TaosType(colType);
+ double value = rowCursor.getDouble(columnIndex, nativeType);
+ return new BigDecimal(value);
}
@Override
@@ -378,7 +210,6 @@ public class DatabaseMetaDataResultSet implements ResultSet {
} else {
return 0;
}
-
}
@Override
@@ -397,680 +228,23 @@ public class DatabaseMetaDataResultSet implements ResultSet {
}
@Override
- public void setFetchDirection(int direction) throws SQLException {
-
- }
-
- @Override
- public int getFetchDirection() throws SQLException {
- return ResultSet.FETCH_FORWARD;
- }
-
- @Override
- public void setFetchSize(int rows) throws SQLException {
-
- }
-
- @Override
- public int getFetchSize() throws SQLException {
- return 0;
- }
-
- @Override
- public int getType() throws SQLException {
- return ResultSet.TYPE_FORWARD_ONLY;
- }
-
- @Override
- public int getConcurrency() throws SQLException {
- return ResultSet.CONCUR_READ_ONLY;
- }
-
- @Override
- public boolean rowUpdated() throws SQLException {
- return false;
+ public Statement getStatement() throws SQLException {
+ return null;
}
- @Override
- public boolean rowInserted() throws SQLException {
- return false;
+ public Timestamp getTimestamp(int columnIndex, Calendar cal) throws SQLException {
+ //TODO: calendar is not used
+ return getTimestamp(columnIndex);
}
@Override
- public boolean rowDeleted() throws SQLException {
+ public boolean isClosed() throws SQLException {
return false;
}
@Override
- public void updateNull(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBoolean(int columnIndex, boolean x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateByte(int columnIndex, byte x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateShort(int columnIndex, short x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateInt(int columnIndex, int x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateLong(int columnIndex, long x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateFloat(int columnIndex, float x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateDouble(int columnIndex, double x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBigDecimal(int columnIndex, BigDecimal x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateString(int columnIndex, String x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBytes(int columnIndex, byte[] x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateDate(int columnIndex, Date x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateTime(int columnIndex, Time x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateTimestamp(int columnIndex, Timestamp x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateAsciiStream(int columnIndex, InputStream x, int length) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBinaryStream(int columnIndex, InputStream x, int length) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateCharacterStream(int columnIndex, Reader x, int length) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateObject(int columnIndex, Object x, int scaleOrLength) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateObject(int columnIndex, Object x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateNull(String columnLabel) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBoolean(String columnLabel, boolean x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateByte(String columnLabel, byte x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateShort(String columnLabel, short x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateInt(String columnLabel, int x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateLong(String columnLabel, long x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateFloat(String columnLabel, float x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateDouble(String columnLabel, double x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBigDecimal(String columnLabel, BigDecimal x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateString(String columnLabel, String x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ public String getNString(int columnIndex) throws SQLException {
+ return getString(columnIndex);
}
- @Override
- public void updateBytes(String columnLabel, byte[] x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateDate(String columnLabel, Date x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateTime(String columnLabel, Time x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateTimestamp(String columnLabel, Timestamp x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateAsciiStream(String columnLabel, InputStream x, int length) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateBinaryStream(String columnLabel, InputStream x, int length) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateCharacterStream(String columnLabel, Reader reader, int length) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateObject(String columnLabel, Object x, int scaleOrLength) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateObject(String columnLabel, Object x) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void insertRow() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void updateRow() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void deleteRow() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void refreshRow() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void cancelRowUpdates() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void moveToInsertRow() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public void moveToCurrentRow() throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public Statement getStatement() throws SQLException {
- return null;
- }
-
- @Override
- public Object getObject(int columnIndex, Map> map) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public Ref getRef(int columnIndex) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public Blob getBlob(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public Clob getClob(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public Array getArray(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public Object getObject(String columnLabel, Map> map) throws SQLException {
- return null;
- }
-
- @Override
- public Ref getRef(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public Blob getBlob(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public Clob getClob(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public Array getArray(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public Date getDate(int columnIndex, Calendar cal) throws SQLException {
- return null;
- }
-
- @Override
- public Date getDate(String columnLabel, Calendar cal) throws SQLException {
- return null;
- }
-
- @Override
- public Time getTime(int columnIndex, Calendar cal) throws SQLException {
- return null;
- }
-
- @Override
- public Time getTime(String columnLabel, Calendar cal) throws SQLException {
- return null;
- }
-
- @Override
- public Timestamp getTimestamp(int columnIndex, Calendar cal) throws SQLException {
- return null;
- }
-
- @Override
- public Timestamp getTimestamp(String columnLabel, Calendar cal) throws SQLException {
- return null;
- }
-
- @Override
- public URL getURL(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public URL getURL(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public void updateRef(int columnIndex, Ref x) throws SQLException {
-
- }
-
- @Override
- public void updateRef(String columnLabel, Ref x) throws SQLException {
-
- }
-
- @Override
- public void updateBlob(int columnIndex, Blob x) throws SQLException {
-
- }
-
- @Override
- public void updateBlob(String columnLabel, Blob x) throws SQLException {
-
- }
-
- @Override
- public void updateClob(int columnIndex, Clob x) throws SQLException {
-
- }
-
- @Override
- public void updateClob(String columnLabel, Clob x) throws SQLException {
-
- }
-
- @Override
- public void updateArray(int columnIndex, Array x) throws SQLException {
-
- }
-
- @Override
- public void updateArray(String columnLabel, Array x) throws SQLException {
-
- }
-
- @Override
- public RowId getRowId(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public RowId getRowId(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public void updateRowId(int columnIndex, RowId x) throws SQLException {
-
- }
-
- @Override
- public void updateRowId(String columnLabel, RowId x) throws SQLException {
-
- }
-
- @Override
- public int getHoldability() throws SQLException {
- return 0;
- }
-
- @Override
- public boolean isClosed() throws SQLException {
- return false;
- }
-
- @Override
- public void updateNString(int columnIndex, String nString) throws SQLException {
-
- }
-
- @Override
- public void updateNString(String columnLabel, String nString) throws SQLException {
-
- }
-
- @Override
- public void updateNClob(int columnIndex, NClob nClob) throws SQLException {
-
- }
-
- @Override
- public void updateNClob(String columnLabel, NClob nClob) throws SQLException {
-
- }
-
- @Override
- public NClob getNClob(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public NClob getNClob(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public SQLXML getSQLXML(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public SQLXML getSQLXML(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public void updateSQLXML(int columnIndex, SQLXML xmlObject) throws SQLException {
-
- }
-
- @Override
- public void updateSQLXML(String columnLabel, SQLXML xmlObject) throws SQLException {
-
- }
-
- @Override
- public String getNString(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public String getNString(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public Reader getNCharacterStream(int columnIndex) throws SQLException {
- return null;
- }
-
- @Override
- public Reader getNCharacterStream(String columnLabel) throws SQLException {
- return null;
- }
-
- @Override
- public void updateNCharacterStream(int columnIndex, Reader x, long length) throws SQLException {
-
- }
-
- @Override
- public void updateNCharacterStream(String columnLabel, Reader reader, long length) throws SQLException {
-
- }
-
- @Override
- public void updateAsciiStream(int columnIndex, InputStream x, long length) throws SQLException {
-
- }
-
- @Override
- public void updateBinaryStream(int columnIndex, InputStream x, long length) throws SQLException {
-
- }
-
- @Override
- public void updateCharacterStream(int columnIndex, Reader x, long length) throws SQLException {
-
- }
-
- @Override
- public void updateAsciiStream(String columnLabel, InputStream x, long length) throws SQLException {
-
- }
-
- @Override
- public void updateBinaryStream(String columnLabel, InputStream x, long length) throws SQLException {
-
- }
-
- @Override
- public void updateCharacterStream(String columnLabel, Reader reader, long length) throws SQLException {
-
- }
-
- @Override
- public void updateBlob(int columnIndex, InputStream inputStream, long length) throws SQLException {
-
- }
-
- @Override
- public void updateBlob(String columnLabel, InputStream inputStream, long length) throws SQLException {
-
- }
-
- @Override
- public void updateClob(int columnIndex, Reader reader, long length) throws SQLException {
-
- }
-
- @Override
- public void updateClob(String columnLabel, Reader reader, long length) throws SQLException {
-
- }
-
- @Override
- public void updateNClob(int columnIndex, Reader reader, long length) throws SQLException {
-
- }
-
- @Override
- public void updateNClob(String columnLabel, Reader reader, long length) throws SQLException {
-
- }
-
- @Override
- public void updateNCharacterStream(int columnIndex, Reader x) throws SQLException {
-
- }
-
- @Override
- public void updateNCharacterStream(String columnLabel, Reader reader) throws SQLException {
-
- }
-
- @Override
- public void updateAsciiStream(int columnIndex, InputStream x) throws SQLException {
-
- }
-
- @Override
- public void updateBinaryStream(int columnIndex, InputStream x) throws SQLException {
-
- }
-
- @Override
- public void updateCharacterStream(int columnIndex, Reader x) throws SQLException {
-
- }
-
- @Override
- public void updateAsciiStream(String columnLabel, InputStream x) throws SQLException {
-
- }
-
- @Override
- public void updateBinaryStream(String columnLabel, InputStream x) throws SQLException {
-
- }
-
- @Override
- public void updateCharacterStream(String columnLabel, Reader reader) throws SQLException {
-
- }
-
- @Override
- public void updateBlob(int columnIndex, InputStream inputStream) throws SQLException {
-
- }
-
- @Override
- public void updateBlob(String columnLabel, InputStream inputStream) throws SQLException {
-
- }
-
- @Override
- public void updateClob(int columnIndex, Reader reader) throws SQLException {
-
- }
-
- @Override
- public void updateClob(String columnLabel, Reader reader) throws SQLException {
-
- }
-
- @Override
- public void updateNClob(int columnIndex, Reader reader) throws SQLException {
-
- }
-
- @Override
- public void updateNClob(String columnLabel, Reader reader) throws SQLException {
-
- }
-
- @Override
- public T getObject(int columnIndex, Class type) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public T getObject(String columnLabel, Class type) throws SQLException {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
- }
-
- @Override
- public T unwrap(Class iface) throws SQLException {
- return null;
- }
-
- @Override
- public boolean isWrapperFor(Class> iface) throws SQLException {
- return false;
- }
-
- private int getTrueColumnIndex(int columnIndex) throws SQLException {
- if (columnIndex < 1) {
- throw new SQLException("Column Index out of range, " + columnIndex + " < " + 1);
- }
-
- int numOfCols = this.columnMetaDataList.size();
- if (columnIndex > numOfCols) {
- throw new SQLException("Column Index out of range, " + columnIndex + " > " + numOfCols);
- }
-
- return columnIndex - 1;
- }
}
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConstants.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConstants.java
index f38555ce8a6c7ee946b3bdbda2204c702b49198a..e6406d2c6dc7990ec4f3149bb8c5146202f5d326 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConstants.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBConstants.java
@@ -41,15 +41,15 @@ public abstract class TSDBConstants {
public static final int TSDB_DATA_TYPE_BINARY = 8;
public static final int TSDB_DATA_TYPE_TIMESTAMP = 9;
public static final int TSDB_DATA_TYPE_NCHAR = 10;
- /*
- 系统增加新的无符号数据类型,分别是:
- unsigned tinyint, 数值范围:0-254, NULL 为255
- unsigned smallint,数值范围: 0-65534, NULL 为65535
- unsigned int,数值范围:0-4294967294,NULL 为4294967295u
- unsigned bigint,数值范围:0-18446744073709551614u,NULL 为18446744073709551615u。
- example:
- create table tb(ts timestamp, a tinyint unsigned, b smallint unsigned, c int unsigned, d bigint unsigned);
- */
+ /**
+ * 系统增加新的无符号数据类型,分别是:
+ * unsigned tinyint, 数值范围:0-254, NULL 为255
+ * unsigned smallint,数值范围: 0-65534, NULL 为65535
+ * unsigned int,数值范围:0-4294967294,NULL 为4294967295u
+ * unsigned bigint,数值范围:0-18446744073709551614u,NULL 为18446744073709551615u。
+ * example:
+ * create table tb(ts timestamp, a tinyint unsigned, b smallint unsigned, c int unsigned, d bigint unsigned);
+ */
public static final int TSDB_DATA_TYPE_UTINYINT = 11; //unsigned tinyint
public static final int TSDB_DATA_TYPE_USMALLINT = 12; //unsigned smallint
public static final int TSDB_DATA_TYPE_UINT = 13; //unsigned int
@@ -57,6 +57,47 @@ public abstract class TSDBConstants {
// nchar column max length
public static final int maxFieldSize = 16 * 1024;
+ // precision for data types
+ public static final int BOOLEAN_PRECISION = 1;
+ public static final int TINYINT_PRECISION = 4;
+ public static final int SMALLINT_PRECISION = 6;
+ public static final int INT_PRECISION = 11;
+ public static final int BIGINT_PRECISION = 20;
+ public static final int FLOAT_PRECISION = 12;
+ public static final int DOUBLE_PRECISION = 22;
+ public static final int TIMESTAMP_MS_PRECISION = 23;
+ public static final int TIMESTAMP_US_PRECISION = 26;
+ // scale for data types
+ public static final int FLOAT_SCALE = 31;
+ public static final int DOUBLE_SCALE = 31;
+
+ public static int typeName2JdbcType(String type) {
+ switch (type.toUpperCase()) {
+ case "TIMESTAMP":
+ return Types.TIMESTAMP;
+ case "INT":
+ return Types.INTEGER;
+ case "BIGINT":
+ return Types.BIGINT;
+ case "FLOAT":
+ return Types.FLOAT;
+ case "DOUBLE":
+ return Types.DOUBLE;
+ case "BINARY":
+ return Types.BINARY;
+ case "SMALLINT":
+ return Types.SMALLINT;
+ case "TINYINT":
+ return Types.TINYINT;
+ case "BOOL":
+ return Types.BOOLEAN;
+ case "NCHAR":
+ return Types.NCHAR;
+ default:
+ return Types.NULL;
+ }
+ }
+
public static int taosType2JdbcType(int taosType) throws SQLException {
switch (taosType) {
case TSDBConstants.TSDB_DATA_TYPE_BOOL:
@@ -88,7 +129,7 @@ public abstract class TSDBConstants {
}
public static String taosType2JdbcTypeName(int taosType) throws SQLException {
- switch (taosType){
+ switch (taosType) {
case TSDBConstants.TSDB_DATA_TYPE_BOOL:
return "BOOL";
case TSDBConstants.TSDB_DATA_TYPE_UTINYINT:
@@ -119,7 +160,7 @@ public abstract class TSDBConstants {
}
public static int jdbcType2TaosType(int jdbcType) throws SQLException {
- switch (jdbcType){
+ switch (jdbcType) {
case Types.BOOLEAN:
return TSDBConstants.TSDB_DATA_TYPE_BOOL;
case Types.TINYINT:
@@ -145,7 +186,7 @@ public abstract class TSDBConstants {
}
public static String jdbcType2TaosTypeName(int jdbcType) throws SQLException {
- switch (jdbcType){
+ switch (jdbcType) {
case Types.BOOLEAN:
return "BOOL";
case Types.TINYINT:
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBJNIConnector.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBJNIConnector.java
index 256e735285bd493f37c9e369a49b369e9e6b4b38..92792d97517c98f9a5402aaae557d01e09bbca30 100755
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBJNIConnector.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBJNIConnector.java
@@ -16,13 +16,13 @@
*/
package com.taosdata.jdbc;
+import com.taosdata.jdbc.utils.TaosInfo;
+
import java.nio.ByteBuffer;
import java.sql.SQLException;
import java.sql.SQLWarning;
import java.util.List;
-import com.taosdata.jdbc.utils.TaosInfo;
-
/**
* JNI connector
*/
@@ -30,10 +30,10 @@ public class TSDBJNIConnector {
private static volatile Boolean isInitialized = false;
private TaosInfo taosInfo = TaosInfo.getInstance();
-
+
// Connection pointer used in C
private long taos = TSDBConstants.JNI_NULL_POINTER;
-
+
// result set status in current connection
private boolean isResultsetClosed;
@@ -194,7 +194,9 @@ public class TSDBJNIConnector {
* Get schema metadata
*/
public int getSchemaMetaData(long resultSet, List columnMetaData) {
- return this.getSchemaMetaDataImp(this.taos, resultSet, columnMetaData);
+ int ret = this.getSchemaMetaDataImp(this.taos, resultSet, columnMetaData);
+ columnMetaData.stream().forEach(column -> column.setColIndex(column.getColIndex() + 1));
+ return ret;
}
private native int getSchemaMetaDataImp(long connection, long resultSet, List columnMetaData);
@@ -221,7 +223,7 @@ public class TSDBJNIConnector {
*/
public void closeConnection() throws SQLException {
int code = this.closeConnectionImp(this.taos);
-
+
if (code < 0) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_JNI_CONNECTION_NULL);
} else if (code == 0) {
@@ -229,7 +231,7 @@ public class TSDBJNIConnector {
} else {
throw new SQLException("Undefined error code returned by TDengine when closing a connection");
}
-
+
// invoke closeConnectionImpl only here
taosInfo.connect_close_increment();
}
@@ -274,67 +276,76 @@ public class TSDBJNIConnector {
}
private native int validateCreateTableSqlImp(long connection, byte[] sqlBytes);
-
- public long prepareStmt(String sql) throws SQLException {
- Long stmt = prepareStmtImp(sql.getBytes(), this.taos);
- if (stmt == TSDBConstants.JNI_TDENGINE_ERROR) {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_INVALID_SQL);
- } else if (stmt == TSDBConstants.JNI_CONNECTION_NULL) {
+
+ public long prepareStmt(String sql) throws SQLException {
+ Long stmt;
+ try {
+ stmt = prepareStmtImp(sql.getBytes(), this.taos);
+ } catch (Exception e) {
+ e.printStackTrace();
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_ENCODING);
+ }
+
+ if (stmt == TSDBConstants.JNI_CONNECTION_NULL) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_JNI_CONNECTION_NULL);
- } else if (stmt == TSDBConstants.JNI_SQL_NULL) {
+ }
+
+ if (stmt == TSDBConstants.JNI_SQL_NULL) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_JNI_SQL_NULL);
- } else if (stmt == TSDBConstants.JNI_OUT_OF_MEMORY) {
+ }
+
+ if (stmt == TSDBConstants.JNI_OUT_OF_MEMORY) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_JNI_OUT_OF_MEMORY);
}
-
- return stmt;
+
+ return stmt;
}
-
+
private native long prepareStmtImp(byte[] sql, long con);
-
+
public void setBindTableName(long stmt, String tableName) throws SQLException {
- int code = setBindTableNameImp(stmt, tableName, this.taos);
- if (code != TSDBConstants.JNI_SUCCESS) {
+ int code = setBindTableNameImp(stmt, tableName, this.taos);
+ if (code != TSDBConstants.JNI_SUCCESS) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "failed to set table name");
- }
- }
-
+ }
+ }
+
private native int setBindTableNameImp(long stmt, String name, long conn);
-
+
public void setBindTableNameAndTags(long stmt, String tableName, int numOfTags, ByteBuffer tags, ByteBuffer typeList, ByteBuffer lengthList, ByteBuffer nullList) throws SQLException {
- int code = setTableNameTagsImp(stmt, tableName, numOfTags, tags.array(), typeList.array(), lengthList.array(),
- nullList.array(), this.taos);
- if (code != TSDBConstants.JNI_SUCCESS) {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "failed to bind table name and corresponding tags");
- }
+ int code = setTableNameTagsImp(stmt, tableName, numOfTags, tags.array(), typeList.array(), lengthList.array(),
+ nullList.array(), this.taos);
+ if (code != TSDBConstants.JNI_SUCCESS) {
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "failed to bind table name and corresponding tags");
+ }
}
-
+
private native int setTableNameTagsImp(long stmt, String name, int numOfTags, byte[] tags, byte[] typeList, byte[] lengthList, byte[] nullList, long conn);
-
- public void bindColumnDataArray(long stmt, ByteBuffer colDataList, ByteBuffer lengthList, ByteBuffer isNullList, int type, int bytes, int numOfRows,int columnIndex) throws SQLException {
- int code = bindColDataImp(stmt, colDataList.array(), lengthList.array(), isNullList.array(), type, bytes, numOfRows, columnIndex, this.taos);
- if (code != TSDBConstants.JNI_SUCCESS) {
+
+ public void bindColumnDataArray(long stmt, ByteBuffer colDataList, ByteBuffer lengthList, ByteBuffer isNullList, int type, int bytes, int numOfRows, int columnIndex) throws SQLException {
+ int code = bindColDataImp(stmt, colDataList.array(), lengthList.array(), isNullList.array(), type, bytes, numOfRows, columnIndex, this.taos);
+ if (code != TSDBConstants.JNI_SUCCESS) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "failed to bind column data");
- }
- }
-
+ }
+ }
+
private native int bindColDataImp(long stmt, byte[] colDataList, byte[] lengthList, byte[] isNullList, int type, int bytes, int numOfRows, int columnIndex, long conn);
-
+
public void executeBatch(long stmt) throws SQLException {
- int code = executeBatchImp(stmt, this.taos);
- if (code != TSDBConstants.JNI_SUCCESS) {
+ int code = executeBatchImp(stmt, this.taos);
+ if (code != TSDBConstants.JNI_SUCCESS) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "failed to execute batch bind");
- }
+ }
}
-
+
private native int executeBatchImp(long stmt, long con);
-
+
public void closeBatch(long stmt) throws SQLException {
- int code = closeStmt(stmt, this.taos);
- if (code != TSDBConstants.JNI_SUCCESS) {
+ int code = closeStmt(stmt, this.taos);
+ if (code != TSDBConstants.JNI_SUCCESS) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "failed to close batch bind");
- }
+ }
}
-
+
private native int closeStmt(long stmt, long con);
}
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBPreparedStatement.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBPreparedStatement.java
index f6810237c097a62a4c8f0f63d6e435bfb0354125..c3d5abf35c7304f86f9cc4dc4449d8c88d144e3d 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBPreparedStatement.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBPreparedStatement.java
@@ -39,18 +39,18 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
private String rawSql;
private Object[] parameters;
private boolean isPrepared;
-
+
private ArrayList colData;
private ArrayList tableTags;
private int tagValueLength;
-
+
private String tableName;
private long nativeStmtHandle = 0;
-
+
private volatile TSDBParameterMetaData parameterMetaData;
TSDBPreparedStatement(TSDBConnection connection, String sql) {
- super(connection);
+ super(connection);
init(sql);
int parameterCnt = 0;
@@ -64,11 +64,11 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
this.isPrepared = true;
}
- if (parameterCnt > 1) {
- // the table name is also a parameter, so ignore it.
- this.colData = new ArrayList();
- this.tableTags = new ArrayList();
- }
+ if (parameterCnt > 1) {
+ // the table name is also a parameter, so ignore it.
+ this.colData = new ArrayList();
+ this.tableTags = new ArrayList();
+ }
}
private void init(String sql) {
@@ -205,9 +205,7 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
@Override
public void setBigDecimal(int parameterIndex, BigDecimal x) throws SQLException {
- if (isClosed())
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ setObject(parameterIndex, x.doubleValue());
}
@Override
@@ -222,16 +220,12 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
@Override
public void setDate(int parameterIndex, Date x) throws SQLException {
- if (isClosed())
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ setObject(parameterIndex, new Timestamp(x.getTime()));
}
@Override
public void setTime(int parameterIndex, Time x) throws SQLException {
- if (isClosed())
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ setObject(parameterIndex, new Timestamp(x.getTime()));
}
@Override
@@ -279,11 +273,10 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
if (isClosed()) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
}
-
+
if (parameterIndex < 1 && parameterIndex >= parameters.length) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_PARAMETER_INDEX_OUT_RANGE);
}
-
parameters[parameterIndex - 1] = x;
}
@@ -323,7 +316,7 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
if (isClosed()) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
}
-
+
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
}
@@ -350,9 +343,9 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
@Override
public ResultSetMetaData getMetaData() throws SQLException {
- if (isClosed())
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ if (this.getResultSet() == null)
+ return null;
+ return getResultSet().getMetaData();
}
@Override
@@ -396,10 +389,7 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
if (isClosed())
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
- if (parameterMetaData == null) {
- this.parameterMetaData = new TSDBParameterMetaData(parameters);
- }
- return this.parameterMetaData;
+ return new TSDBParameterMetaData(parameters);
}
@Override
@@ -411,9 +401,7 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
@Override
public void setNString(int parameterIndex, String value) throws SQLException {
- if (isClosed())
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
+ setString(parameterIndex, value);
}
@Override
@@ -536,489 +524,495 @@ public class TSDBPreparedStatement extends TSDBStatement implements PreparedStat
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_STATEMENT_CLOSED);
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNSUPPORTED_METHOD);
}
-
+
///////////////////////////////////////////////////////////////////////
// NOTE: the following APIs are not JDBC compatible
// set the bind table name
private static class ColumnInfo {
- @SuppressWarnings("rawtypes")
- private ArrayList data;
- private int type;
- private int bytes;
- private boolean typeIsSet;
-
- public ColumnInfo() {
- this.typeIsSet = false;
- }
-
- public void setType(int type) throws SQLException {
- if (this.isTypeSet()) {
+ @SuppressWarnings("rawtypes")
+ private ArrayList data;
+ private int type;
+ private int bytes;
+ private boolean typeIsSet;
+
+ public ColumnInfo() {
+ this.typeIsSet = false;
+ }
+
+ public void setType(int type) throws SQLException {
+ if (this.isTypeSet()) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data type has been set");
- }
-
- this.typeIsSet = true;
- this.type = type;
- }
-
- public boolean isTypeSet() {
- return this.typeIsSet;
- }
- };
-
+ }
+
+ this.typeIsSet = true;
+ this.type = type;
+ }
+
+ public boolean isTypeSet() {
+ return this.typeIsSet;
+ }
+ }
+
+ ;
+
private static class TableTagInfo {
- private boolean isNull;
- private Object value;
- private int type;
- public TableTagInfo(Object value, int type) {
- this.value = value;
- this.type = type;
- }
-
- public static TableTagInfo createNullTag(int type) {
- TableTagInfo info = new TableTagInfo(null, type);
- info.isNull = true;
- return info;
- }
- };
-
+ private boolean isNull;
+ private Object value;
+ private int type;
+
+ public TableTagInfo(Object value, int type) {
+ this.value = value;
+ this.type = type;
+ }
+
+ public static TableTagInfo createNullTag(int type) {
+ TableTagInfo info = new TableTagInfo(null, type);
+ info.isNull = true;
+ return info;
+ }
+ }
+
+ ;
+
public void setTableName(String name) {
- this.tableName = name;
+ this.tableName = name;
}
-
+
private void ensureTagCapacity(int index) {
- if (this.tableTags.size() < index + 1) {
- int delta = index + 1 - this.tableTags.size();
- this.tableTags.addAll(Collections.nCopies(delta, null));
- }
+ if (this.tableTags.size() < index + 1) {
+ int delta = index + 1 - this.tableTags.size();
+ this.tableTags.addAll(Collections.nCopies(delta, null));
+ }
}
-
+
public void setTagNull(int index, int type) {
- ensureTagCapacity(index);
- this.tableTags.set(index, TableTagInfo.createNullTag(type));
+ ensureTagCapacity(index);
+ this.tableTags.set(index, TableTagInfo.createNullTag(type));
}
-
+
public void setTagBoolean(int index, boolean value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_BOOL));
- this.tagValueLength += Byte.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_BOOL));
+ this.tagValueLength += Byte.BYTES;
}
-
+
public void setTagInt(int index, int value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_INT));
- this.tagValueLength += Integer.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_INT));
+ this.tagValueLength += Integer.BYTES;
}
-
+
public void setTagByte(int index, byte value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_TINYINT));
- this.tagValueLength += Byte.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_TINYINT));
+ this.tagValueLength += Byte.BYTES;
}
-
+
public void setTagShort(int index, short value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_SMALLINT));
- this.tagValueLength += Short.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_SMALLINT));
+ this.tagValueLength += Short.BYTES;
}
-
+
public void setTagLong(int index, long value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_BIGINT));
- this.tagValueLength += Long.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_BIGINT));
+ this.tagValueLength += Long.BYTES;
}
-
+
public void setTagTimestamp(int index, long value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP));
- this.tagValueLength += Long.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP));
+ this.tagValueLength += Long.BYTES;
}
-
+
public void setTagFloat(int index, float value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_FLOAT));
- this.tagValueLength += Float.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_FLOAT));
+ this.tagValueLength += Float.BYTES;
}
-
+
public void setTagDouble(int index, double value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_DOUBLE));
- this.tagValueLength += Double.BYTES;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_DOUBLE));
+ this.tagValueLength += Double.BYTES;
}
-
+
public void setTagString(int index, String value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_BINARY));
- this.tagValueLength += value.getBytes().length;
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_BINARY));
+ this.tagValueLength += value.getBytes().length;
}
-
+
public void setTagNString(int index, String value) {
- ensureTagCapacity(index);
- this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_NCHAR));
-
- String charset = TaosGlobalConfig.getCharset();
- try {
- this.tagValueLength += value.getBytes(charset).length;
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- }
- }
-
+ ensureTagCapacity(index);
+ this.tableTags.set(index, new TableTagInfo(value, TSDBConstants.TSDB_DATA_TYPE_NCHAR));
+
+ String charset = TaosGlobalConfig.getCharset();
+ try {
+ this.tagValueLength += value.getBytes(charset).length;
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+ }
+
public void setValueImpl(int columnIndex, ArrayList list, int type, int bytes) throws SQLException {
- if (this.colData.size() == 0) {
- this.colData.addAll(Collections.nCopies(this.parameters.length - 1 - this.tableTags.size(), null));
-
- }
- ColumnInfo col = (ColumnInfo) this.colData.get(columnIndex);
- if (col == null) {
- ColumnInfo p = new ColumnInfo();
- p.setType(type);
- p.bytes = bytes;
- p.data = (ArrayList>) list.clone();
- this.colData.set(columnIndex, p);
- } else {
- if (col.type != type) {
+ if (this.colData.size() == 0) {
+ this.colData.addAll(Collections.nCopies(this.parameters.length - 1 - this.tableTags.size(), null));
+ }
+
+ ColumnInfo col = (ColumnInfo) this.colData.get(columnIndex);
+ if (col == null) {
+ ColumnInfo p = new ColumnInfo();
+ p.setType(type);
+ p.bytes = bytes;
+ p.data = (ArrayList>) list.clone();
+ this.colData.set(columnIndex, p);
+ } else {
+ if (col.type != type) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data type mismatch");
- }
- col.data.addAll(list);
- }
+ }
+ col.data.addAll(list);
+ }
}
-
+
public void setInt(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_INT, Integer.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_INT, Integer.BYTES);
}
-
+
public void setFloat(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_FLOAT, Float.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_FLOAT, Float.BYTES);
}
-
+
public void setTimestamp(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP, Long.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP, Long.BYTES);
}
-
+
public void setLong(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_BIGINT, Long.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_BIGINT, Long.BYTES);
}
-
+
public void setDouble(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_DOUBLE, Double.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_DOUBLE, Double.BYTES);
}
-
+
public void setBoolean(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_BOOL, Byte.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_BOOL, Byte.BYTES);
}
-
+
public void setByte(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_TINYINT, Byte.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_TINYINT, Byte.BYTES);
}
-
+
public void setShort(int columnIndex, ArrayList list) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_SMALLINT, Short.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_SMALLINT, Short.BYTES);
}
-
+
public void setString(int columnIndex, ArrayList list, int size) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_BINARY, size);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_BINARY, size);
}
-
+
// note: expand the required space for each NChar character
public void setNString(int columnIndex, ArrayList list, int size) throws SQLException {
- setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_NCHAR, size * Integer.BYTES);
+ setValueImpl(columnIndex, list, TSDBConstants.TSDB_DATA_TYPE_NCHAR, size * Integer.BYTES);
}
-
+
public void columnDataAddBatch() throws SQLException {
- // pass the data block to native code
- if (rawSql == null) {
+ // pass the data block to native code
+ if (rawSql == null) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "sql statement not set yet");
- }
-
- // table name is not set yet, abort
- if (this.tableName == null) {
+ }
+
+ // table name is not set yet, abort
+ if (this.tableName == null) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "table name not set yet");
- }
-
- int numOfCols = this.colData.size();
- if (numOfCols == 0) {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data not bind");
- }
-
- TSDBJNIConnector connector = ((TSDBConnection) this.getConnection()).getConnector();
- this.nativeStmtHandle = connector.prepareStmt(rawSql);
-
- if (this.tableTags == null) {
- connector.setBindTableName(this.nativeStmtHandle, this.tableName);
- } else {
- int num = this.tableTags.size();
- ByteBuffer tagDataList = ByteBuffer.allocate(this.tagValueLength);
- tagDataList.order(ByteOrder.LITTLE_ENDIAN);
-
- ByteBuffer typeList = ByteBuffer.allocate(num);
- typeList.order(ByteOrder.LITTLE_ENDIAN);
-
- ByteBuffer lengthList = ByteBuffer.allocate(num * Long.BYTES);
- lengthList.order(ByteOrder.LITTLE_ENDIAN);
-
- ByteBuffer isNullList = ByteBuffer.allocate(num * Integer.BYTES);
- isNullList.order(ByteOrder.LITTLE_ENDIAN);
-
- for (int i = 0; i < num; ++i) {
- TableTagInfo tag = this.tableTags.get(i);
- if (tag.isNull) {
- typeList.put((byte) tag.type);
- isNullList.putInt(1);
- lengthList.putLong(0);
- continue;
- }
-
- switch (tag.type) {
- case TSDBConstants.TSDB_DATA_TYPE_INT: {
- Integer val = (Integer) tag.value;
- tagDataList.putInt(val);
- lengthList.putLong(Integer.BYTES);
- break;
- }
- case TSDBConstants.TSDB_DATA_TYPE_TINYINT: {
- Byte val = (Byte) tag.value;
- tagDataList.put(val);
- lengthList.putLong(Byte.BYTES);
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_BOOL: {
- Boolean val = (Boolean) tag.value;
- tagDataList.put((byte) (val ? 1 : 0));
- lengthList.putLong(Byte.BYTES);
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_SMALLINT: {
- Short val = (Short) tag.value;
- tagDataList.putShort(val);
- lengthList.putLong(Short.BYTES);
-
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP:
- case TSDBConstants.TSDB_DATA_TYPE_BIGINT: {
- Long val = (Long) tag.value;
- tagDataList.putLong(val == null ? 0 : val);
- lengthList.putLong(Long.BYTES);
-
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_FLOAT: {
- Float val = (Float) tag.value;
- tagDataList.putFloat(val == null ? 0 : val);
- lengthList.putLong(Float.BYTES);
-
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_DOUBLE: {
- Double val = (Double) tag.value;
- tagDataList.putDouble(val == null ? 0 : val);
- lengthList.putLong(Double.BYTES);
-
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_NCHAR:
- case TSDBConstants.TSDB_DATA_TYPE_BINARY: {
- String charset = TaosGlobalConfig.getCharset();
- String val = (String) tag.value;
-
- byte[] b = null;
- try {
- if (tag.type == TSDBConstants.TSDB_DATA_TYPE_BINARY) {
- b = val.getBytes();
- } else {
- b = val.getBytes(charset);
- }
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- }
-
- tagDataList.put(b);
- lengthList.putLong(b.length);
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_UTINYINT:
- case TSDBConstants.TSDB_DATA_TYPE_USMALLINT:
- case TSDBConstants.TSDB_DATA_TYPE_UINT:
- case TSDBConstants.TSDB_DATA_TYPE_UBIGINT: {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "not support data types");
- }
- }
-
- typeList.put((byte) tag.type);
- isNullList.putInt(tag.isNull? 1 : 0);
- }
-
- connector.setBindTableNameAndTags(this.nativeStmtHandle, this.tableName, this.tableTags.size(), tagDataList,
- typeList, lengthList, isNullList);
- }
-
- ColumnInfo colInfo = (ColumnInfo) this.colData.get(0);
- if (colInfo == null) {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data not bind");
- }
-
- int rows = colInfo.data.size();
- for (int i = 0; i < numOfCols; ++i) {
- ColumnInfo col1 = this.colData.get(i);
- if (col1 == null || !col1.isTypeSet()) {
+ }
+
+ int numOfCols = this.colData.size();
+ if (numOfCols == 0) {
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data not bind");
+ }
+
+ TSDBJNIConnector connector = ((TSDBConnection) this.getConnection()).getConnector();
+ this.nativeStmtHandle = connector.prepareStmt(rawSql);
+
+ if (this.tableTags == null) {
+ connector.setBindTableName(this.nativeStmtHandle, this.tableName);
+ } else {
+ int num = this.tableTags.size();
+ ByteBuffer tagDataList = ByteBuffer.allocate(this.tagValueLength);
+ tagDataList.order(ByteOrder.LITTLE_ENDIAN);
+
+ ByteBuffer typeList = ByteBuffer.allocate(num);
+ typeList.order(ByteOrder.LITTLE_ENDIAN);
+
+ ByteBuffer lengthList = ByteBuffer.allocate(num * Long.BYTES);
+ lengthList.order(ByteOrder.LITTLE_ENDIAN);
+
+ ByteBuffer isNullList = ByteBuffer.allocate(num * Integer.BYTES);
+ isNullList.order(ByteOrder.LITTLE_ENDIAN);
+
+ for (int i = 0; i < num; ++i) {
+ TableTagInfo tag = this.tableTags.get(i);
+ if (tag.isNull) {
+ typeList.put((byte) tag.type);
+ isNullList.putInt(1);
+ lengthList.putLong(0);
+ continue;
+ }
+
+ switch (tag.type) {
+ case TSDBConstants.TSDB_DATA_TYPE_INT: {
+ Integer val = (Integer) tag.value;
+ tagDataList.putInt(val);
+ lengthList.putLong(Integer.BYTES);
+ break;
+ }
+ case TSDBConstants.TSDB_DATA_TYPE_TINYINT: {
+ Byte val = (Byte) tag.value;
+ tagDataList.put(val);
+ lengthList.putLong(Byte.BYTES);
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_BOOL: {
+ Boolean val = (Boolean) tag.value;
+ tagDataList.put((byte) (val ? 1 : 0));
+ lengthList.putLong(Byte.BYTES);
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_SMALLINT: {
+ Short val = (Short) tag.value;
+ tagDataList.putShort(val);
+ lengthList.putLong(Short.BYTES);
+
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP:
+ case TSDBConstants.TSDB_DATA_TYPE_BIGINT: {
+ Long val = (Long) tag.value;
+ tagDataList.putLong(val == null ? 0 : val);
+ lengthList.putLong(Long.BYTES);
+
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_FLOAT: {
+ Float val = (Float) tag.value;
+ tagDataList.putFloat(val == null ? 0 : val);
+ lengthList.putLong(Float.BYTES);
+
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_DOUBLE: {
+ Double val = (Double) tag.value;
+ tagDataList.putDouble(val == null ? 0 : val);
+ lengthList.putLong(Double.BYTES);
+
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_NCHAR:
+ case TSDBConstants.TSDB_DATA_TYPE_BINARY: {
+ String charset = TaosGlobalConfig.getCharset();
+ String val = (String) tag.value;
+
+ byte[] b = null;
+ try {
+ if (tag.type == TSDBConstants.TSDB_DATA_TYPE_BINARY) {
+ b = val.getBytes();
+ } else {
+ b = val.getBytes(charset);
+ }
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+
+ tagDataList.put(b);
+ lengthList.putLong(b.length);
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_UTINYINT:
+ case TSDBConstants.TSDB_DATA_TYPE_USMALLINT:
+ case TSDBConstants.TSDB_DATA_TYPE_UINT:
+ case TSDBConstants.TSDB_DATA_TYPE_UBIGINT: {
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "not support data types");
+ }
+ }
+
+ typeList.put((byte) tag.type);
+ isNullList.putInt(tag.isNull ? 1 : 0);
+ }
+
+ connector.setBindTableNameAndTags(this.nativeStmtHandle, this.tableName, this.tableTags.size(), tagDataList,
+ typeList, lengthList, isNullList);
+ }
+
+ ColumnInfo colInfo = (ColumnInfo) this.colData.get(0);
+ if (colInfo == null) {
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data not bind");
+ }
+
+ int rows = colInfo.data.size();
+ for (int i = 0; i < numOfCols; ++i) {
+ ColumnInfo col1 = this.colData.get(i);
+ if (col1 == null || !col1.isTypeSet()) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "column data not bind");
- }
-
- if (rows != col1.data.size()) {
+ }
+
+ if (rows != col1.data.size()) {
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "the rows in column data not identical");
- }
-
- ByteBuffer colDataList = ByteBuffer.allocate(rows * col1.bytes);
- colDataList.order(ByteOrder.LITTLE_ENDIAN);
-
+ }
+
+ ByteBuffer colDataList = ByteBuffer.allocate(rows * col1.bytes);
+ colDataList.order(ByteOrder.LITTLE_ENDIAN);
+
ByteBuffer lengthList = ByteBuffer.allocate(rows * Integer.BYTES);
lengthList.order(ByteOrder.LITTLE_ENDIAN);
-
+
ByteBuffer isNullList = ByteBuffer.allocate(rows * Byte.BYTES);
isNullList.order(ByteOrder.LITTLE_ENDIAN);
-
- switch (col1.type) {
- case TSDBConstants.TSDB_DATA_TYPE_INT: {
- for (int j = 0; j < rows; ++j) {
- Integer val = (Integer) col1.data.get(j);
- colDataList.putInt(val == null? Integer.MIN_VALUE:val);
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_TINYINT: {
- for (int j = 0; j < rows; ++j) {
- Byte val = (Byte) col1.data.get(j);
- colDataList.put(val == null? 0:val);
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_BOOL: {
- for (int j = 0; j < rows; ++j) {
- Boolean val = (Boolean) col1.data.get(j);
- if (val == null) {
- colDataList.put((byte) 0);
- } else {
- colDataList.put((byte) (val? 1:0));
- }
-
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_SMALLINT: {
- for (int j = 0; j < rows; ++j) {
- Short val = (Short) col1.data.get(j);
- colDataList.putShort(val == null? 0:val);
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP:
- case TSDBConstants.TSDB_DATA_TYPE_BIGINT: {
- for (int j = 0; j < rows; ++j) {
- Long val = (Long) col1.data.get(j);
- colDataList.putLong(val == null? 0:val);
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_FLOAT: {
- for (int j = 0; j < rows; ++j) {
- Float val = (Float) col1.data.get(j);
- colDataList.putFloat(val == null? 0:val);
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_DOUBLE: {
- for (int j = 0; j < rows; ++j) {
- Double val = (Double) col1.data.get(j);
- colDataList.putDouble(val == null? 0:val);
- isNullList.put((byte) (val == null? 1:0));
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_NCHAR:
- case TSDBConstants.TSDB_DATA_TYPE_BINARY: {
- String charset = TaosGlobalConfig.getCharset();
- for (int j = 0; j < rows; ++j) {
- String val = (String) col1.data.get(j);
-
- colDataList.position(j * col1.bytes); // seek to the correct position
- if (val != null) {
- byte[] b = null;
- try {
- if (col1.type == TSDBConstants.TSDB_DATA_TYPE_BINARY) {
- b = val.getBytes();
- } else {
- b = val.getBytes(charset);
- }
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- }
-
- if (val.length() > col1.bytes) {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "string data too long");
- }
-
- colDataList.put(b);
- lengthList.putInt(b.length);
- isNullList.put((byte) 0);
- } else {
- lengthList.putInt(0);
- isNullList.put((byte) 1);
- }
- }
- break;
- }
-
- case TSDBConstants.TSDB_DATA_TYPE_UTINYINT:
- case TSDBConstants.TSDB_DATA_TYPE_USMALLINT:
- case TSDBConstants.TSDB_DATA_TYPE_UINT:
- case TSDBConstants.TSDB_DATA_TYPE_UBIGINT: {
- throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "not support data types");
- }
- };
-
- connector.bindColumnDataArray(this.nativeStmtHandle, colDataList, lengthList, isNullList, col1.type, col1.bytes, rows, i);
- }
- }
-
- public void columnDataExecuteBatch() throws SQLException {
- TSDBJNIConnector connector = ((TSDBConnection) this.getConnection()).getConnector();
- connector.executeBatch(this.nativeStmtHandle);
- this.columnDataClearBatch();
- }
-
+
+ switch (col1.type) {
+ case TSDBConstants.TSDB_DATA_TYPE_INT: {
+ for (int j = 0; j < rows; ++j) {
+ Integer val = (Integer) col1.data.get(j);
+ colDataList.putInt(val == null ? Integer.MIN_VALUE : val);
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_TINYINT: {
+ for (int j = 0; j < rows; ++j) {
+ Byte val = (Byte) col1.data.get(j);
+ colDataList.put(val == null ? 0 : val);
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_BOOL: {
+ for (int j = 0; j < rows; ++j) {
+ Boolean val = (Boolean) col1.data.get(j);
+ if (val == null) {
+ colDataList.put((byte) 0);
+ } else {
+ colDataList.put((byte) (val ? 1 : 0));
+ }
+
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_SMALLINT: {
+ for (int j = 0; j < rows; ++j) {
+ Short val = (Short) col1.data.get(j);
+ colDataList.putShort(val == null ? 0 : val);
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP:
+ case TSDBConstants.TSDB_DATA_TYPE_BIGINT: {
+ for (int j = 0; j < rows; ++j) {
+ Long val = (Long) col1.data.get(j);
+ colDataList.putLong(val == null ? 0 : val);
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_FLOAT: {
+ for (int j = 0; j < rows; ++j) {
+ Float val = (Float) col1.data.get(j);
+ colDataList.putFloat(val == null ? 0 : val);
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_DOUBLE: {
+ for (int j = 0; j < rows; ++j) {
+ Double val = (Double) col1.data.get(j);
+ colDataList.putDouble(val == null ? 0 : val);
+ isNullList.put((byte) (val == null ? 1 : 0));
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_NCHAR:
+ case TSDBConstants.TSDB_DATA_TYPE_BINARY: {
+ String charset = TaosGlobalConfig.getCharset();
+ for (int j = 0; j < rows; ++j) {
+ String val = (String) col1.data.get(j);
+
+ colDataList.position(j * col1.bytes); // seek to the correct position
+ if (val != null) {
+ byte[] b = null;
+ try {
+ if (col1.type == TSDBConstants.TSDB_DATA_TYPE_BINARY) {
+ b = val.getBytes();
+ } else {
+ b = val.getBytes(charset);
+ }
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+
+ if (val.length() > col1.bytes) {
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "string data too long");
+ }
+
+ colDataList.put(b);
+ lengthList.putInt(b.length);
+ isNullList.put((byte) 0);
+ } else {
+ lengthList.putInt(0);
+ isNullList.put((byte) 1);
+ }
+ }
+ break;
+ }
+
+ case TSDBConstants.TSDB_DATA_TYPE_UTINYINT:
+ case TSDBConstants.TSDB_DATA_TYPE_USMALLINT:
+ case TSDBConstants.TSDB_DATA_TYPE_UINT:
+ case TSDBConstants.TSDB_DATA_TYPE_UBIGINT: {
+ throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_UNKNOWN, "not support data types");
+ }
+ }
+ ;
+
+ connector.bindColumnDataArray(this.nativeStmtHandle, colDataList, lengthList, isNullList, col1.type, col1.bytes, rows, i);
+ }
+ }
+
+ public void columnDataExecuteBatch() throws SQLException {
+ TSDBJNIConnector connector = ((TSDBConnection) this.getConnection()).getConnector();
+ connector.executeBatch(this.nativeStmtHandle);
+ this.columnDataClearBatch();
+ }
+
public void columnDataClearBatch() {
- int size = this.colData.size();
- this.colData.clear();
-
+ int size = this.colData.size();
+ this.colData.clear();
+
this.colData.addAll(Collections.nCopies(size, null));
this.tableName = null; // clear the table name
}
-
+
public void columnDataCloseBatch() throws SQLException {
- TSDBJNIConnector connector = ((TSDBConnection) this.getConnection()).getConnector();
- connector.closeBatch(this.nativeStmtHandle);
-
- this.nativeStmtHandle = 0L;
- this.tableName = null;
+ TSDBJNIConnector connector = ((TSDBConnection) this.getConnection()).getConnector();
+ connector.closeBatch(this.nativeStmtHandle);
+
+ this.nativeStmtHandle = 0L;
+ this.tableName = null;
}
}
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSet.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSet.java
index aba29d602b8900d3bedee49ee94e7d226b3bd1f0..59a64ad520f01c8c7f2b85f95057365e2410ecb6 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSet.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSet.java
@@ -133,9 +133,10 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.getString(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = this.rowData.getString(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getString(columnIndex, nativeType);
}
return res;
}
@@ -147,9 +148,10 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.getBoolean(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = this.rowData.getBoolean(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getBoolean(columnIndex, nativeType);
}
return res;
}
@@ -161,9 +163,10 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return (byte) this.blockData.getInt(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = (byte) this.rowData.getInt(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = (byte) this.rowData.getInt(columnIndex, nativeType);
}
return res;
}
@@ -175,9 +178,10 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return (short) this.blockData.getInt(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = (short) this.rowData.getInt(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = (short) this.rowData.getInt(columnIndex, nativeType);
}
return res;
}
@@ -189,9 +193,11 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.getInt(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = this.rowData.getInt(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getInt(columnIndex, nativeType);
}
return res;
}
@@ -203,13 +209,15 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.getLong(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- Object value = this.rowData.get(columnIndex - 1);
- if (value instanceof Timestamp)
+ Object value = this.rowData.getObject(columnIndex);
+ if (value instanceof Timestamp) {
res = ((Timestamp) value).getTime();
- else
- res = this.rowData.getLong(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ } else {
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getLong(columnIndex, nativeType);
+ }
}
return res;
}
@@ -221,9 +229,11 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return (float) this.blockData.getDouble(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
- if (!lastWasNull)
- res = this.rowData.getFloat(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
+ if (!lastWasNull) {
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getFloat(columnIndex, nativeType);
+ }
return res;
}
@@ -235,9 +245,10 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.getDouble(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = this.rowData.getDouble(columnIndex - 1, this.columnMetaDataList.get(columnIndex - 1).getColType());
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getDouble(columnIndex, nativeType);
}
return res;
}
@@ -245,34 +256,27 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
public byte[] getBytes(int columnIndex) throws SQLException {
checkAvailability(columnIndex, this.columnMetaDataList.size());
- Object value = this.rowData.get(columnIndex - 1);
+ Object value = this.rowData.getObject(columnIndex);
if (value == null)
return null;
- int colType = this.columnMetaDataList.get(columnIndex - 1).getColType();
- switch (colType) {
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ switch (nativeType) {
case TSDBConstants.TSDB_DATA_TYPE_BIGINT:
- return Longs.toByteArray((Long) value);
+ return Longs.toByteArray((long) value);
case TSDBConstants.TSDB_DATA_TYPE_INT:
return Ints.toByteArray((int) value);
case TSDBConstants.TSDB_DATA_TYPE_SMALLINT:
- return Shorts.toByteArray((Short) value);
+ return Shorts.toByteArray((short) value);
case TSDBConstants.TSDB_DATA_TYPE_TINYINT:
return new byte[]{(byte) value};
+ case TSDBConstants.TSDB_DATA_TYPE_BINARY:
+ return (byte[]) value;
+ case TSDBConstants.TSDB_DATA_TYPE_BOOL:
+ case TSDBConstants.TSDB_DATA_TYPE_NCHAR:
+ default:
+ return value.toString().getBytes();
}
- return value.toString().getBytes();
- }
-
- @Override
- public Date getDate(int columnIndex) throws SQLException {
- Timestamp timestamp = getTimestamp(columnIndex);
- return timestamp == null ? null : new Date(timestamp.getTime());
- }
-
- @Override
- public Time getTime(int columnIndex) throws SQLException {
- Timestamp timestamp = getTimestamp(columnIndex);
- return timestamp == null ? null : new Time(timestamp.getTime());
}
public Timestamp getTimestamp(int columnIndex) throws SQLException {
@@ -282,9 +286,10 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.getTimestamp(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- res = this.rowData.getTimestamp(columnIndex - 1);
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ res = this.rowData.getTimestamp(columnIndex, nativeType);
}
return res;
}
@@ -304,13 +309,9 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return this.blockData.get(columnIndex - 1);
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
if (!lastWasNull) {
- int colType = this.columnMetaDataList.get(columnIndex - 1).getColType();
- if (colType == TSDBConstants.TSDB_DATA_TYPE_BINARY)
- res = ((String) this.rowData.get(columnIndex - 1)).getBytes();
- else
- res = this.rowData.get(columnIndex - 1);
+ res = this.rowData.getObject(columnIndex);
}
return res;
}
@@ -318,7 +319,7 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
public int findColumn(String columnLabel) throws SQLException {
for (ColumnMetaData colMetaData : this.columnMetaDataList) {
if (colMetaData.getColName() != null && colMetaData.getColName().equalsIgnoreCase(columnLabel)) {
- return colMetaData.getColIndex() + 1;
+ return colMetaData.getColIndex();
}
}
throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_INVALID_VARIABLE);
@@ -329,25 +330,25 @@ public class TSDBResultSet extends AbstractResultSet implements ResultSet {
if (this.getBatchFetch())
return new BigDecimal(this.blockData.getLong(columnIndex - 1));
- this.lastWasNull = this.rowData.wasNull(columnIndex - 1);
+ this.lastWasNull = this.rowData.wasNull(columnIndex);
BigDecimal res = null;
if (!lastWasNull) {
- int colType = this.columnMetaDataList.get(columnIndex - 1).getColType();
- switch (colType) {
+ int nativeType = this.columnMetaDataList.get(columnIndex - 1).getColType();
+ switch (nativeType) {
case TSDBConstants.TSDB_DATA_TYPE_TINYINT:
case TSDBConstants.TSDB_DATA_TYPE_SMALLINT:
case TSDBConstants.TSDB_DATA_TYPE_INT:
case TSDBConstants.TSDB_DATA_TYPE_BIGINT:
- res = new BigDecimal(Long.valueOf(this.rowData.get(columnIndex - 1).toString()));
+ res = new BigDecimal(Long.valueOf(this.rowData.getObject(columnIndex).toString()));
break;
case TSDBConstants.TSDB_DATA_TYPE_FLOAT:
case TSDBConstants.TSDB_DATA_TYPE_DOUBLE:
- res = new BigDecimal(Double.valueOf(this.rowData.get(columnIndex - 1).toString()));
+ res = new BigDecimal(Double.valueOf(this.rowData.getObject(columnIndex).toString()));
break;
case TSDBConstants.TSDB_DATA_TYPE_TIMESTAMP:
- return new BigDecimal(((Timestamp) this.rowData.get(columnIndex - 1)).getTime());
+ return new BigDecimal(((Timestamp) this.rowData.getObject(columnIndex)).getTime());
default:
- res = new BigDecimal(this.rowData.get(columnIndex - 1).toString());
+ res = new BigDecimal(this.rowData.getObject(columnIndex).toString());
}
}
return res;
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetMetaData.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetMetaData.java
index e4ac5303d09f132279e29039bf6b5b812b6c5404..48d42473926b638401cf5d9dd97466695ba452ab 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetMetaData.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetMetaData.java
@@ -113,6 +113,7 @@ public class TSDBResultSetMetaData extends WrapperImpl implements ResultSetMetaD
ColumnMetaData columnMetaData = this.colMetaDataList.get(column - 1);
switch (columnMetaData.getColType()) {
+
case TSDBConstants.TSDB_DATA_TYPE_FLOAT:
return 5;
case TSDBConstants.TSDB_DATA_TYPE_DOUBLE:
diff --git a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetRowData.java b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetRowData.java
index 618e896a6ddfe43d63f631b663a356f485575b06..01104440ab00c974aa021f10b4168c3f1332e91a 100644
--- a/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetRowData.java
+++ b/src/connector/jdbc/src/main/java/com/taosdata/jdbc/TSDBResultSetRowData.java
@@ -14,6 +14,8 @@
*****************************************************************************/
package com.taosdata.jdbc;
+import com.taosdata.jdbc.utils.NullType;
+
import java.math.BigDecimal;
import java.sql.SQLException;
import java.sql.Timestamp;
@@ -22,11 +24,13 @@ import java.util.ArrayList;
import java.util.Collections;
public class TSDBResultSetRowData {
+
private ArrayList