JDBC - 创建表

上一页
下一页

本章提供使用 JDBC 应用程序创建表、临时表和复制表的示例。在执行以下示例之前，请确保已准备好以下内容：

  • 要执行以下示例，您可以将用户名和密码替换为您实际的用户名和密码。

  • 您的 MySQL 正在运行。

必要步骤

使用 JDBC 应用程序创建新数据库需要以下步骤：

  • 导入包 - 需要包含用于数据库编程所需的 JDBC 类所在的包。大多数情况下，使用import java.sql.*就足够了。

  • 打开连接 - 需要使用DriverManager.getConnection()方法创建一个 Connection 对象，该对象表示与数据库服务器的物理连接。

  • 执行查询 - 需要使用 Statement 类型的对象来构建和提交 SQL 语句，以便在选定的数据库中创建一个表。

  • 清理环境 - try with resources 会自动关闭资源。

示例：创建表

在本例中，我们有三个静态字符串，包含数据库连接 URL、用户名、密码。现在使用 DriverManager.getConnection() 方法，我们准备了一个数据库连接。连接准备就绪后，我们使用 createStatement() 方法准备了一个 Statement 对象。下一步，我们准备了一个 SQL 字符串来创建一个新的 REGISTRATION 表，并通过调用 statement.executeUpdate() 方法在数据库中创建了该表。

如果在连接到数据库时发生任何异常，catch 块将处理 SQLException 并打印堆栈跟踪。

