Dao模式是Java面向设计时的一种模式。而Dao中的BaseDao无非是对数据进行CURD（增删改查），下面是最常用的连接，增删改查的方法。 

1 package dao;  2   3 import java.sql.*;  4   5 /**  6  * 数据库访问类  7  */  8 public class BaseDao {  9     //数据库驱动 10     private static String driver = "com.mysql.jdbc.Driver"; 11     //数据库连接地址 12     private static String url = "jdbc:mysql://127.0.0.1:3306/flight?useSSL=False"; 13     //数据库用户名 14     private static String user = "root"; 15     //数据库密码 16     private static String password = "123456"; 17  18     //数据库连接 19     protected Connection conn = null; 20     //statement对象 21     protected PreparedStatement pstmt = null; 22  23     /** 24      * 连接数据库 25      * 26      * @return 数据库连接 27      * @throws ClassNotFoundException 未找到驱动类异常 28      * @throws SQLException           数据库异常 29      */ 30     protected Connection getConn() throws ClassNotFoundException, SQLException { 31         //加载驱动 32         Class.forName(driver); 33         //获取连接 34         conn = DriverManager.getConnection(url, user, password); 35         return conn; 36     } 37  38     /** 39      * 数据库查询方法 40      * 41      * @param sql    预编译sql语句 42      * @param params 预编译参数 43      * @return 查询结果集 44      * @throws SQLException 数据库异常 45      */ 46     protected ResultSet executeQuerySQL(String sql, Object[] params) throws SQLException { 47         ResultSet rs = null; 48         try { 49             conn = getConn(); 50         } catch (ClassNotFoundException e) { 51             e.printStackTrace(); 52         } 53         pstmt = conn.prepareStatement(sql); 54         if (params != null) { 55             for (int i = 0; i < params.length; i++) { 56                 pstmt.setObject(i + 1, params[i]); 57             } 58         } 59         rs = pstmt.executeQuery(); 60         return rs; 61     } 62  63     /** 64      * 数据库增删改方法 65      * 66      * @param sql    预编译sql语句 67      * @param params 预编译参数 68      * @return 数据库影响行数 69      * @throws SQLException 数据库异常 70      */ 71     protected int executeUpdate(String sql, Object[] params) throws SQLException { 72         try { 73             conn = getConn(); 74         } catch (ClassNotFoundException e) { 75             e.printStackTrace(); 76         } 77         int num = 0; 78         pstmt = conn.prepareStatement(sql); 79         if (params != null) { 80             for (int i = 0; i < params.length; i++) { 81                 pstmt.setObject(i + 1, params[i]); 82             } 83         } 84         num = pstmt.executeUpdate(); 85  86         return num; 87     } 88  89     /** 90      * 关闭数据库连接 91      * @param conn 数据库连接 92      * @param pstmt  statement对象 93      * @param rs  ResultSet对象 94      */ 95     protected void closeALL(Connection conn, PreparedStatement pstmt, ResultSet rs) { 96         try { 97             if (rs != null) { 98                 rs.close(); 99             }100             if (pstmt != null) {101                 pstmt.close();102             }103             if (conn != null) {104                 conn.close();105             }106         } catch (SQLException e) {107             e.printStackTrace();108         }109     }110 }