Java使用jdbc连接MySql数据库，实现增删改查

首先，导入MySql连接数据库的jar包，我用的是

mysql连接jar包
DB类，用于获得数据库连接

import java.sql.DriverManager;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;

public class DB {
    //数据库的URL
    private static final String URL="jdbc:mysql://127.0.0.1:3306/test";
    //数据库连接的用户名
    private static final String USER="root";
    //密码
    private static final String PASSWORD="123456";
    private static Connection conn=null;
    static {
        try {
            //加载驱动程序
            Class.forName("com.mysql.jdbc.Driver");
            //获得数据库的连接
            conn=(Connection) DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static Connection getConnection(){
        return conn;
    }
}

实体类Users：

public class Users {
    private int id;
    private String username;
    private String password;
    public Users() {
        super();
    }
    public int getId() {
        return id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    public Users(String username, String password) {
        this.username = username;
        this.password = password;
    }
}

数据库操作类UsersDao，实现users的增删改查操作

import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
//导入刚才的两个类
import cn.jufe.sex.db.DB;
import cn.jufe.sex.model.Users;

public class UsersDao {
    public boolean addUser(Users user) throws SQLException{
    //增加用户,传入一个users对象，将对象中的数据加入数据库
    //id属性我在数据中设置了自增长型，所以ID不用去设置
        //获得数据库连接
        Connection conn = DB.getConnection();
        //sql语句
        String sql ="insert into users(username,password) "+ "values(?,?)";
        //通过conn获得PreparedStatement对象，该对象可对sql语句进行预编译
        PreparedStatement ptmt = (PreparedStatement) conn.prepareStatement(sql);
        //对sql语句中的参数进行赋值
        ptmt.setString(1, user.getUsername());
        ptmt.setString(2, user.getPassword());
        //执行SQL语句,返回受影响的行数，a大于0，则成功
        int a = ptmt.executeUpdate();
        if(a>0)
           return true;
        else
           return false;
    }
    public boolean deluser(Integer id) throws SQLException{//删
        //获得数据库连接
        Connection conn = DB.getConnection();
        //sql语句
        String sql ="delete from users where id=?";
        //通过conn获得PreparedStatement对象，该对象可对sql语句进行预编译
        PreparedStatement ptmt = (PreparedStatement) conn.prepareStatement(sql);
        ptmt.setInt(1, id);
        //执行SQL语句,返回受影响的行数，a大于0，则成功
        int a = ptmt.executeUpdate();
        if(a>0)
           return true;
        else
           return false;
    }
    public boolean updateuser(Users user) throws SQLException{//改
        //获得数据库连接
        Connection conn = DB.getConnection();
        //sql语句
        String sql =" update users set name=?,password=? where id=?";
        //通过conn获得PreparedStatement对象，该对象可对sql语句进行预编译
        PreparedStatement ptmt = (PreparedStatement) conn.prepareStatement(sql);
        ptmt.setString(1, u.getName());
        ptmt.setString(2, u.getPassword());
        ptmt.setString(3, u.getId());
        //执行SQL语句,返回受影响的行数，a大于0，则成功
        int a = ptmt.executeUpdate();
        if(a>0)
           return true;
        else
           return false;
    }
    public Users findByName(String username) throws SQLException{
    //通过姓名查询用户，通过ID同理
        //获得数据库连接
        Connection conn=DB.getConnection();
        //sql语句
        String sql="select * from users where username=?";
        //通过conn获得PreparedStatement对象，该对象可对sql语句进行预编译
        PreparedStatement ptmt=(PreparedStatement) conn.prepareStatement(sql);
        ptmt.setString(1, username);
        //new一个Resultset对象接受返回的数据
        ResultSet rs=ptmt.executeQuery();
        //通过users对象接受rs中的数据，如果rs中含有多个数据则使用数组接收
        //while(rs.next()) {
        //  Users user=new Users();
        //  user.setPassword(rs.getString("password"));
        //  user.setUsername(rs.getString("username"));
        //  list.add(user);
        //}
        //  return list;
        while(rs.next()) {
            Users user=new Users();
            user.setPassword(rs.getString("password"));
            user.setUsername(rs.getString("username"));
        }
        return user;
    }
}

UsersDao的使用，直接new一个UsersDao对象，调用函数即可