淺析JDBC的使用方法
1.使用步驟:
導包 加載驅動類class.forName(....) DriverManager獲取sql對象 寫sql語句 Statement與prepareStatement不一樣的執行sql語句,前者是直接sql對象 . 執行語句,而后者是預處理,即在創建sql對象時,就用sql語句,最后在用對象執行操作。2.JDBCUtils工具類:
就是把使用步驟的共性,提出來,放在一個類中,這樣以后就能直接調用創建sql對象的方法就行了。
值得一提的是,如果我們使用配置文件,擴展性更好,在使用其他數據庫時,我們只需要更改配置文件properties。獲取配置文件可以使用properties對象。獲取jar包的絕對路徑可以使用classLoader類加載器。這樣我們就不用自己添加路徑了。
public class JDBCUtils { private static String url; private static String user; private static String password; private static String driver; /** * 文件的讀取,只需要讀取一次即可拿到這些值。使用靜態代碼塊 */ static{ //讀取資源文件,獲取值。 try { //1. 創建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. 獲取數據,賦值 url = pro.getProperty('url'); user = pro.getProperty('user'); password = pro.getProperty('password'); driver = pro.getProperty('driver'); //4. 注冊驅動 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控制事務:
在執行sql語句時,如果程序執行過程中,發生了異常。比如有兩個sql語句,一個是轉賬操作,一個人存轉的這筆錢,如果第一個操作結束后發生了異常。那么這筆錢就會不翼而飛,所以為了避免這樣的情況,可以使用事務。
具體操作
開啟事務:setAutoCommit( boolean autoCommit ) :調用該方法設置參數為false,即開啟事務。 提交事務:commit( )當所有sql都執行完提交事務。 回滾事務:rollback( ) 在catch中回滾事務。public static void main(String[] args) { PreparedStatement pstmt1 = null; PreparedStatement pstmt2 = null; Connection con = null; try { con = JDBCUtils.getConnection(); //開啟事務 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. 設置參數,sql語句里的問號 pstmt1.setDouble(1,500);//填第一個數據 pstmt1.setInt(2,1);//填第二個數據 pstmt2.setDouble(1,500); pstmt2.setInt(2,2); //5.執行sql pstmt1.executeUpdate(); // 手動制造異常 int i = 3/0; pstmt2.executeUpdate(); //提交事務 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連接池
連接池,就是先創建好一些連接對象,要用的的時候,直接使用,提高了效率,用完之后,歸還給連接池,以便其他的使用。
c3p0連接池:
1.步驟:
導入jar包 (兩個) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar ,還需要導入數據庫驅動jar包
2.定義配置文件:
名稱: c3p0.properties 或者 c3p0-config.xml。路徑:直接將文件放在src目錄下即可。
3.創建核心對象 數據庫連接池對象 ComboPooledDataSource
4.獲取連接: getConnection
代碼:
//1.創建數據庫連接池對象 DataSource ds = new ComboPooledDataSource(); //2. 獲取連接對象 Connection conn = ds.getConnection();
druid:
這個是阿里的,性能更好,效率更高。
1.步驟:
導入jar包 druid-1.0.9.jar
2.定義配置文件:
是properties形式的可以叫任意名稱,可以放在任意目錄下
3.加載配置文件。Properties
4.獲取數據庫連接池對象:通過工廠類來獲取 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();
由于代碼還是冗長,重復率高,所以可以自定義個工具類:
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的開發
1.步驟:
導入jar包創建JdbcTemplate對象。依賴于數據源DataSource
JdbcTemplate template = new JdbcTemplate(ds);
2.調用JdbcTemplate的方法來完成CRUD的操作
update():執行DML語句。增、刪、改語句queryForMap():查詢結果將結果集封裝為map集合,將列名作為key,將值作為value 將這條記錄封裝為一個map集合
注意:這個方法查詢的結果集長度只能是1queryForList():查詢結果將結果集封裝為list集合
注意:將每一條記錄封裝為一個Map集合,再將Map集合裝載到List集合中query():查詢結果,將結果封裝為JavaBean對象
query的參數:RowMapper
一般我們使用BeanPropertyRowMapper實現類。可以完成數據到JavaBean的自動封裝new BeanPropertyRowMapper<類型>(類型.class)queryForObject:查詢結果,將結果封裝為對象
一般用于聚合函數的查詢
//2. 定義sql //1. 獲取JDBCTemplate對象private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());String sql = 'update emp set salary = 10000 where id = 1001';//3. 執行sqlint count = template.update(sql);System.out.println(count);
這大大簡化了我們curd的代碼量。
以上就是淺析JDBC的使用方法的詳細內容,更多關于Java jdbc使用的資料請關注好吧啦網其它相關文章!
相關文章:
