转载至:https://www.liyongzhen.com/
上一节课里我们学习通过PreparedStatement对象执行带参数的查询SQL和修改SQL。
这节课我们学习使用 PreparedStatement对象执行插入SQL,并且返回主键。
要返回主键,有一个前提,就是数据库表必须有主键自增。
下面的代码演示了执行插入SQL并返回主键的用法。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
String sql = "INSERT INTO products(`ProductName`,`SupplierID`,`CategoryID`,`Unit`,`Price`)VALUES(?,?,?,?,?);" ;
PreparedStatement statement = connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS); //加入参数Statement.RETURN_GENERATED_KEYS
statement.setString( 1 , "milk" ); //设置参数……
statement.setLong( 2 , 16 );
statement.setLong( 3 , 1 );
statement.setString( 4 , "500ml" );
statement.setBigDecimal( 5 , new BigDecimal( 5.6 ));
int value = statement.executeUpdate();
System.out.println( "受影响的记录数 " +value);
int id = 0 ;
ResultSet rs = statement.getGeneratedKeys(); //得到生成的主键,主键放在ResultSet对象里
if (rs.next()){ //提取主键值
id = rs.getInt( 1 );
} System.out.println( "主键 " +id);
|
关键技术:
- 在创建PreparedStatement对象时,指定一个常量Statement.RETURN_GENERATED_KEYS,表示有返回主键的能力。
- 执行SQL语句时,仍然调用executeUpdate()方法。另外要调用getGeneratedKeys()方法,返回ResultSet对象。 ResultSet对象是结果集,存储查询结果,主键就保存在这里。
- 第三步,从ResultSet对象里提取主键。
完整代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
import java.math.BigDecimal; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class Insert { public static void main(String[] args) {
String url = "jdbc:mysql://127.0.0.1:3306/northwind";
String user = "northwind";
String password = "northwind";
try (Connection connection = DriverManager.getConnection(url, user, password)) {
String sql = "INSERT INTO products(`ProductName`,`SupplierID`,`CategoryID`,`Unit`,`Price`)VALUES(?,?,?,?,?);";
PreparedStatement statement = connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
statement.setString(1, "milk");
statement.setLong(2, 16);
statement.setLong(3, 1);
statement.setString(4, "500ml");
statement.setBigDecimal(5, new BigDecimal(5.6));
int value = statement.executeUpdate();
System.out.println("受影响的记录数 "+value);
int id = 0;
ResultSet rs = statement.getGeneratedKeys();
if(rs.next()){
id = rs.getInt(1);
}
System.out.println("主键 "+id);
rs.close();
statement.close(); // 关闭statement,释资源
} catch (SQLException e) {
e.printStackTrace();
}
}
} |