当前位置：网站首页>JDBC revisited
JDBC revisited
2022-08-02 06:04:00 【so sleepy tomato】
文章目录
1.JDBC程序的编写步骤
- 加载并注册驱动（Different databases have different drivers（Equivalent to a class implemented by each database vendor））
- 创建Connection连接对象（连接数据库）
- 创建Statement或者PreparedStatement对象
- 执行SQL语句
- 使用ResultSet收集对象、关闭ResultSet对象（If it is an addition, deletion or modification, it is not necessary）
- 关闭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.The overall complete process
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语句是一个整体,要么都执行,要么都不执行.
Consider the code implementation after the transaction：
执行sqlput before the statementmysqlThe default commit feature is turned off,在执行多个sqlA connection cannot be closed in the middle of a statement,If an exception occurs in the middle, it must be rolled backsql
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;
}
}
边栏推荐
猜你喜欢
随机推荐
递归实现组合型枚举(DAY 92)
matlab simulink 模糊pid结合smith控制温度
Android Studio 实现登录注册-源代码 （连接MySql数据库）
UE4 局域网联机案例
CodeTON Round 2 (Div. 1 + Div. 2, Rated, Prizes!)
JDBC再回顾
2022 Huawei Software Elite Challenge (Preliminary) - Summary
软件测试常见的问题
The line chart with square PyQt5_pyqtgraph mouse
mysql 存储过程详解
系统(层次)聚类
ORA-04044:此处不允许过程、函数、程序包或类型，系统分析与解决
ES6——class类实现继承
MySql字符串拆分实现split功能（字段分割转列、转行）
从头开始实现YOLOV3
牛客-TOP101-BM41
关于地图GIS开发事项的一次实践整理（上）
2022河南萌新联赛第（四）场：郑州轻工业大学 A - ZZULI
【七夕】是时候展现专属于程序员的“浪漫”了
UE4 3DUI显示与交互案例