Java连接Sql数据库经常用到的操作

Java连接Sql数据库操作攻略

Java连接Sql数据库操作可以分为以下几个步骤：

1. 加载数据库驱动
2. 连接数据库
3. 创建Statement对象
4. 执行SQL语句
5. 处理结果

下面详细讲解这几个步骤。

1. 加载数据库驱动

在连接Sql数据库之前，首先需要加载数据库驱动。例如，如果想要连接MySQL数据库，可以使用以下代码加载驱动：

Class.forName("com.mysql.jdbc.Driver");

这里使用了Class.forName()方法来加载驱动。注意，不同的数据库驱动类的名称可能不同。

2. 连接数据库

连接数据库需要指定数据库的URL、用户名和密码。例如，如果想要连接名为mydb的MySQL数据库，用户名为root，密码为123456，可以使用以下代码：

String url = "jdbc:mysql://localhost/mydb";
String username = "root";
String password = "123456";
Connection conn = DriverManager.getConnection(url, username, password);

3. 创建Statement对象

连接成功后，需要创建Statement对象来执行SQL语句。例如，如果想要查询用户表格中所有的用户名和密码，可以使用以下代码：

String sql = "SELECT username, password FROM user";
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(sql);

4. 执行SQL语句

创建Statement对象后，需要执行SQL语句。例如，如果想要更新用户表格中用户名为john的密码为123456，可以使用以下代码：

String sql = "UPDATE user SET password = '123456' WHERE username = 'john'";
Statement stmt = conn.createStatement();
int rows = stmt.executeUpdate(sql);

5. 处理结果

执行SQL语句后，需要处理查询结果或者更新结果。例如，如果执行查询语句返回了结果集，可以使用以下代码处理结果：

while(rs.next()) {
    String username = rs.getString("username");
    String password = rs.getString("password");
    System.out.println("Username: " + username + ", Password: " + password);
}

如果执行更新语句返回了影响的行数，可以使用以下代码处理结果：

if(rows > 0) {
    System.out.println(rows + " rows updated.");
} else {
    System.out.println("Update failed.");
}

以下是两个示例：

示例1： 查询数据库中的用户信息

String url = "jdbc:mysql://localhost/mydb";
String username = "root";
String password = "123456";
try {
    // 加载数据库驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 连接数据库
    Connection conn = DriverManager.getConnection(url, username, password);
    // 创建Statement对象，执行SQL语句
    String sql = "SELECT username, password FROM user";
    Statement stmt = conn.createStatement();
    ResultSet rs = stmt.executeQuery(sql);
    // 处理结果
    while(rs.next()) {
        String username = rs.getString("username");
        String password = rs.getString("password");
        System.out.println("Username: " + username + ", Password: " + password);
    }
    // 关闭数据库连接
    rs.close();
    stmt.close();
    conn.close();
} catch (ClassNotFoundException e) {
    e.printStackTrace();
} catch (SQLException e) {
    e.printStackTrace();
}

示例2： 更新数据库中的用户信息

String url = "jdbc:mysql://localhost/mydb";
String username = "root";
String password = "123456";
try {
    // 加载数据库驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 连接数据库
    Connection conn = DriverManager.getConnection(url, username, password);
    // 创建Statement对象，执行SQL语句
    String sql = "UPDATE user SET password = '123456' WHERE username = 'john'";
    Statement stmt = conn.createStatement();
    int rows = stmt.executeUpdate(sql);
    // 处理结果
    if(rows > 0) {
        System.out.println(rows + " rows updated.");
    } else {
        System.out.println("Update failed.");
    }
    // 关闭数据库连接
    stmt.close();
    conn.close();
} catch (ClassNotFoundException e) {
    e.printStackTrace();
} catch (SQLException e) {
    e.printStackTrace();
}

以上就是Java连接Sql数据库经常用到的操作攻略，希望对你有帮助！