淺析JDBC的使用方法

更新時間：2020年08月27日 09:29:54 作者：陳全蛋

這篇文章主要介紹了JDBC的使用方法，幫助大家更好的理解和學(xué)習(xí)Java，感興趣的朋友可以了解下

1.使用步驟：

導(dǎo)包
加載驅(qū)動類class.forName(....)
DriverManager獲取sql對象
寫sql語句
Statement與prepareStatement不一樣的執(zhí)行sql語句，前者是直接sql對象 . 執(zhí)行語句，而后者是預(yù)處理，即在創(chuàng)建sql對象時，就用sql語句，最后在用對象執(zhí)行操作。

2.JDBCUtils工具類：

就是把使用步驟的共性，提出來，放在一個類中，這樣以后就能直接調(diào)用創(chuàng)建sql對象的方法就行了。

值得一提的是，如果我們使用配置文件，擴展性更好，在使用其他數(shù)據(jù)庫時，我們只需要更改配置文件properties。獲取配置文件可以使用properties對象。獲取jar包的絕對路徑可以使用classLoader類加載器。這樣我們就不用自己添加路徑了。

public class JDBCUtils {
 private static String url;
 private static String user;
 private static String password;
 private static String driver;
 /**
  * 文件的讀取，只需要讀取一次即可拿到這些值。使用靜態(tài)代碼塊
  */
 static{
  //讀取資源文件，獲取值。
 
  try {
  //1. 創(chuàng)建Properties集合類。
  Properties pro = new Properties();
 
  //獲取src路徑下的文件的方式--->ClassLoader 類加載器
  ClassLoader classLoader = JDBCUtils.class.getClassLoader();
  URL res = classLoader.getResource("jdbc.properties");
  String path = res.getPath();
  
  //2. 加載文件
  pro.load(new FileReader(path));
 
  //3. 獲取數(shù)據(jù)，賦值
  url = pro.getProperty("url");
  user = pro.getProperty("user");
  password = pro.getProperty("password");
  driver = pro.getProperty("driver");
  //4. 注冊驅(qū)動
  Class.forName(driver);
  } catch (IOException e) {
  e.printStackTrace();
  } catch (ClassNotFoundException e) {
  e.printStackTrace();
  }
 }
 
 
 /**
  * 獲取連接
  * @return 連接對象
  */
 public static Connection getConnection() throws SQLException {
 
  return DriverManager.getConnection(url, user, password);
 }
 
 /**
  * 釋放資源
  * @param stmt
  * @param conn
  */
 public static void close(Statement stmt,Connection conn){
  if( stmt != null){
  try {
   stmt.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }
  }
 
  if( conn != null){
  try {
   conn.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }
  }
 }
 
 
 /**
  * 釋放資源
  * @param stmt
  * @param conn
  */
 public static void close(ResultSet rs,Statement stmt, Connection conn){
  if( rs != null){
  try {
   rs.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }
  }
 
  if( stmt != null){
  try {
   stmt.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }
  }
 
  if( conn != null){
  try {
   conn.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }
  }
 }
 
 }

3.DBC控制事務(wù)：

在執(zhí)行sql語句時，如果程序執(zhí)行過程中，發(fā)生了異常。比如有兩個sql語句，一個是轉(zhuǎn)賬操作，一個人存轉(zhuǎn)的這筆錢，如果第一個操作結(jié)束后發(fā)生了異常。那么這筆錢就會不翼而飛，所以為了避免這樣的情況，可以使用事務(wù)。

具體操作

開啟事務(wù)：setAutoCommit( boolean autoCommit ) ：調(diào)用該方法設(shè)置參數(shù)為false，即開啟事務(wù)。
提交事務(wù)：commit( )當(dāng)所有sql都執(zhí)行完提交事務(wù)。
回滾事務(wù)：rollback( ) 在catch中回滾事務(wù)。

public static void main(String[] args) {
 PreparedStatement pstmt1 = null;
 PreparedStatement pstmt2 = null;
 Connection con = null;


 try {
 con = JDBCUtils.getConnection();
 //開啟事務(wù)
 con.setAutoCommit(false);
 //2.1 張三 - 500
 String sql1 = "update account set balance = balance - ? where id = ?";
 //2.2 李四 + 500
 String sql2 = "update account set balance = balance + ? where id = ?";


 pstmt1 = con.prepareStatement(sql1);
 pstmt2 = con.prepareStatement(sql2);


 //4. 設(shè)置參數(shù),sql語句里的問號
 pstmt1.setDouble(1,500);//填第一個數(shù)據(jù)
 pstmt1.setInt(2,1);//填第二個數(shù)據(jù)


 pstmt2.setDouble(1,500);
 pstmt2.setInt(2,2);
 //5.執(zhí)行sql
 pstmt1.executeUpdate();
 // 手動制造異常
 int i = 3/0;


 pstmt2.executeUpdate();
 //提交事務(wù)
 con.commit();
 } catch (SQLException e) {
 e.printStackTrace();
 } catch (Exception e){
 try {
  con.rollback();
 } catch (SQLException ex) {
  ex.printStackTrace();
 }
 } finally{
 JDBCUtils.close(con,pstmt1);
 JDBCUtils.close(con,pstmt2);
 }
}

