Task Submission And Execution Of JDBC API

The first way depends on the JDBC module in the pom:

  1. <dependency>
  2.     <groupId>org.apache.linkis</groupId>
  3.     <artifactId>linkis-jdbc-driver</artifactId>
  4.     <version>${linkis.version}</version>
  5. </dependency>

Note: The module has not been deployed to the central repository. You need to execute mvn install -Dmaven.test.skip=true in the linkis-computation-governance/linkis-jdbc-driver directory for local installation.

The second way is through packaging and compilation:

  1. Enter the linkis-jdbc-driver directory in the Linkis project and enter the command in the terminal to package mvn assembly:assembly -Dmaven.test.skip=true The packaging instruction skips the running of the unit test and the compilation of the test code, and packages the dependencies required by the JDBC module into the Jar package.
  2. After the packaging is complete, two Jar packages will be generated in the target directory of JDBC. The one with dependencies in the Jar package name is the Jar package we need.

Establish a Java test class LinkisJDBCTest, the specific interface meaning can be seen in the notes:

  1. package org.apache.linkis.jdbc.test;
  3. import java.sql.*;
  5. public class LinkisJDBCTest {
  7.     public static void main(String[] args) throws SQLException, ClassNotFoundException {
  9.         //1. load driver：org.apache.linkis.ujes.jdbc.UJESSQLDriver
  10.         Class.forName("org.apache.linkis.ujes.jdbc.UJESSQLDriver");
  12.         //2. Get Connection：jdbc:linkis://gatewayIP:gatewayPort/dbName?EngineType=hive&creator=test, user/password   
  13.         Connection connection =  DriverManager.getConnection("jdbc:linkis://127.0.0.1:9001/default?EngineType=hive&creator=test","hadoop","hadoop");
  14.         //3. Create statement 
  15.         Statement st= connection.createStatement();
  16.         ResultSet rs=st.executeQuery("show tables");
  17.         //4.get result
  18.         while (rs.next()) {
  19.             ResultSetMetaData metaData = rs.getMetaData();
  20.             for (int i = 1; i <= metaData.getColumnCount(); i++) {
  21.                 System.out.print(metaData.getColumnName(i) + ":" +metaData.getColumnTypeName(i)+": "+ rs.getObject(i) + "    ");
  22.             }
  23.             System.out.println();
  24.         }
  25.         //close resource
  26.         rs.close();
  27.         st.close();
  28.         connection.close();
  29.     }
  30. }
  1. Where EngineType is the specified corresponding engine type: supports Spark/hive/presto/shell, etc.
  2. Creator is the specified corresponding application type, which is used for resource isolation between applications