如何基于JDBC结果集创建MySQL表?
ResultSetMetadata 类提供了各种方法,可以获取当前 ResultSet 对象的信息,例如列数、表名、列名、列的数据类型等等。
要准备CREATE查询,您需要获取:
- 表名,使用 getTableName() 方法。
- 列数,使用 getColumnCount() 方法迭代列。
- 每列的名称,使用 getColumnName() 方法。
- 每列的数据类型,使用 getColumnTypeName() 方法。
- 每列的精度,使用 getPrecision() 方法。
示例
让我们使用如下所示的 CREATE 查询在 MySQL 数据库中创建一个名为 customers 的表:
CREATE TABLE Customers ( ID INT NOT NULL, NAME VARCHAR (20) NOT NULL, AGE INT NOT NULL, SALARY DECIMAL (18, 2), ADDRESS VARCHAR (25), PRIMARY KEY (ID) );
下面的JDBC程序在数据库中创建另一个名为 customers2 的表。
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; public class CreatingTableFromReusultSet { public static void main(String args[]) throws SQLException { //Registering the Driver DriverManager.registerDriver(new com.mysql.jdbc.Driver()); //Getting the connection String mysqlUrl = "jdbc:mysql://127.0.0.1/sampledatabase"; Connection con = DriverManager.getConnection(mysqlUrl, "root", "password"); System.out.println("Connection established......"); //Creating the Statement Statement stmt = con.createStatement(); //Query to retrieve records String query = "Select * from Customers"; //Executing the query ResultSet rs = stmt.executeQuery(query); //retrieving the ResultSetMetaData object ResultSetMetaData resultSetMetaData = rs.getMetaData(); //Retrieving the column count of the current table int columnCount = resultSetMetaData.getColumnCount(); String createQuery = "CREATE TABLE " +resultSetMetaData.getTableName(1)+"2 ("; String createQuery2 = ""; for(int i = 1; i<columnCount; i++ ) { createQuery2 = createQuery2+ resultSetMetaData.getColumnName(i)+ " "+resultSetMetaData.getColumnTypeName(i) +"("+resultSetMetaData.getPrecision(i)+"), "; } createQuery2 = createQuery2+ resultSetMetaData.getColumnName(columnCount)+ " "+resultSetMetaData.getColumnTypeName(columnCount) +"("+resultSetMetaData.getPrecision(columnCount)+") ) "; System.out.println("Query to create new table: "); System.out.println(createQuery+createQuery2); stmt.execute(createQuery+createQuery2); System.out.println("Table created ......."); } }
输出
Connection established...... Query to create new table: CREATE TABLE customers2 (ID INT(11), NAME VARCHAR(20), AGE INT(11), SALARY DECIMAL(18), ADDRESS VARCHAR(25) ) Table created ......
注意 - 这可能不适用于不需要声明精度的那些数据类型。例如,日期类型。
广告