Java Web简明教程–Java篇[9]–使用SQL语句实现增删改查

import java.sql.*;//导入数据库相关类库
/**
 * MysqlHandler MySQL数据库管理类
 * @author 猫哥
 * @date 2016.12.31
 */
public class MysqlHandler{
  //三个必备属性
    private Connection conn = null;//Connection表示跟数据库的连接，这个很好理解。你每一次打电话都要通了之后才行，你每一次连接数据库都要连接了才行
    private Statement stmt = null;//Java连接了数据库之后，要对数据库进行什么操作？需要告诉数据库哪些参数？这些信息都依赖于Statement
    private ResultSet rs = null;//如果是从数据库查询数据，可以把返回的数据放在ResultSet里面
    //首先第一步，需要跟数据库建立连接
    public Connection buildConnection() {        
      String driver = "com.mysql.jdbc.Driver";//MySQL数据库的驱动程序名
         String url = "jdbc:mysql://localhost:3306/java?useUnicode=true&characterEncoding=utf-8";//数据库连接字符串
         String user = "root";//用户名
         String password = "Pass1234";//密码
         try{   
          Class.forName(driver);//加载驱动程序
          conn=DriverManager.getConnection(url,user,password);//输入必备参数，获取连接   
         }
         catch(Exception ex){
          ex.printStackTrace();//可以输出比较详细的异常信息 
         }
        return conn;
    }
    //第二步，“增删改查”中，增、删、改都是执行sql语句，无需返回ResultSet结果集，所以设置为一个方法
    public int execute(String sql){
        try {
          if(stmt==null)//创建Statement
          stmt=conn.createStatement();
            int affectedCount = stmt.executeUpdate(sql);//此处真正执行stmt定义的操作
            return affectedCount;//这个是收到影响的行数
        } catch (Exception ex) {
            ex.printStackTrace();
            return -1;//返回-1，表示执行失败了，有异常
        }
    }
    //第二步，如果是查询，需返回结果集
    public ResultSet query(String sql){
        try {
          if(stmt==null)//创建Statement
          stmt=conn.createStatement();
            rs = stmt.executeQuery(sql);//执行pstmt中定义的查询
            return rs;//将结果集返回
        } catch (Exception ex) {
            ex.printStackTrace();
            return null;//如果有错误，返回null
        }
    }
    //第四步，之前建立了和数据库的连接，要知道数据库的连接是有限的，用完了必须释放，不然咱一个程序占人家20个连接，太浪费了
    public void sayGoodbye(){
      //此处注意，不要用一个try{}把三个.close()都包含起来，如果第一个就异常了，后面即使不异常也关闭不了，对吧
        if(rs!=null){//关闭结果集，这个不关闭也浪费
            try {
                rs.close();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
        if(stmt!=null){//关闭Statement，不要浪费
            try {
              stmt.close();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
        if(conn!=null){//关闭连接
            try {
                conn.close();
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
    }
}

import java.sql.*;
public class TestMysql {//测试MysqlHandler类
  public static void main(String[] args)  {
  try {//捕获异常
    testOneTime();
  } catch (SQLException e) {
    e.printStackTrace();
  }
  }
  //测试一次完整的增删改查操作
  private static void testOneTime()throws SQLException{//可能会有异常，我们在更广阔的天地捕获之
  MysqlHandler hand=new MysqlHandler();
  Connection con=hand.buildConnection();//建立连接
  ResultSet rs;//可以使用多次
  //查
  rs=hand.query("select * from student_info");
  //展示结果
  System.out.println("\n查询结果如下：");
  while(rs.next()){
    System.out.print(rs.getInt(1) + "|");
             System.out.print(rs.getString(2) + "\t");
  }
  //增加2个
  int addCount=hand.execute("insert into student_info (student_name) values('火星人'),('水星人')");
  System.out.println("\n增加了"+addCount+"个");
  //删除一个
  int delCount=hand.execute("delete from student_info where student_name='张三'");
  System.out.println("\n删除了"+delCount+"个");
  //修改一个，把李四改造成火星人
  int changeCount=hand.execute("update student_info set student_name='火星人李四' where student_name='李四'");
  System.out.println("\n修改了"+changeCount+"个");
  //查
  rs=hand.query("select * from student_info");
  System.out.println("\n查询结果如下：");
  while(rs.next()){
    System.out.print(rs.getInt(1) + "|");
    System.out.print(rs.getString(2) + "\t");
  }
  hand.sayGoodbye();//千万别忘了关闭
  }
}

import java.sql.*;
public class TestMysql {//测试MysqlHandler类
  public static void main(String[] args)  {
  try {//捕获异常
    long start=System.currentTimeMillis();//产生一个当前的毫秒(自1970年1月1日0时起的毫秒数)
    for(int i=0;i<100;i++){//***此处控制测试次数***
    testOneTime();
    }
    long end=System.currentTimeMillis();
    System.out.println("\n消耗时间："+(end-start)+"毫秒");
  } catch (SQLException e) {
    e.printStackTrace();
  }
  }
  //测试一次完整查询
  private static void testOneTime()throws SQLException{//可能会有异常，我们在更广阔的天地捕获之
  MysqlHandler hand=new MysqlHandler();
  Connection con=hand.buildConnection();//建立连接
  ResultSet rs;//可以使用多次
  //查
  rs=hand.query("select * from student_info");
  hand.sayGoodbye();//千万别忘了关闭
  }
}

import java.sql.*;
public class TestMysql {//测试MysqlHandler类
  public static MysqlHandler hand=new MysqlHandler();
  public static Connection con=hand.buildConnection();//建立连接
  public static ResultSet rs;//可以使用多次
  public static void main(String[] args)  {
  try {//捕获异常
    long start=System.currentTimeMillis();//产生一个当前的毫秒(自1970年1月1日0时起的毫秒数)
    for(int i=0;i<1;i++){
    testOneTime();
    }
    hand.sayGoodbye();//千万别忘了关闭
    long end=System.currentTimeMillis();
    System.out.println("\n消耗时间："+(end-start)+"毫秒");
  } catch (SQLException e) {
    e.printStackTrace();
  }
  }
  //测试一次完整查询
  private static void testOneTime()throws SQLException{//可能会有异常，我们在更广阔的天地捕获之
  //查
  rs=hand.query("select * from student_info");