转载: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 }