Java连接MySQl数据库实现代码

package connectionmysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class ConnectionMysql {

    //数据库连接用户名
    private String userName = "root";
    
    //数据库连接密码
    private String pwd = "910214";
    
    //设置数据库
    private String database = "jsp";
    
    //设置jdbc驱动
    private String dbDriver = "com.mysql.jdbc.Driver";
    
    //设置数据库连接URL
    private String dbCOnnect= "jdbc:mysql://localhost:3306/"+database;
    
    //连接变量
    private Connection cOnn= null;
    
    private Statement stmt = null;
    
    ResultSet rs = null;
    
    
    /*数据库驱动注册*/
    public ConnectionMysql()
    {
        try{
            Class.forName(dbDriver);
        }
        catch(Exception ex)
        {
            System.out.println("连接失败: "+ex.getMessage());
        }
    }
    
    /*建立数据库连接及其数据查询*/
    public ResultSet executeQuery(String sql) throws SQLException{
        rs = null;
        try{
            conn = DriverManager.getConnection(dbConnect, userName, pwd);
            stmt = conn.createStatement();
            rs = stmt.executeQuery(sql);
        }catch(Exception ex)
        {
            System.out.println("连接失败: "+ex.getMessage());
        }
//        finally{
//            //关闭数据库连接
//            stmt.close();
//            conn.close();
//        }
        return rs;
    }
    
    /*建立数据库连接和数据库查询*/
    public void excuteUpdate(String sql) throws SQLException
    {
        stmt = null;
        try{
            //连接数据库
            cOnn= DriverManager.getConnection(dbConnect, userName, pwd);
            stmt = conn.createStatement();
            stmt.executeUpdate(sql);
        }catch(Exception ex){
            //手动抛出异常
            throw new SQLException(ex.getMessage());
        }
//        finally{
//            stmt.close();
//            conn.close();
//        }
    }
    
    /*
     * 考虑数据库的性能问题，需要释放数据库资源，因此关闭方法
     */
    //关闭陈述语句
    public void CloseStmt()
    {
        try{
            stmt.close();
        }catch(SQLException ex){
            System.out.println("关闭数据库失败: "+ex.getMessage());
        }
    }
    //关闭连接
    public void CloseConn(){
        try{
            conn.close();
        }catch(SQLException ex){
            System.out.println("关闭连接失败: "+ex.getMessage());
        }
    }
    
    
}

package connectionmysql;

import java.sql.ResultSet;
import java.sql.SQLException;

public class TestMysqlConnection {

    /**
     * 运行程序测试
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub

        ConnectionMysql conMysql = new ConnectionMysql();
        //查询数据库SQL语句
        String sql = "select username,password from userlogin";
        
        try{
            //返回查询结果集
            ResultSet rs = conMysql.executeQuery(sql);
            //打印查询数据
            if(rs.next()){
                String username = rs.getString(1);
                String password = rs.getString(2);
                System.out.println("用户名: "+username);
                System.out.println("密    码 : "+password);
//                System.out.println(rs.getString(2));
            }
        }catch(SQLException ex){
            System.out.println("查询失败: "+ex.getMessage());
        }finally{
            //关闭数据库连接
            conMysql.CloseStmt();
            conMysql.CloseConn();
        }
    }

}