当前位置：网站首页>JDBC再回顾
JDBC再回顾
2022-08-02 04:12:00 【番茄好困】
文章目录
1.JDBC程序的编写步骤
- 加载并注册驱动（不同数据库的驱动是不同的（相当于每个数据库厂商实现的类））
- 创建Connection连接对象（连接数据库）
- 创建Statement或者PreparedStatement对象
- 执行SQL语句
- 使用ResultSet收集对象、关闭ResultSet对象（如果是增删改就不用）
- 关闭Statement或者PreparedStatement对象
2.加载驱动，获取连接
public class ConnectionTest {
// 获取连接对象
@Test
public void test1() throws Exception{
InputStream resourceAsStream = ConnectionTest.class.getClassLoader().getResourceAsStream("jdbc.properties");
Properties properties = new Properties();
properties.load(resourceAsStream);
String username = properties.getProperty("user");
String password = properties.getProperty("password");
String url = properties.getProperty("url");
String driver = properties.getProperty("driverClass");
Class.forName(driver);
Connection connection = DriverManager.getConnection(url, username,password);
System.out.println(connection);
}
}
3.创建Statement或者PraparedStatement对象
Connection.Statement();
Connection.prepareStatement(sql);
4.整体完整流程
4.1针对增删改操作
@Test
public void test2(){
Connection connection = null;
PreparedStatement ps = null;
try {
InputStream resourceAsStream = ConnectionTest.class.getClassLoader().getResourceAsStream("jdbc.properties");
Properties properties = new Properties();
properties.load(resourceAsStream);
String username = properties.getProperty("user");
String password = properties.getProperty("password");
String url = properties.getProperty("url");
String driver = properties.getProperty("driverClass");
// 1.注册驱动
Class.forName(driver);
// 2.获取连接
connection = DriverManager.getConnection(url, username,password);
// 3.SQL语句
String sql = "insert into customers(name,email,birth)values(?,?,?)";// ？是占位符
ps = connection.prepareStatement(sql);
// 替换占位符(下标从1开始)
ps.setString(1, "李四");
ps.setString(2, "[email protected]");
ps.setDate(3,new java.sql.Date(new Date().getTime()));
// 执行语句
int updateRow = ps.executeUpdate();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
if(connection != null) {
try {
connection.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(ps != null) {
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
4.2针对查询操作
@Test
public void test3(){
Connection connection = null;
PreparedStatement ps = null;
try {
InputStream resourceAsStream = ConnectionTest.class.getClassLoader().getResourceAsStream("jdbc.properties");
Properties properties = new Properties();
properties.load(resourceAsStream);
String username = properties.getProperty("user");
String password = properties.getProperty("password");
String url = properties.getProperty("url");
String driver = properties.getProperty("driverClass");
// 1.注册驱动
Class.forName(driver);
// 2.获取连接
connection = DriverManager.getConnection(url, username,password);
// 3.SQL语句
String sql = "select * from customers";// ？是占位符
ps = connection.prepareStatement(sql);
// 4.执行语句
ResultSet resultSet = ps.executeQuery();
ArrayList<User> list = new ArrayList<User>();
while(resultSet.next()) {
User user = new User();
user.setId(resultSet.getInt("id"));
user.setName(resultSet.getString("name"));
user.setEmail(resultSet.getString("email"));
user.setBirth(resultSet.getDate("birth"));
user.setPhoto(resultSet.getBlob("photo"));
list.add(user);
}
list.forEach(System.out::println);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
if(connection != null) {
try {
connection.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(ps != null) {
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
5.工具类封装
public class JDBCUtil {
private static Connection getConnection() throws Exception {
InputStream inputStream = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
Properties properties = new Properties();
properties.load(inputStream);
String username = properties.getProperty("user");
String password = properties.getProperty("password");
String url = properties.getProperty("url");
String driver = properties.getProperty("driverClass");
// 1.注册驱动
Class.forName(driver);
// 2.获取连接
Connection connection = DriverManager.getConnection(url, username,password);
return connection;
}
private static void close(Connection conn, PreparedStatement ps, ResultSet rs) throws Exception{
if(conn != null) {
conn.close();
}
if(ps != null) {
ps.close();
}
if(rs != null) {
rs.close();
}
}
/** * 增删改通用 * @return * @throws Exception */
public static int update(String sql, Object ...args) {
int executeUpdate = 0;
Connection connection = null;
PreparedStatement prepareStatement = null;
try {
connection = getConnection();
prepareStatement = connection.prepareStatement(sql);
for(int i = 0; i< args.length; i ++) {
prepareStatement.setObject(i+1, args[i]);
}
executeUpdate = prepareStatement.executeUpdate();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
close(connection,prepareStatement,null);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return executeUpdate;
}
public static <T> List<T> query(String sql,Class clazz,Object ...args){
List<T> list = null;
Connection connection = null;
PreparedStatement prepareStatement = null;
ResultSet executeQuery = null;
try {
connection = getConnection();
prepareStatement = connection.prepareStatement(sql);
for(int i = 0; i< args.length; i ++) {
prepareStatement.setObject(i+1, args[i]);
}
executeQuery = prepareStatement.executeQuery();
ResultSetMetaData metaData = executeQuery.getMetaData();
int columnCount = metaData.getColumnCount();
list = new ArrayList<T>();
while(executeQuery.next()) {
T t = (T) clazz.newInstance();
for(int i = 0; i < columnCount; i++) {
String key = metaData.getColumnLabel(i+1);
Object value = executeQuery.getObject(i+1);
Field field = clazz.getDeclaredField(key);
field.setAccessible(true);
field.set(t, value);
}
list.add(t);
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
try {
close(connection,prepareStatement,executeQuery);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return list;
}
}
6.数据库事务
事务：一组SQL语句是一个整体，要么都执行，要么都不执行。
考虑事务后的代码实现：
执行sql语句之前把mysql的默认提交功能关闭，在执行多个sql语句中间不能关闭连接，中间出现异常得回滚sql
public class TranslationTest {
@Test
public void test1() {
Connection connection = null;
try {
connection = JDBCUtil.getConnection();
// 1.关闭自动提交
connection.setAutoCommit(false);
String sql1 = "update user_table set balance = balance - 100 where user = ?";
update(connection,sql1,"AA");
int i = 5 / 0;
String sql2 = "update user_table set balance = balance + 100 where user = ?";
update(connection,sql2,"BB");
connection.commit();
System.out.println("success");
} catch (Exception e) {
// TODO Auto-generated catch block
// 回滚
try {
connection.rollback();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
e.printStackTrace();
}finally {
try {
// 关闭连接
JDBCUtil.close(connection, null, null);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
/** * 增删改通用 * @return * @throws Exception */
public int update(Connection connection,String sql, Object ...args) throws Exception{
int executeUpdate = 0;
PreparedStatement prepareStatement = null;
prepareStatement = connection.prepareStatement(sql);
for(int i = 0; i< args.length; i ++) {
prepareStatement.setObject(i+1, args[i]);
}
executeUpdate = prepareStatement.executeUpdate();
JDBCUtil.close(null,prepareStatement,null);
return executeUpdate;
}
}
ent prepareStatement = null;
prepareStatement = connection.prepareStatement(sql);
for(int i = 0; i< args.length; i ++) {
prepareStatement.setObject(i+1, args[i]);
}
executeUpdate = prepareStatement.executeUpdate();
JDBCUtil.close(null,prepareStatement,null);
return executeUpdate;
}
}
边栏推荐
猜你喜欢
PDF文件转换格式
从事功能测试1年，裸辞1个月，找不到工作的“我”怎么办？
吴恩达机器学习系列课程笔记——第六章：逻辑回归(Logistic Regression)
1318_将ST link刷成jlink
深蓝学院-视觉SLAM十四讲-第七章作业
CaDDN code debugging
科研笔记(八) 深度学习及其在 WiFi 人体感知中的应用(上)
Research Notes (8) Deep Learning and Its Application in WiFi Human Perception (Part 2)
深蓝学院-视觉SLAM十四讲-第六章作业
3D object detection dataset
随机推荐
线代005
吴恩达机器学习系列课程笔记——第十四章：降维(Dimensionality Reduction)
使用GD32F207的高级定时器来产生PWM波出现的隐藏BUG
Research Notes (8) Deep Learning and Its Application in WiFi Human Perception (Part 1)
被大厂强制毕业，两个月空窗期死背八股文，幸好上岸，不然房贷都还不上了
batch_size of deep learning foundation
自定义一个下划线分词器
[Win11] PowerShell cannot activate Conda virtual environment
CaDDN paper reading of monocular 3D target detection
轮询和长轮询的区别
ADSP21489数据手册表摘要
深蓝学院-视觉SLAM十四讲-第四章作业
Scientific research notes (5) SLAC WiFi Fingerprint+ Step counter fusion positioning
批量--09---批量读文件入表
Arduino框架下STM32F1/F4系列HID模式程序烧录教程
ESP32-C5 简介：乐鑫首款双频 Wi-Fi 6 MCU
开放原子开源峰会落幕，百度超级链牵头成立XuperCore开源工作组
【FreeRTOS】12 任务通知——更省资源的同步方式
吴恩达机器学习系列课程笔记——第六章：逻辑回归(Logistic Regression)
吴恩达机器学习系列课程笔记——第十八章：应用实例：图片文字识别(Application Example: Photo OCR)