1.首先在项目根目录创lLib文件夹，放入jdbc驱动程序，然后Add As Library
2.建包
bean包：专门放置属性类
dao包： 进行数据操作的类
util包： 放工具类
test包： 测试类
正式开始
1.在bean包中写实体类：
package com.hopu.bean;
public class Member {
private String name;
private String pwd;
private float score;
private int rank;
//无参
public Member() {
}
//有参
public Member(String name, String pwd, float score, int rank) {
this.name = name;
this.pwd = pwd;
this.score = score;
this.rank = rank;
}
//get和set方法
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPwd() {
return pwd;
}
public void setPwd(String pwd) {
this.pwd = pwd;
}
public float getScore() {
return score;
}
public void setScore(float score) {
this.score = score;
}
public int getRank() {
return rank;
}
public void setRank(int rank) {
this.rank = rank;
}
@Override
public String toString() {
return "Member{" +
"name='" + name + '\'' +
", pwd='" + pwd + '\'' +
", score=" + score +
", rank=" + rank +
'}';
}
}
对应的mysql数据库
2.在util包中的MemberUtil类写了连接数据库和释放资源两个方法：
package com.hopu.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class MemberUtil {
//1.获取数据库的连接 2.释放资源
//连接数据库的四大参数(也可以形成配置文件)
public static String driver="com.mysql.cj.jdbc.Driver";//MySQL驱动程序的全类名
public static String url="jdbc:mysql://127.0.0.1:3306/shop?useSSL=false&serverTimezone=UTC";
public static String username="root";
public static String password="678";
public static Connection con=null;
//
public static Connection getCon(){
try{
//1.加载驱动包
Class.forName(driver);
//2.使用驱动管理器来获得连接---获得一个数据库连接对象Connection
con = DriverManager.getConnection(url, username, password);
}catch (Exception e){
e.printStackTrace();
}
return con;
}
public static void myClose(ResultSet rs, PreparedStatement pstm, Connection con){
//回收资源
try{
if(rs!=null){
rs.close();
}
if(pstm!=null){
pstm.close();
}
if(con!=null){
con.close();
}
}catch (Exception e){
e.printStackTrace();
}
}
public static void myClose( PreparedStatement pstm,Connection con){
//
try{
if(pstm!=null){
pstm.close();
}
if(con!=null){
con.close();
}
}catch (Exception e){
e.printStackTrace();
}
}
}
getCon()方法返回 Connection 对象，myClose()方法无返回值。
dao包里面写增删改查四种方法，其中sql语句一定要写对，也不要有多余的空格。
package com.hopu.dao;
import com.hopu.bean.Member;
import com.hopu.util.MemberUtil;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
public class MemberDao {
private Connection con=null;//连接器
private PreparedStatement pstm=null;//sql执行器对象
private ResultSet rs=null;//结果集对象
private int n=0;//更新影响的行数。
//添加
public int add(Member member){
try{
//1.获取数据库的连接
con = MemberUtil.getCon();
//2.获取带参数的sql语句执行器
String sql="insert into member values(?,?,?,?)";
//使用Connection创建PreparedStatement语句对象---PreparedStatement对象可以执行sql语句
pstm = con.prepareStatement(sql);
//3.给pstm的？赋值
pstm.setObject(1,member.getName());
pstm.setObject(2,member.getPwd());
pstm.setObject(3,member.getScore());
pstm.setObject(4,member.getRank());
//4.执行sql
n = pstm.executeUpdate();
}catch (Exception e){
e.printStackTrace();
}finally {
//调用MemberUtil中的myClose方法进行资源的释放
MemberUtil.myClose(pstm,con);
}
return n;
}
//删
public int delete(int rank){
try{
//
con = MemberUtil.getCon();
//
String sql="delete from member where `rank`=?";
pstm = con.prepareStatement(sql);
pstm.setObject(1,rank);
n = pstm.executeUpdate();
}catch (Exception e){
e.printStackTrace();
}finally {
//调用MemberUtil中的myClose方法进行资源的释放
MemberUtil.myClose(pstm,con);
}
return n;
}
//改
public int update(Member member){
try{
con = MemberUtil.getCon();
String sql="update member set name=?,pwd=?,score=? where `rank`=?";
pstm = con.prepareStatement(sql);
pstm.setObject(1,member.getName());
pstm.setObject(2,member.getPwd());
pstm.setObject(3,member.getScore());
pstm.setObject(4,member.getRank());
n = pstm.executeUpdate();
}catch (Exception e){
e.printStackTrace();
}finally {
//调用MemberUtil中的myClose方法进行资源的释放
MemberUtil.myClose(pstm,con);
}
return n;
}
//查
public ArrayList<Member> selectAll(){
ArrayList<Member> list = new ArrayList<>();
try{
con = MemberUtil.getCon();
String sql="select * from member";
pstm = con.prepareStatement(sql);
rs = pstm.executeQuery();
//是查询结果集，指针用来操作数据。指针默认指向列标题，要想徼作数据，需要向下移动
while(rs.next()){
//获取数据库表中当前每一个字段的值并存入到member对象中
Member member = new Member();
member.setName(rs.getString("name"));
member.setPwd(rs.getString("pwd"));
member.setScore(rs.getFloat("score"));
member.setRank(rs.getInt("rank"));
//把Member对象存入到集合中
list.add(member);
}
}catch (Exception e){
e.printStackTrace();
}finally {
//调用MemberUtil中的myClose方法进行资源的释放
MemberUtil.myClose(rs,pstm,con);
}
return list;
}
//单查
public Member selectById(int rank){
Member member = new Member();
try{
//1.获取数据库连接
con = MemberUtil.getCon();
//2.获取SQL的执行器
String sql="select * from member where `rank`=?";
pstm = con.prepareStatement(sql);
pstm.setObject(1,rank);
//执行全查询
rs = pstm.executeQuery();
//获取结果集---（一行数据就是一个Member对象）
if(rs.next()){
member.setName(rs.getString("name"));
member.setPwd(rs.getString("pwd"));
member.setScore(rs.getFloat("score"));
member.setRank(rs.getInt("rank"));
}
}catch (Exception e){
e.printStackTrace();
}finally {
//调用MemberUtil中的myClose方法进行资源的释放
MemberUtil.myClose(rs,pstm,con);
}
return member;
}
}
4.test测试类中 因为写一个小功能就要写一个类，写一个main方法，所以我们直接在需要的地方打出@Test，注意要自己打这个是没有提示的，然后按下Alt + Enter 选择导入JUnit4
package com.hopu.test;
import com.hopu.bean.Member;
import com.hopu.dao.MemberDao;
import org.junit.Test;
import java.util.ArrayList;
public class Test01 {
//！!!!!!!!!!!!!!!!!!!!!!!!!sql语句中不要有空格。
//添加
@Test
public void add(){
MemberDao memberDao = new MemberDao();
Member member = new Member();
member.setName("小五");
member.setPwd("456");
member.setScore(56);
member.setRank(2);
int n = memberDao.add(member);
if(n>0){
System.out.println("添加成功！");
}else{
System.out.println("添加失败！");
}
}
//删除
@Test
public void delete(){
MemberDao memberDao = new MemberDao();
int n = memberDao.delete(2);
if(n>0){
System.out.println("删除成功！");
}else{
System.out.println("删除失败！");
}
}
//改
@Test
public void update(){
MemberDao memberDao = new MemberDao();
//1.首先查询当前数据
Member member = memberDao.selectById(2);
//System.out.println(member);
//2.再修改某些字段值
member.setName("花花");
//3.执行更新
int n = memberDao.update(member);
if(n>0){
System.out.println("修改成功！");
}else{
System.out.println("修改失败！");
}
}
//查
@Test
public void selectAll(){
MemberDao memberDao = new MemberDao();
ArrayList<Member> members = memberDao.selectAll();
for (Member member : members) {
System.out.println(member);
}
}
}
mysql数据库的运行结果：
显示运行成功，数据库发生变化，删改查一样运行对应的方法。
删除：
修改：
全查：