4.JDBC連接池

連接池，就是先創(chuàng)建好一些連接對象，要用的的時候，直接使用，提高了效率，用完之后，歸還給連接池，以便其他的使用。

c3p0連接池：

1.步驟：

導(dǎo)入jar包 (兩個) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar ，還需要導(dǎo)入數(shù)據(jù)庫驅(qū)動jar包

2.定義配置文件：

名稱： c3p0.properties 或者 c3p0-config.xml。
路徑：直接將文件放在src目錄下即可。

3.創(chuàng)建核心對象數(shù)據(jù)庫連接池對象 ComboPooledDataSource

4.獲取連接： getConnection

代碼：

//1.創(chuàng)建數(shù)據(jù)庫連接池對象
 DataSource ds = new ComboPooledDataSource();
 //2. 獲取連接對象
 Connection conn = ds.getConnection();

druid：

這個是阿里的，性能更好，效率更高。

1.步驟：

導(dǎo)入jar包 druid-1.0.9.jar

2.定義配置文件：

是properties形式的
可以叫任意名稱，可以放在任意目錄下

3.加載配置文件。Properties

4.獲取數(shù)據(jù)庫連接池對象：通過工廠類來獲取 DruidDataSourceFactory

5.獲取連接：getConnection

//3.加載配置文件
Properties pro = new Properties();
InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(is);
//4.獲取連接池對象
DataSource ds = DruidDataSourceFactory.createDataSource(pro);
//5.獲取連接
Connection conn = ds.getConnection();

由于代碼還是冗長，重復(fù)率高，所以可以自定義個工具類：

public class JDBCUtils {

    //1.定義成員變量 DataSource
    private static DataSource ds ;
   
    static{
     try {
      //1.加載配置文件
      Properties pro = new Properties();
      pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
      //2.獲取DataSource
      ds = DruidDataSourceFactory.createDataSource(pro);
     } catch (IOException e) {
      e.printStackTrace();
     } catch (Exception e) {
      e.printStackTrace();
     }
    }
   
    /**
     * 獲取連接
     */
    public static Connection getConnection() throws SQLException {
     return ds.getConnection();
    }

Spring JDBC

Spring框架對JDBC的簡單封裝。提供了一個JDBCTemplate對象簡化JDBC的開發(fā)

1.步驟：

導(dǎo)入jar包
創(chuàng)建JdbcTemplate對象。依賴于數(shù)據(jù)源DataSource

JdbcTemplate template = new JdbcTemplate(ds);

2.調(diào)用JdbcTemplate的方法來完成CRUD的操作

update():執(zhí)行DML語句。增、刪、改語句
queryForMap():查詢結(jié)果將結(jié)果集封裝為map集合，將列名作為key，將值作為value 將這條記錄封裝為一個map集合

注意：這個方法查詢的結(jié)果集長度只能是1
queryForList():查詢結(jié)果將結(jié)果集封裝為list集合

注意：將每一條記錄封裝為一個Map集合，再將Map集合裝載到List集合中
query():查詢結(jié)果，將結(jié)果封裝為JavaBean對象

query的參數(shù)：RowMapper

一般我們使用BeanPropertyRowMapper實現(xiàn)類?？梢酝瓿蓴?shù)據(jù)到JavaBean的自動封裝
new BeanPropertyRowMapper<類型>(類型.class)
queryForObject：查詢結(jié)果，將結(jié)果封裝為對象

一般用于聚合函數(shù)的查詢

//2. 定義sql
 
//1. 獲取JDBCTemplate對象
private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
String sql = "update emp set salary = 10000 where id = 1001";
//3. 執(zhí)行sql
int count = template.update(sql);
System.out.println(count);

這大大簡化了我們curd的代碼量。

以上就是淺析JDBC的使用方法的詳細(xì)內(nèi)容，更多關(guān)于Java jdbc使用的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: