在上篇博客上已经写过如何如实现用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类也是一样的对所需要的信息进行添加相应的方法即可实现。
