JDBC连接数据库(Mysql):纯java驱动连接

时间:2021-05-31 13:06:46

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