轉載:C博客:獨孤熊
1 package com.upc.dao; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.SQLException; 7 import java.sql.Statement; 8 9 public class BaseDao { 10 //JDBC連接數據庫:純java驅動方式 11 //Statement對象,用來向數據庫發送查詢和命令,它由Connection的createStatement方法創建 12 //Statement里面帶有很多方法,比如executeUpdate可以實現插入,更新和刪除等 13 14 15 private static final String DataBaseName="數據庫名稱"; 16 private static final String DRIVER="com.mysql.jdbc.Driver"; 17 // URL編寫方式:jdbc:mysql://主機名稱:連接端口/數據庫的名稱?參數=值 18 private static final String URL = "jdbc:mysql://localhost:3306/DataBaseName?"; 19 private static final String USERNAME="root"; 20 private static final String PASSWORD="123456"; 21 22 23 //連接數據庫 24 public Connection getConn()throws ClassNotFoundException,SQLException{ 25 Class.forName(DRIVER); //動態加載mysql驅動 26 Connection conn = DriverManager.getConnection(URL,USERNAME,PASSWORD); //建立數據庫鏈接 27 return conn; //返回數據庫連接對象 28 } 29 30 //釋放資源 31 public void closeAll(Connection conn,Statement stmt,ResultSet rs)throws SQLException{ 32 if(rs!=null){ 33 rs.close(); 34 } 35 if(stmt!=null){ 36 stmt.close(); 37 } 38 if(conn!=null){ 39 conn.close(); 40 } 41 } 42 43 //執行SQL語句,可以進行增、刪、改的操作 44 //return 影響條數 45 public int executeSQL(String sql)throws ClassNotFoundException,SQLException{ 46 Connection conn = this.getConn(); 47 Statement stmt = conn.createStatement(); 48 //對於 CREATE TABLE 或 DROP TABLE 等不操作行的語句,executeUpdate 的返回值總為零 49 int number = stmt.executeUpdate(sql); 50 this.closeAll(conn, stmt, null); 51 return number; 52 } 53 }
