用JDBC实现MySQL的增删改查

在上篇博客上已经写过如何如实现用JDBC去连接数据库了，无非就是几个步骤，首先是去下载mysql官方驱动包、注册驱动，然后去创建数据库连接，再者去创建SQL执行对象，接下来就是去获取数据库内容，最后是关闭这些对象。把这几个步骤实现起来并不难，最后把jdbc进行重构，就很容易去使用了。

接下来要讲到的是如何去写一个类去实现对数据库的增、删、改、查？既然是数据库肯定的对数据进行更新的，那就得对数据库的数据进行操作了。

首先我们创建一个类去操作完成增删改查，再在该类中实现这些方法，代码如下：

  import java.sql.Connection;
  import java.sql.ResultSet;
  import java.sql.Statement;
  import java.sql.Timestamp;
  import java.util.ArrayList;
  import java.util.List;
  import org.junit.Test;
  import entity.User;
  import util.JdbcUtil;
 //创建一个普通类
public class UserCURD {
         //添加一个用户
        public void addUser() {}
        //修改用户
        public void updateUser() {}
            //删除用户
        public void deleteUser() {}
       //查询所有用户
        public List<User> findAllUser(){}
    }

接下来就是要把这几个方法进行实现了，我们按着方法的顺序进行依次实现这些方法

实现增加一个用户信息

   public void addUser(User  user) throws Exception{
    String sql = "INSERT INTO USERS(ID,NAME,SAL) VALUES(?,?,?,?)"; //根据数据库字段信息进行添加记录
    Connection conn = null;
    PrepareStatement stmt = null;
    ResultSet rs = null;
    try{
        conn = JdbcUtil.getConnection();//调用工具类JdbcUtil方法
        psta=(PreparedStatement) conn.prepareStatement(sql);//PreparedStatement为Statement的子类
        psta.setInt(1,user.getid());//从外面得到的值，然后将它传入数据库
        psta.setString(2, user.getname());
        psta.setString(3, user.getsal());
        psta.executeUpdate();//更新数据库里面的数据

    }
    catch(Exception e)
    {
        e.printStackTrace();
    
    }finally{
        JdbcUtil.close(rs);
        JdbcUtil.close(stmt);
        JdbcUtil.close(conn);
    }
}

实现删除用户

 public void deleteUser() throws SQLException
{
    String sql="delete from users where id in(1,3)";
    Connection conn=null;
    Statement stmt=null;
    ResultSet rs=null;
    try
    {
        conn=JdbcUtil.getConnection(); //创建连接数据库
        stmt=conn.createStatement();//创建一个数据库对象 ，即数据库里的表
        int i=stmt.executeUpdate(sql);
                  //如果i的值不为空，则说明有数据存在，对数据进行删除
        if(i>0)
        {
            System.out.println("删除成功");
        }
        else
        {
            System.out.println("删除失败");
        }
    }
    catch(Exception e)
    {
        
    }
    finally
    {
        JdbcUtil.close(rs);
        JdbcUtil.close(stmt);
        JdbcUtil.close(conn);
    }
}

修改用户信息

public void opdateUser() throws SQLException
{
    String sql="update users set sal=sal+6666  where name='张三'";
    Connection conn=null;
    Statement stmt=null;
    ResultSet rs=null;
    try
    {
        conn=JdbcUtil.getConnection(); //创建连接数据库
        stmt=conn.createStatement();//创建一个数据库对象 ，即数据库里的表
        int i=stmt.executeUpdate(sql);
        if(i>0)
        {
            System.out.println("修改成功");
        }
        else
        {
            System.out.println("修改失败");
        }
    }
    catch(Exception e)
    {
        
    }
    finally
    {
        JdbcUtil.close(rs);
        JdbcUtil.close(stmt);
        JdbcUtil.close(conn);
    }
}

实现用户查询

public void findUser() throws SQLException
{
    String sql="SELECT * FROM USERS WHERE ID=2";
    Connection conn=null;
    Statement stmt=null;
    ResultSet rs=null;
    try
    {
        conn=JdbcUtil.getConnection(); //创建连接数据库
        stmt=conn.createStatement();//创建一个数据库对象 
        rs=stmt.executeQuery(sql);
        if(rs.next())
        {
            System.out.println("查询成功"); 
                         //输出用户信息
            String name=rs.getString("name");
            double sal=rs.getDouble("sal");
            System.out.println(name+"   "+sal);
        }
        else
        {
            System.out.println("查询失败");
        }
    }
    catch(Exception e)
    {
        
    }
    finally
    {
        JdbcUtil.close(rs);
        JdbcUtil.close(stmt);
        JdbcUtil.close(conn);
    }
}

这样就能实现一个类来对数据库进行增删改查了，对于工具类JdbcUtil的实现在这里就不给出了，可以结合上一篇博客内容对数据库驱动的注册进行封装在工具类中，User类也是一样的对所需要的信息进行添加相应的方法即可实现。