云服务器内容精选

华为云首页用户手册

使用JDBC提交Spark SQL作业

数据湖探索 DLI-JDBC API参考:支持的API列表

支持的API列表 DLI JDBC Driver支持的API列表如下，对可能与JDBC标准产生歧义的地方加以备注说明。 Connection API支持的常用方法签名： Statement createStatement() PreparedStatement prepareStatement(String sql) void close() boolean isClosed() DatabaseMetaData getMetaData() PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) Driver API支持的常用方法签名： Connection connect(String url, Properties info) boolean acceptsURL(String url) DriverPropertyInfo[] getPropertyInfo(String url, Properties info) ResultSetMetaData API支持的常用方法签名： String getColumnClassName(int column) int getColumnCount() int getColumnDisplaySize(int column) String getColumnLabel(int column) String getColumnName(int column) int getColumnType(int column) String getColumnTypeName(int column) int getPrecision(int column) int getScale(int column) boolean isCaseSensitive(int column) Statement API支持的常用方法签名： ResultSet executeQuery(String sql) int executeUpdate(String sql) boolean execute(String sql) void close() int getMaxRows() void setMaxRows(int max) int getQueryTimeout() void setQueryTimeout(int seconds) void cancel() ResultSet getResultSet() int getUpdateCount() boolean isClosed() PreparedStatement API支持的常用方法签名： void clearParameters() boolean execute() ResultSet executeQuery() int executeUpdate() PreparedStatement Set系列方法 ResultSet API支持的常用方法签名： int getRow() boolean isClosed() boolean next() void close() int findColumn(String columnLabel) boolean wasNull() get系列方法 DatabaseMetaData API支持的常用方法签名 ResultSet getCatalogs() 在DLI服务中没有Catalog的概念，返回空的ResultSet。 ResultSet getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) Connection getConnection() getTables(String catalog, String schemaPattern,String tableNamePattern, String types[]) 该方法不采纳Catalog参数，schemaPattern对应DLI服务的database的概念。 ResultSet getTableTypes() ResultSet getSchemas() ResultSet getSchemas(String catalog, String schemaPattern)

数据湖探索 DLI 使用JDBC提交Spark SQL作业
数据湖探索 DLI-使用JDBC提交作业:操作场景

操作场景在Linux或Windows环境下您可以使用JDBC应用程序连接DLI服务端提交作业。使用JDBC连接DLI提交的作业运行在Spark引擎上。 DLI支持13种数据类型，每一种类型都可以映射成一种JDBC类型，在使用JDBC连接服务器时，请使用映射后的JAVA类型，映射关系如表1所示。表1 数据类型映射 DLI类型 JDBC类型 JAVA类型 INT INTEGER java.lang.Integer STRING VARCHAR java.lang.String FLOAT FLOAT java.lang.Float DOUBLE DOUBLE java.lang.Double DECIMAL DECIMAL java.math.BigDecimal BOOLEAN BOOLEAN java.lang.Boolean SMALLINT/SHORT SMALLINT java.lang.Short TINYINT TINYINT java.lang.Short BIGINT/LONG BIGINT java.lang.Long TIMESTAMP TIMESTAMP java.sql.Timestamp CHAR CHAR Java.lang.Character VARCHAR VARCHAR java.lang.String DATE DATE java.sql.Date

数据湖探索 DLI 使用JDBC提交Spark SQL作业