JDBC-自定义数据库工具类（DBService）

public class Driver extends NonRegisteringDriver implements java.sql.Driver {
  // ~ Static fields/initializers
  // ---------------------------------------------

  //
  // Register ourselves with the DriverManager
  //
  static {
     try {
        java.sql.DriverManager. registerDriver( new Driver());
    } catch (SQLException E) {
         throw new RuntimeException( "Can't register driver!" );
    }
 }

 // 注册驱动：告诉 java去连接哪种数据库
//DriverManager.registerDriver(new com.mysql.jdbc.Driver());
 new com.mysql.jdbc.Driver();

 // 注册驱动：告诉 java 去连接哪种数据库
 //DriverManager.registerDriver(new com.mysql.jdbc.Driver());
 //new com.mysql.jdbc.Driver();
Class. forName( "com.mysql.jdbc.Driver");

url = "jdbc:mysql://localhost:3306/****"

url = jdbc:mysql://localhost:3306/****?userUnicode=true&characterEncoding=utf8?userUnicode=true&characterEncoding=utf8
//加上这个可以解决数据库的乱码问题

// 创建语句对象Statement
 Statement stmt = con.createStatement();

//创建预设语句对象PreparedStatement
String sql = "update class set classDesc = ? where id = ?";
 PreparedStatement pstmt = con.prepareStatement(sql);

select * from user where username='zhangsan' and password = '123456';

select * from user where username='zhangsan' and password = '' or '1'='1'

<? xml version ="1.0" encoding= "UTF-8" ?>
< c3p0-config>
         <!-- 默认配置，c3p0框架默认加载这段默认配置 -->
         < default-config>
              <!-- 配置JDBC 四个基本属性 -->
              < property name ="driverClass" > com.mysql.jdbc.Driver</ property >
               < property name ="jdbcUrl" > jdbc:mysql:///数据库名</ property >
               < property name ="user" > 数据库用户名</ property >
               < property name ="password" > 数据库密码</ property >
        </ default-config> <!-- This app is massive! -->
</ c3p0-config>

 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.ResultSetMetaData;
 import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
  
 import org.junit.Test;
  
 import com.mchange.v2.c3p0.ComboPooledDataSource;
 import com.mchange.v2.c3p0.util.TestUtils;
  
 public class DBService {
  
     // 三剑客
     Connection con = null;// 连接对象
     PreparedStatement pstmt = null;// 语句对象
     ResultSet rs = null;// 结果集对象
  
     /**
      * 获得连接对象
      *
      * @return 连接对象
      * @throws ClassNotFoundException
      * @throws SQLException
      */
     public Connection getConnection() throws ClassNotFoundException,
             SQLException {
  
         // 创建c3p0连接池
         ComboPooledDataSource ds = new ComboPooledDataSource("itcast");
         // 通过连接池对象创建连接
         con = ds.getConnection();
         return con;
     }
  
     /**
      * 关闭三剑客
      *
      * @throws SQLException
      */
     public void close(ResultSet rs, PreparedStatement pstmt, Connection con) {
  
         try {
             if (rs != null)
                 rs.close();
             if (pstmt != null)
                 pstmt.close();
             if (con != null)
                 con.close();
         } catch (SQLException e) {
             // TODO: handle exception
             e.printStackTrace();
         }
     }
  
     /**
      * 执行更新
      *
      * @param sql
      *            传入的预设的sql语句
      * @param params
      *            问号参数列表
      * @return 影响行数
      */
     public int execUpdate(String sql, Object[] params) {
         try {
             this.getConnection();// 获得连接对象
             this.pstmt = this.con.prepareStatement(sql);// 获得预设语句对象
  
             if (params != null) {
                 // 设置参数列表
                 for (int i = 0; i < params.length; i++) {
                     // 因为问号参数的索引是从1开始，所以是i+1，将所有值都转为字符串形式，好让setObject成功运行
                     this.pstmt.setObject(i + 1, params[i] + "");
                 }
             }
  
             return this.pstmt.executeUpdate();// 执行更新，并返回影响行数
  
         } catch (ClassNotFoundException | SQLException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         } finally {
             this.close(this.rs, this.pstmt, this.con);
         }
         return 0;
     }
  
     /**
      * 执行查询
      *
      * @param sql
      *            传入的预设的sql语句
      * @param params
      *            问号参数列表
      * @return 查询后的结果
      */
     public List<Map<String, Object>> execQuery(String sql, Object[] params) {
  
         try {
             this.getConnection();// 获得连接对象
             this.pstmt = this.con.prepareStatement(sql);// 获得预设语句对象
  
             if (params != null) {
                 // 设置参数列表
                 for (int i = 0; i < params.length; i++) {
                     // 因为问号参数的索引是从1开始，所以是i+1，将所有值都转为字符串形式，好让setObject成功运行
                     this.pstmt.setObject(i + 1, params[i] + "");
                 }
             }
  
             // 执行查询
             ResultSet rs = pstmt.executeQuery();
  
             List<Map<String, Object>> al = new ArrayList<Map<String, Object>>();
  
             // 获得结果集元数据（元数据就是描述数据的数据，比如把表的列类型列名等作为数据）
             ResultSetMetaData rsmd = rs.getMetaData();
  
             // 获得列的总数
             int columnCount = rsmd.getColumnCount();
  
             // 遍历结果集
             while (rs.next()) {
                 Map<String, Object> hm = new HashMap<String, Object>();
                 for (int i = 0; i < columnCount; i++) {
                     // 根据列索引取得每一列的列名,索引从1开始
                     String columnName = rsmd.getColumnName(i + 1);
                     // 根据列名获得列值
                     Object columnValue = rs.getObject(columnName);
                     // 将列名作为key，列值作为值，放入hm中，每个hm相当于一条记录
                     hm.put(columnName, columnValue);
                 }
                 // 将每个hm添加到al中,al相当于是整个表，每个hm是里面的一条记录
                 al.add(hm);
             }
  
             return al;
  
         } catch (ClassNotFoundException | SQLException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         } finally {
             this.close(this.rs, this.pstmt, this.con);
         }
  
         return null;
     }
  
 }