当前位置：首页 > 数据库 > 正文

Java如何创建数据库表

admin
数据库
2025-06-20
2097

在Java中创建数据库表需使用JDBC API：加载驱动、建立连接，通过Statement对象执行SQL的CREATE TABLE语句，定义表名、列名及数据类型，最后关闭资源。

核心步骤

环境准备

导入JDBC驱动：在项目中添加数据库驱动（如MySQL的mysql-connector-java或Oracle的ojdbc）。

<!-- Maven示例（MySQL） -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.33</version>
</dependency>

建立数据库连接

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class CreateTableExample {
    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC";
        String user = "root";
        String password = "yourpassword";
        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            System.out.println("数据库连接成功！");
            createTable(conn); // 调用建表方法
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

编写建表SQL语句

根据需求设计表结构,例如创建用户表：

CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL UNIQUE,
    email VARCHAR(100) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

IF NOT EXISTS：避免重复创建。
AUTO_INCREMENT：自增主键。
DEFAULT：设置默认值。

使用JDBC执行SQL

import java.sql.Statement;
private static void createTable(Connection conn) throws SQLException {
    String sql = "CREATE TABLE IF NOT EXISTS users ("
            + "id INT AUTO_INCREMENT PRIMARY KEY,"
            + "username VARCHAR(50) NOT NULL UNIQUE,"
            + "email VARCHAR(100) NOT NULL,"
            + "created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP"
            + ")";
    try (Statement stmt = conn.createStatement()) {
        stmt.executeUpdate(sql); // 执行SQL
        System.out.println("表创建成功（或已存在）");
    }
}

关键注意事项

异常处理：
- 捕获SQLException并处理连接/执行错误。
- 使用try-with-resources自动关闭资源（JDK 7+）。
防SQL注入：
- 建表语句无需参数化，但其他操作（如INSERT）应使用PreparedStatement。

事务管理：

默认自动提交事务,需手动控制时：

conn.setAutoCommit(false); // 关闭自动提交
// 执行多个SQL...
conn.commit(); // 提交事务

数据库兼容性：
- SQL语法因数据库而异（如MySQL的AUTO_INCREMENT vs PostgreSQL的SERIAL）。

最佳实践

表结构设计原则：
- 主键选择：推荐自增整数或UUID。
- 字段约束：使用NOT NULL、UNIQUE等保障数据完整性。
- 索引优化：对高频查询字段添加索引（需在创建表后单独执行）。

代码健壮性：

检查表是否存在：通过DatabaseMetaData避免重复创建。

DatabaseMetaData meta = conn.getMetaData();
ResultSet rs = meta.getTables(null, null, "users", null);
if (!rs.next()) {
    // 表不存在时创建
}

连接池使用：
- 生产环境用HikariCP或Druid替代DriverManager，提升性能。

完整代码示例

import java.sql.*;
public class TableCreator {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydb";
        String user = "root";
        String password = "securepass";
        try (Connection conn = DriverManager.getConnection(url, user, password);
             Statement stmt = conn.createStatement()) {
            String sql = "CREATE TABLE IF NOT EXISTS employees ("
                    + "emp_id INT AUTO_INCREMENT PRIMARY KEY,"
                    + "name VARCHAR(100) NOT NULL,"
                    + "department VARCHAR(50),"
                    + "salary DECIMAL(10, 2) CHECK (salary > 0)"
                    + ")";
            stmt.executeUpdate(sql);
            System.out.println("表 'employees' 已就绪");
        } catch (SQLException e) {
            System.err.println("错误: " + e.getMessage());
        }
    }
}