JDBC补充 statement对象
statement对象
Jdbc中的statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需要通过这个对象向数据库发送增删改
查语句即可。
Statement对象的executeUpdate方法,用于向数据库发送增、删、改的sq|语句, executeUpdate执行完后,将会返回一个整
数(即增删改语句导致了数据库几行数据发生了变化)。
Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象。
CRUD操作-create
使用executeUpdate(String sq)方法完成数据添加操作,示例操作:
Statement st = conn.createstatement();
String sq1 = "insert into uer(...) values(....) ";
int num = st.executeupdate(sq1);
if (num>0){
System.out.print1n("插入成功!!!");
}
CRUD操作-delete
使用executeUpdate(String sq|)方法完成数据删除操作,示例操作:
Statement st = conn.CreateStatement();
String sq1 = "delete from user where id=1";
int num = st.executeupdate(sq1) ;
if (num>0){
System.out. print1n(“删除成功! ! ! ");
}
CRUD操作-update
使用executeUpdate(String sq|)方法完成数据修改操作,示例操作:
Statement st = conn.createStatement () ;
string sq1 = "update user set name='' where name='";
int num = st.executeupdate(sq1);
if(num>0){
System.out.print1n(“修改成功! ! ! ");
}
CRUD操作-read
使用executeQuery(String sq|)方法完成数据查询操作,示例操作:
Statement st = conn.createStatement();
string sq1 = "select * fcom user where id=1";
Resultset rs = st.executeupdate(sq1);
while(rs.next(){
//根据 获取列的数据类型,分别调用rs的相应方法映射到java对象中
}
代码实现
1、提取工具类
package com.lantian.lesson02.utils;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
public class jdbcUtils {
private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;
static {
try {
InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("src/db.properties");
Properties properties = new Properties();
properties.load(in);
driver = properties.getProperty("driver");
url = properties.getProperty("url");
username = properties.getProperty("username");
password = properties.getProperty("password");
//1. 驱动只用加载一次
Class.forName(driver);
} catch (Exception e){
e.printStackTrace();
}
}
//获取链接
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url, username, password);
}
//释放资源
public static void release(Connection connection, Statement statement, ResultSet resultSet){
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();
}
}
}
}
2、编写增删改查的方法 'executeUpdate'
3、查询