使用JDBC连接MySQL数据库的一个基本案例

package com.java_JDBC;

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


public class JDBC_test {

    private static String Driver="com.mysql.jdbc.Driver"; //数据库驱动
    //连接数据库的URL地址
    private static String url="jdbc:mysql://localhost:3306/hellojdbc?useUnicode=true&characterEncoding=UTF-8";
    private static String username="root";//数据库连接用户名
    private static String password="123456";//数据库连接密码
    
    private static Connection conn=null;//数据库连接对象
    private static Statement stat=null;//语句陈述对象
    private static ResultSet rs=null;//结果数据集
    private static PreparedStatement pst=null;//预编译语句
    
    //使用静态块的方式加载驱动
    static {
        try {
            //调用Class对象的静态forName()方法加载数据库驱动类
            Class.forName(Driver);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        
    }
    
    //使用单例模式返回数据库连接对象
    public static Connection getConnection() throws SQLException{
        if(conn==null){
            conn=DriverManager.getConnection(url, username, password);
            return conn;
        }
        return conn;

    } 
    
    
    //测试数据库连接是否正常
    public static void isConnect() throws SQLException{
        Connection con=getConnection();
        if(con!=null)
            System.out.println("数据库连接正常");
        else
            System.out.println("数据库连接失败");
    }
    
    
    //查询全部数据库表中所有信息
    public static void QueryToAll(){
        try {
            stat=conn.createStatement();//由连接获取语句陈述对象
            rs=stat.executeQuery("select * from roster");//获取结果集信息
            while(rs.next()){
                System.out.println("id:"+rs.getInt("id")+",name:"+rs.getString("name")+",age:"+rs.getInt("age"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            clean();
        }
        
        
    }
    
    
    //按名字查找数据库中信息
    public static void QueryForName(String name){
        try {
            pst = conn.prepareStatement("select * from roster where name=?");//获取预编译语句
            pst.setString(1, name);//设置预编译语句参数
            rs=pst.executeQuery();//执行预编译语句，获取结果数据集
            while(rs.next()){
                System.out.println("id:"+rs.getInt("id")+",name:"+rs.getString("name")+",age:"+rs.getInt("age"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            clean();
        }
        
    }
    
    
    //增加数据库中数据信息
    public static void insert(){
        try {
            String sql="insert into roster(id,name,age) values (‘4‘,‘zhangsan‘,‘14‘)";
            stat=conn.createStatement();
            int count=stat.executeUpdate(sql);//执行语句陈述对象的更新操作
            System.out.println("插入操作成功，插入信息条数为"+count);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            clean();
        }
        
    }
    
    //修改数据库中数据信息
    public static void alter(){
        try {
            String sql="update roster set age=12 where name=‘zhangsan‘";
            stat=conn.createStatement();
            int count = stat.executeUpdate(sql);//执行语句陈述对象的更新操作
            System.out.println("修改操作成功，修改信息条数为"+count);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            clean();
        }
        
    }
    
    //删除数据库中数据信息
    public static void delete(){
        try {
            String sql="delete from roster where name=‘zhangsan‘";
            stat=conn.createStatement();
            int count=stat.executeUpdate(sql);//执行语句陈述对象的更新操作
            System.out.println("删除操作成功，删除信息条数为"+count);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            clean();
        }
        
        
    }
    
    //释放内存，清理环境
    public static void clean(){
        try {
            if(rs!=null)
                rs.close();
            if(pst!=null)
                pst.close();
            if(stat!=null)
                stat.close();
            
            //不能关闭单例模式下的connection连接对象，否则当一个数据库操作完成后便不能进行其他数据库操作
//            if(conn!=null)
//                conn.close();
//                
                
            } catch (SQLException e) {
                e.printStackTrace();
            }
        
    }
    
    
    public static void main(String[] args) throws SQLException {
        isConnect();
        QueryForName("Bob");
        System.out.println("--------------------------------------");
        QueryToAll();
        System.out.println("--------------------------------------");
        insert();
        System.out.println("--------------------------------------");
        QueryToAll();
        System.out.println("--------------------------------------");
        alter();
        System.out.println("--------------------------------------");
        QueryToAll();
        System.out.println("--------------------------------------");
        delete();
        System.out.println("--------------------------------------");
        QueryToAll();

    }

}