溫馨提示×
您好，登錄后才能下訂單哦！
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》
您好，登錄后才能下訂單哦！
小編給大家分享一下java中如何實(shí)現(xiàn)JDBC增刪改查操作，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！
我們先看一遍步驟：
這里不推薦使用Statement，兩個原因：
1.存在拼串操作，繁瑣。
2.存在sql注入問題。
那我們使用誰來代替Statement呢？
操作前，我們先解決上面的問題，我們使用PreparedStatement來代替Statement。
可以通過調(diào)用 Connection 對象的 preparedStatement(String sql) 方法獲取 PreparedStatement 對象
PreparedStatement 接口是 Statement 的子接口，它表示一條預(yù)編譯過的 SQL 語句
PreparedStatement 對象所代表的 SQL 語句中的參數(shù)用問號(?)來表示，調(diào)用 PreparedStatement 對象的 setXxx() 方法來設(shè)置這些參數(shù). setXxx() 方法有兩個參數(shù)，第一個參數(shù)是要設(shè)置的 SQL 語句中的參數(shù)的索引(從 1 開始)，第二個是設(shè)置的 SQL 語句中的參數(shù)的值
優(yōu)點(diǎn)：
解決字符串拼串問題，防止sql注入提高性能
這里給出一個針對不同表的通用增刪改操作，拿著直接用就可以了。
//通用增刪改操作
public boolean updateInfo(String sql,Object...args){
Connection conn = null;
PreparedStatement ps = null;
boolean b = true;
try {
//1.建立連接
conn = JDBCUtils.getConnection();
//2.預(yù)編譯sql語句
ps = conn.prepareStatement(sql);
//3.填充占位符
for (int i = 0; i <args.length ; i++) {
ps.setObject(i+1,args[i]);
}
//4.執(zhí)行操作
b = ps.execute();
} catch (Exception e) {
e.printStackTrace();
} finally {
//5.關(guān)閉資源
JDBCUtils.close(conn,ps);
}
return b;
}是不是復(fù)制使用會報錯，這是因?yàn)椴┲靼褦?shù)據(jù)庫連接和關(guān)閉資源也封裝成了一個類JDBCUtils。
下面給出這個類的具體代碼：
配置文件就自己寫吧，畢竟每個人的數(shù)據(jù)庫都不一樣。以及該導(dǎo)入的包自己動動手就行了。
public class JDBCUtils {
//連接
public static Connection getConnection(){
Connection conn = null;
try {
//1.加載配置文件
InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
Properties prop = new Properties();
prop.load(is);
//2.讀取配置文件
String user = prop.getProperty("user");
String password = prop.getProperty("password");
String url = prop.getProperty("url");
String driverClass = prop.getProperty("driverClass");
//3.加載驅(qū)動
Class.forName(driverClass);
//4.建立連接
conn = DriverManager.getConnection(url, user, password);
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
//關(guān)閉
public static void close(Connection conn, PreparedStatement ps){
try {
if (conn != null){
conn.close();
}
if (ps != null){
ps.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
//關(guān)閉帶resultset
public static void close(Connection conn, PreparedStatement ps , ResultSet rs){
try {
if (conn != null){
conn.close();
}
if (ps != null){
ps.close();
}
if (rs != null){
rs.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}我們來測試一下上面的代碼
這里有一張order表，里面有初始數(shù)據(jù)：
然后我們通過上面提供的方法給他增加一條數(shù)據(jù)：
public class Test {
public static void main(String[] args) {
Operation operation = new Operation();
String insertSql = "INSERT INTO `order`(order_id,order_name,order_date) VALUES (?,?,?)";
boolean b = operation.updateInfo(insertSql, 3, "CC", new Date(12312132));
if (!b){
System.out.println("操作成功！");
}else {
System.out.println("操作失??！");
}
}
}控制臺打印輸出：
那么是不是已經(jīng)插入成功了呢，我們?nèi)?shù)據(jù)庫中看一下：
我們 SELECT * FROM `order`;
看來我們確實(shí)成功了！所以我們給出的方法還是沒有問題。
接下來我們就是查操作了。
public <T> T doQuery(Class<T> clazz,String sql,Object...args) {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
//1.建立連接
conn = JDBCUtils.getConnection();
//2.預(yù)編譯sql語句
ps = conn.prepareStatement(sql);
//3.填充占位符
for (int i = 0; i <args.length ; i++) {
ps.setObject(i+1,args[i]);
}
//4.得到結(jié)果集ResultSet
rs = ps.executeQuery();
//5.得到結(jié)果集元數(shù)據(jù)
ResultSetMetaData rsdm = rs.getMetaData();
//6.通過rs得到列值，rsdm得到列名和列數(shù)
//得到列數(shù)
int columnCount = rsdm.getColumnCount();
if (rs.next()){
T t = clazz.getDeclaredConstructor().newInstance();
for (int i = 0; i <columnCount ; i++) {
//得到列值
Object columnvalue = rs.getObject(i + 1);
//得到列的別名
String columnLabel = rsdm.getColumnLabel(i + 1);
//通過反射給對象賦值
Field field = clazz.getDeclaredField(columnLabel);
//暴力反射
field.setAccessible(true);
field.set(t,columnvalue);
}
return t;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
//關(guān)閉資源
JDBCUtils.close(conn,ps,rs);
}
return null;
}老樣子，測試！
public class Test {
public static void main(String[] args) {
Operation operation = new Operation();
String sql = "SELECT order_id orderId,order_name orderName,order_date orderDate FROM `order` WHERE order_id = ?;";
Order order = operation.doQuery(Order.class, sql, 2);
System.out.println(order);
}
}控制臺輸出：
public <T> List doQueryMore(Class<T> clazz,String sql,Object...args){
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
//1.建立連接
conn = JDBCUtils.getConnection();
//2.預(yù)編譯sql語句
ps = conn.prepareStatement(sql);
//3.填充占位符
for (int i = 0; i <args.length ; i++) {
ps.setObject(i+1,args[i]);
}
//4.得到結(jié)果集ResultSet
rs = ps.executeQuery();
//5.得到結(jié)果集元數(shù)據(jù)
ResultSetMetaData rsdm = rs.getMetaData();
//6.通過rs得到列值，rsdm得到列名和列數(shù)
//得到列數(shù)
int columnCount = rsdm.getColumnCount();
//創(chuàng)建集合
ArrayList<T> list = new ArrayList<>();
while (rs.next()){
T t = clazz.getDeclaredConstructor().newInstance();
for (int i = 0; i <columnCount ; i++) {
//得到列值
Object columnvalue = rs.getObject(i + 1);
//得到列的別名
String columnLabel = rsdm.getColumnLabel(i + 1);
//通過反射給對象賦值
Field field = clazz.getDeclaredField(columnLabel);
//暴力反射
field.setAccessible(true);
field.set(t,columnvalue);
}
list.add(t);
}
return list;
} catch (Exception e) {
e.printStackTrace();
} finally {
//關(guān)閉資源
JDBCUtils.close(conn,ps,rs);
}
return null;
}看完了這篇文章，相信你對“java中如何實(shí)現(xiàn)JDBC增刪改查操作”有了一定的了解，如果想了解更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！
免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。
億速云公眾號
手機(jī)網(wǎng)站二維碼