简单的数据库连接示例

简单数据库工具

public class SimpleDBDemo {
    

    public static void main(String[] args) {
    
    
        try {
    
            // 加载数据库驱动 com.mysql.cj.jdbc.Driver
            String strDriver = "com.mysql.cj.jdbc.Driver";
            // 获取mysql连接地址
            String strURL = "jdbc:mysql://localhost:3306/mytest?&useSSL=false&serverTimezone=UTC";
            // 用户名称
            String username = "root";
            // 用户密码
            String password = "123456";
    
            Class.forName(strDriver);
            System.out.println("SQLServerDriver success");
    
            // 获取一个数据的连接，连接MySql数据库
            Connection con = DriverManager.getConnection(strURL, username, password);
            System.out.println("Connection success");
    
            // 创建statement类对象，用来执行SQL语句！
            Statement stm = con.createStatement();
    
            // 要执行的SQL语句
            String strSql = "select * from student";
    
            // ResultSet类，用来存放获取的结果集！
            ResultSet rs = stm.executeQuery(strSql);
    
            while(rs.next()){
    
    
                String s1 = rs.getString(1);
                String s2 = rs.getString(2);
                double d3 = rs.getDouble(3);
                System.out.println(s1+"\t"+s2+"\t\t"+d3);
            }
    
            rs.close();
            stm.close();
            con.close();
    
        } catch (ClassNotFoundException | SQLException e) {
    
            e.printStackTrace();
        }
    }
}

通用数据库工具

public class JDBCUtil {
    
    private static final String driver;
    private static final String url;
    private static final String userName;
    private static final String password;

    static {
    
        InputStream is = JDBCUtil.class.getClassLoader().getResourceAsStream("db.properties");
        Properties properties = new Properties();
        try {
    

            properties.load(is);
        } catch (IOException e) {
    
            e.printStackTrace();
        }
        driver = properties.getProperty("driver");
        url = properties.getProperty("url");
        userName = properties.getProperty("username");
        password = properties.getProperty("password");
    }

    // 获取数据库连接
    public static Connection getConnection() {
    
        Connection con = null;
        try {
    
            Class.forName(driver);
            con = DriverManager.getConnection(url, userName, password);
        } catch (SQLException | ClassNotFoundException e) {
    
            e.printStackTrace();

        }
        return con;
    }

    // 数据库查询，返回结果集
    public static ResultSet query(Connection con, PreparedStatement st, ResultSet rs, String sql
            , Object[] params) throws SQLException {
    
        st = con.prepareStatement(sql, ResultSet.TYPE_SCROLL_SENSITIVE,
                ResultSet.CONCUR_READ_ONLY);
        if (params != null) {
    
            for (int i = 0; i < params.length; i++) {
    
                st.setObject(i + 1, params[i]);
            }
        }
        rs = st.executeQuery();
        return rs;
    }

    // 数据库增删改
    public static int update(Connection con, String sql
            , Object[] params, ResultSet rs, PreparedStatement st) throws SQLException {
    
        st = con.prepareStatement(sql);
        for (int i = 0; i < params.length; i++) {
    
            st.setObject(i + 1, params[i]);
        }
        return st.executeUpdate();
    }

    // 关闭数据库连接
    public static void release(Connection con, Statement st, ResultSet rs) {
    
        boolean flag = true;

        if (rs != null) {
    
            try {
    
                rs.close();
                rs = null;
            } catch (SQLException e) {
    
                e.printStackTrace();
                flag = false;
            }
        }

        if (st != null) {
    
            try {
    
                st.close();
                st = null;
            } catch (SQLException e) {
    
                e.printStackTrace();
                flag = false;
            }
        }

        if (con != null) {
    
            try {
    
                con.close();
                con = null;
            } catch (SQLException e) {
    
                e.printStackTrace();
                flag = false;
            }
        }
    }
}