java连接数据库定义sql语句的代码有哪些

开发百科 2025年11月18日 21:16 242 admin

Java连接数据库定义SQL语句的代码详解

在Java编程中,与数据库进行交互是常见的任务之一，为了实现这一目标，我们需要使用JDBC（Java Database Connectivity）API，本文将详细讲解如何使用Java连接数据库并定义SQL语句。

引入JDBC驱动包

我们需要确保项目中包含了相应的JDBC驱动包,对于MySQL数据库，我们可以使用MySQL Connector/J，以下是Maven项目的依赖配置：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.23</version>
</dependency>
加载JDBC驱动
我们需要在代码中加载JDBC驱动,这可以通过调用Class.forName()方法来实现：
try {
    Class.forName("com.mysql.cj.jdbc.Driver");
} catch (ClassNotFoundException e) {
    e.printStackTrace();
}
建立数据库连接
使用DriverManager.getConnection()方法可以建立与数据库的连接，需要提供数据库URL、用户名和密码作为参数：

String url = "jdbc:mysql://localhost:3306/yourdatabase";
String user = "yourusername";
String password = "yourpassword";
Connection connection = null;
try {
    connection = DriverManager.getConnection(url, user, password);
} catch (SQLException e) {
    e.printStackTrace();
}
创建Statement对象
通过连接对象可以创建一个Statement对象，用于执行SQL语句：
Statement statement = null;
try {
    statement = connection.createStatement();
} catch (SQLException e) {
    e.printStackTrace();
}
定义和执行SQL语句
我们可以使用Statement对象来定义和执行SQL语句，以下是一些常见的操作示例：
插入数据
String insertSql = "INSERT INTO employees (name, age, position) VALUES ('Alice', 30, 'Engineer')";
try {
    int rowsAffected = statement.executeUpdate(insertSql);
    System.out.println("Rows affected: " + rowsAffected);
} catch (SQLException e) {
    e.printStackTrace();
}
查询数据
String selectSql = "SELECT * FROM employees";
try {
    ResultSet resultSet = statement.executeQuery(selectSql);
    while (resultSet.next()) {
        String name = resultSet.getString("name");
        int age = resultSet.getInt("age");
        String position = resultSet.getString("position");
        System.out.println("Name: " + name + ", Age: " + age + ", Position: " + position);
    }
} catch (SQLException e) {
    e.printStackTrace();
}
更新数据
String updateSql = "UPDATE employees SET position = 'Manager' WHERE name = 'Alice'";
try {
    int rowsAffected = statement.executeUpdate(updateSql);
    System.out.println("Rows affected: " + rowsAffected);
} catch (SQLException e) {
    e.printStackTrace();
}
删除数据
String deleteSql = "DELETE FROM employees WHERE name = 'Bob'";
try {
    int rowsAffected = statement.executeUpdate(deleteSql);
    System.out.println("Rows affected: " + rowsAffected);
} catch (SQLException e) {
    e.printStackTrace();
}
关闭资源
不要忘记关闭ResultSet、Statement和Connection对象以释放资源：
if (resultSet != null) {
    try {
        resultSet.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
if (statement != null) {
    try {
        statement.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
if (connection != null) {
    try {
        connection.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
通过上述步骤,您可以使用Java轻松地连接数据库并执行各种SQL操作。