package com.obtk.util;import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;/*** 數(shù)據(jù)層共用類* * @author pengfei.xiong* */ public class BaseDao {public Connection conn = null;public PreparedStatement pstmt = null;public ResultSet rs = null;/*** 獲得連對象* 下面中文部分自行修改,其他代碼都可以用* @return 返回連接對象*/public Connection getConnection() {try {Class.forName("驅(qū)動(dòng)名稱");conn = DriverManager.getConnection("數(shù)據(jù)庫url", "用戶名", "密碼");} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}return conn;}/*** 關(guān)閉所有對象* * @param rs* 結(jié)果集* @param pstmt* 執(zhí)行* @param conn* 連接*/public void closeAll(ResultSet rs, Statement pstmt, Connection conn) {try {if (rs != null) {rs.close();}if (pstmt != null) {pstmt.close();}if (conn != null) {conn.close();}} catch (SQLException e) {e.printStackTrace();}}/*** 執(zhí)行增刪改操作* * @param sql* 執(zhí)行語句* @param obj* 參數(shù)數(shù)組* @return 返回受影響的行數(shù)*/public int executeUpdateSQL(String sql, Object[] obj) {int row = 0;try {conn = getConnection();pstmt = conn.prepareStatement(sql);if (obj != null) {for (int i = 0; i < obj.length; i++) {pstmt.setObject(i + 1, obj[i]);}}row = pstmt.executeUpdate();} catch (Exception e) {e.printStackTrace();} finally {closeAll(rs, pstmt, conn);}return row;}/*** 執(zhí)行查詢操作* * @param sql* 查詢語句* @param obj* 參數(shù)列表* @return 返回對象的結(jié)果集*/public ResultSet executeQuerySQL(String sql, Object[] obj) {conn = getConnection();try {pstmt = conn.prepareStatement(sql);if (obj != null) {for (int i = 0; i < obj.length; i++) {pstmt.setObject(i + 1, obj[i]);}}rs = pstmt.executeQuery();} catch (SQLException e) {e.printStackTrace();}return rs;} }

轉(zhuǎn)載于:https://www.cnblogs.com/xpf1009/p/9227325.html

總結(jié)

以上是生活随笔為你收集整理的JDBC初学者的basedao工具类的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。