您的位置:

executeUpdate返回值详解

一、executeUpdate的返回值说明

1、executeUpdate方法是JDBC中用来执行SQL语句的一个方法,主要用来执行INSERT、UPDATE、DELETE这三种SQL语句。

2、executeUpdate方法返回值是一个整数,表示执行SQL语句后影响的行数。

3、如果执行INSERT语句,返回值就是插入的行数;如果执行UPDATE或DELETE语句,返回值就是被影响的行数。

String sql = "INSERT INTO user(name, age, sex) VALUES ('Jack', 18, 1)";
Statement statement = connection.createStatement();
int result = statement.executeUpdate(sql);

二、executeUpdate返回0的情况

1、如果执行INSERT语句,但是插入的数据与数据库表中现有的数据重复,则返回0。

String sql = "INSERT INTO user(name, age, sex) VALUES ('Tom', 20, 1)";
Statement statement = connection.createStatement();
int result = statement.executeUpdate(sql);
// 如果数据库中已经有一条name为Tom、age为20、sex为1的记录,则result的值为0。

2、如果执行UPDATE或DELETE语句,但是受影响的行数为0,则返回0。

String sql = "UPDATE user SET age=21 WHERE name='Lucy'";
Statement statement = connection.createStatement();
int result = statement.executeUpdate(sql);
// 如果数据库中不存在name为Lucy的记录,则result的值为0。

三、executeUpdate在批处理中的应用

批处理是指在一次数据库连接中,同时发送多个SQL语句给数据库进行执行的一种方式。它可以提高执行效率,减少与数据库的通信次数。

使用executeUpdate方法可以方便地完成批处理操作。在执行批处理时,executeUpdate返回的是一个数组,数组中的每个元素分别是对应SQL语句影响的行数。

String[] sqls = {"INSERT INTO user(name, age, sex) VALUES ('Amy', 21, 0)",
        "INSERT INTO user(name, age, sex) VALUES ('Ben', 22, 1)",
        "UPDATE user SET age=23 WHERE name='Lucy'",
        "DELETE FROM user WHERE name='Tom'"};
Statement statement = connection.createStatement();
// 添加需要处理的SQL语句
for (String sql : sqls) {
    statement.addBatch(sql);
}
// 执行批处理操作
int[] results = statement.executeBatch();
// 遍历结果数组
for (int result : results) {
    System.out.println(result);
}

四、executeUpdate和事务处理

事务是指一组操作,要么全部执行成功,要么全部执行失败。在JDBC中,执行事务需要以下几个步骤:

1、禁用自动提交,将数据库连接的AutoCommit属性设置为false。

2、使用executeUpdate方法执行多个SQL语句。

3、如果所有操作都执行成功,则使用commit方法提交事务;否则使用rollback方法回滚事务。

try {
    // 禁用自动提交
    connection.setAutoCommit(false);
    Statement statement = connection.createStatement();
    // 执行多个SQL语句
    statement.executeUpdate("UPDATE user SET age=20 WHERE name='Jack'");
    statement.executeUpdate("UPDATE user SET age=22 WHERE name='Tom'");
    statement.executeUpdate("UPDATE user SET age=21 WHERE name='Lucy'");
    statement.executeUpdate("INSERT INTO user(name, age, sex) VALUES ('Mary', 19, 0)");
    // 提交事务
    connection.commit();
} catch (SQLException e) {
    // 回滚事务
    connection.rollback();
    e.printStackTrace();
}

五、executeUpdate的错误处理

1、executeUpdate方法会抛出SQLException异常,在程序中应该对其进行捕获和处理。

try {
    String sql = "INSERT INTO user(name, age, sex) VALUES ('Leo', 18, 1)";
    Statement statement = connection.createStatement();
    int result = statement.executeUpdate(sql);
} catch (SQLException e) {
    e.printStackTrace();
}

2、在编写SQL语句时,避免使用不正确的语法或拼写错误,可以通过预编译的方式来防止SQL注入攻击等安全问题。

String sql = "INSERT INTO user(name, age, sex) VALUES (?, ?, ?)";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, "Zeus");
preparedStatement.setInt(2, 25);
preparedStatement.setInt(3, 1);
int result = preparedStatement.executeUpdate();

六、executeUpdate的适用场景

1、executeUpdate适用于执行INSERT、UPDATE、DELETE语句等对数据进行修改的SQL语句。

2、对于SELECT语句等用于查询数据的SQL语句,应该使用executeQuery方法。

3、如果需要查询并修改数据,可以使用execute方法执行综合的SQL语句。

七、总结

executeUpdate方法是执行INSERT、UPDATE、DELETE等SQL语句的核心方法,在JDBC编程中应用广泛。通过对executeUpdate返回值的详细阐述,我们可以更好地掌握该方法的使用方法和应用场景,为我们的编程工作提供更多便利。