将以下示例复制并粘贴到 TestApplication.java 中，编译并运行如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class TestApplication {
   static final String DB_URL = "jdbc:mysql://127.0.0.1/TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";

   public static void main(String[] args) {
      // Open a connection
      try(Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         Statement stmt = conn.createStatement();
      ) {		      
          String sql = "CREATE TABLE REGISTRATION " +
                   "(id INTEGER not NULL, " +
                   " first VARCHAR(255), " + 
                   " last VARCHAR(255), " + 
                   " age INTEGER, " + 
                   " PRIMARY KEY ( id ))"; 

         stmt.executeUpdate(sql);
         System.out.println("Created table in given database...");   	  
      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

现在让我们按照如下方式编译上述示例：

C:\>javac TestApplication.java
C:\>

运行TestApplication时，会产生以下结果：

C:\>java TestApplication
Created table in given database...
C:\>

示例：创建临时表

我们可以创建一个临时表，该表仅在活动会话期间存在。MySQL、SQL Server、Oracle 等都支持临时表。

在本例中，我们有三个静态字符串，包含数据库连接 URL、用户名、密码。现在使用 DriverManager.getConnection() 方法，我们准备了一个数据库连接。连接准备就绪后，我们使用 createStatement() 方法准备了一个 Statement 对象。下一步，我们准备了一个 SQL 字符串来创建一个新的临时表 EMPLOYEES_COPY，并通过调用 statement.execute() 方法在数据库中创建了该表。

在下一行代码中，我们创建了一个查询字符串以获取新创建的临时表 EMPLOYEES_COPY 中的所有记录。查询使用 statement.executeQuery() 方法触发，结果存储在 ResultSet 中。迭代 ResultSet 以打印所有员工。

如果在连接到数据库时发生任何异常，catch 块将处理 SQLException 并打印堆栈跟踪。

将以下示例复制并粘贴到 TestApplication.java 中，编译并运行如下：

import java.sql.*;

public class TestApplication {

   static final String DB_URL = "jdbc:mysql://127.0.0.1/TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";

   public static void main(String args[]) {
      try{
         Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         Statement stmt = conn.createStatement();

         String QUERY1 = "CREATE TEMPORARY TABLE EMPLOYEES_COPY SELECT * FROM EMPLOYEES";
         stmt.execute(QUERY1);
         String QUERY2 = "SELECT * FROM EMPLOYEES_COPY";
         ResultSet rs = stmt.executeQuery(QUERY2);

         while (rs.next()){
            System.out.print("Id: " + rs.getInt("id"));
            System.out.print(" Age: " + rs.getInt("age"));
            System.out.print(" First: " + rs.getString("first"));
            System.out.println(" Last: " + rs.getString("last"));
            System.out.println("------------------------------------------");
         }
      }catch (SQLException e){
         e.printStackTrace();
      }       
   }
}

现在让我们按照如下方式编译上述示例：

C:\>javac TestApplication.java
C:\>

运行TestApplication时，会产生以下结果：

C:\>java TestApplication
Id: 1 Age: 18 First: Zara Last: Ali
------------------------------------------
Id: 2 Age: 25 First: Mahnaz Last: Fatma
------------------------------------------
Id: 3 Age: 20 First: Zaid Last: Khan
------------------------------------------
Id: 4 Age: 28 First: Sumit Last: Mittal
------------------------------------------
Id: 7 Age: 20 First: Rita Last: Tez
-----------------------------------------
Id: 8 Age: 20 First: Sita Last: Singh
------------------------------------------
Id: 21 Age: 35 First: Jeevan Last: Rao
------------------------------------------
Id: 22 Age: 40 First: Aditya Last: Chaube
------------------------------------------
Id: 25 Age: 35 First: Jeevan Last: Rao
------------------------------------------
Id: 26 Age: 35 First: Aditya Last: Chaube
------------------------------------------
Id: 34 Age: 45 First: Ahmed Last: Ali
------------------------------------------
Id: 35 Age: 50 First: Raksha Last: Agarwal
------------------------------------------
C:\>

示例：创建复制表

我们可以创建一个与现有表完全相同的表。语法为

CREATE new_table_name LIKE orig_table_name;

执行该命令后，原始表中的所有数据都将复制到新表中。

在本例中，我们有三个静态字符串，包含数据库连接 URL、用户名、密码。现在使用 DriverManager.getConnection() 方法，我们准备了一个数据库连接。连接准备就绪后，我们使用 createStatement() 方法准备了一个 Statement 对象。下一步，我们准备了一个 SQL 字符串来创建一个新的复制表 EMPLOYEES_O，并通过调用 statement.execute() 方法在数据库中创建了该表。

在下一行代码中，我们创建了一个查询字符串以获取新创建的复制表 EMPLOYEES_O 中的所有记录。查询使用 statement.executeQuery() 方法触发，结果存储在 ResultSet 中。迭代 ResultSet 以打印所有员工。

如果在连接到数据库时发生任何异常，catch 块将处理 SQLException 并打印堆栈跟踪。

将以下示例复制并粘贴到 TestApplication.java 中，编译并运行如下：

import java.sql.*;
// This class demonstrates the way of creating a table which is exactly similar to another table.        
public class TestApplication {

   static final String DB_URL = "jdbc:mysql://127.0.0.1/TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";

   public static void main(String args[]) {

      try{
         Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         Statement stmt = conn.createStatement();
         String QUERY1 = "CREATE TABLE EMPLOYEES_O LIKE EMPLOYEES";            
         stmt.execute(QUERY1);

         ResultSet rs = stmt.executeQuery("SELECT * FROM EMPLOYEES");            

         System.out.println("Displaying records from EMPLOYEES_O");

         while (rs.next()){

            System.out.print("Id: " + rs.getInt("id"));
            System.out.print(" Age: " + rs.getInt("age"));
            System.out.print(" First: " + rs.getString("first"));
            System.out.println(" Last: " + rs.getString("last"));

            System.out.println("------------------------------------------");
         }

      }catch(SQLException e){
         e.printStackTrace();
      }
   }
}

现在让我们按照如下方式编译上述示例：

C:\>javac TestApplication.java
C:\>

运行TestApplication时，会产生以下结果：

C:\>java TestApplication
Displaying records from EMPLOYEES_O
Id: 1 Age: 18 First: Zara Last: Ali
------------------------------------------
Id: 2 Age: 25 First: Mahnaz Last: Fatma
------------------------------------------
Id: 3 Age: 20 First: Zaid Last: Khan
------------------------------------------
Id: 4 Age: 28 First: Sumit Last: Mittal
------------------------------------------
Id: 7 Age: 20 First: Rita Last: Tez
------------------------------------------
Id: 8 Age: 20 First: Sita Last: Singh
------------------------------------------
Id: 21 Age: 35 First: Jeevan Last: Rao
------------------------------------------
Id: 22 Age: 40 First: Aditya Last: Chaube
-----------------------------------------
Id: 25 Age: 35 First: Jeevan Last: Rao
------------------------------------------
Id: 26 Age: 35 First: Aditya Last: Chaube
------------------------------------------
Id: 34 Age: 45 First: Ahmed Last: Ali
------------------------------------------
Id: 35 Age: 50 First: Raksha Last: Agarwal
------------------------------------------
C:\>
打印页面
上一页
下一页
广告