1.打开Idea,创建一个Maven工程,File---->New---->Project
2.填写文件名和路径,完成
3.打开mysql,创建一个数据库和表
4.向表里添加数据
6.新建一个文件,起名为lib,在电脑里搜索mysql.jar,把它导入这个文件夹中
7.创建bean,dao,util三个包,里面分别建立三个类:Users,UsersDao,Util
8.在Users类里编写
package com.bean; public class Users { private int id; private String name; private String password; public Users(){ } public Users(String name,String password){ this.name=name; this.password=password; } public int getId() { return id; } public void setId(int id){ this.id=id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } }
9.在UsersDao里编写
package com.dao; import com.util.Util; import com.bean.Users; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public class UsersDao extends Util { //添加记录 public void insert(Users user) throws Exception { //1.获取连接对象 conn(); //2.获取一个可以执行sql语句的对象 String sql="insert users(name,password) values(?,?)"; pstm=conn.prepareStatement(sql); pstm.setString(1,user.getName()); pstm.setString(2,user.getPassword()); //3.执行一条添加的sql pstm.execute(); System.out.println("添加记录"); //4.关闭数据库 close(); } //删除记录 public void delete(int id) throws Exception{ //1.获取连接对象 conn(); //2.获取一个可以执行sql语句的对象 String sql="delete from users where id=?"; pstm=conn.prepareStatement(sql); pstm.setInt(1, id); //3.执行一条删除的sql pstm.execute(); System.out.println("删除记录"); //4.关闭数据库 close(); } //修改记录 public void update(int id,Users user) throws Exception{ //1.获取连接对象 conn(); //2.获取一个可以执行sql语句的对象 String sql="update users set name=?,password=? where id=?"; pstm=conn.prepareStatement(sql); pstm.setString(1, user.getName()); pstm.setString(2,user.getPassword()); pstm.setInt(3,id); //3.执行一条修改的sql pstm.executeUpdate(); System.out.println("修改记录"); //4.关闭数据库 close(); } //查询全部 public List<Map> select() throws Exception{ //1.获取连接对象 conn(); //2.获取一个可以执行sql语句的对象 String sql="select * from users"; pstm=conn.prepareStatement(sql); //3.执行一条修改的sql rs=pstm.executeQuery(); List list=new ArrayList(); while(rs.next()){ int id=rs.getInt("id"); String name=rs.getString("name"); String password=rs.getString("password"); Map map=new HashMap(); map.put("id",id); map.put("name",name); map.put("password",password); list.add(map); } System.out.println("查询全部记录"); //4.关闭数据库 close(); return list; } public static void main(String[] args) throws Exception { //在此处对表进行操作 UsersDao db=new UsersDao(); Users user=new Users("大哥","123"); db.insert(user); db.delete(7); Users user1=new Users("二哥","123"); db.update(1,user); List list=db.select(); System.out.println(list); } }
10.在Util里编写
package com.util; import java.sql.*; public class Util { public static String url; public static String name; public static String password; public static Connection conn=null;//连接数据库 public static Statement stm=null;//执行sql语句 public static PreparedStatement pstm=null; public ResultSet rs=null;//结果集 //连接数据库 public static Connection conn() throws Exception { Class.forName("com.mysql.jdbc.Driver"); url="jdbc:mysql://localhost:3306/123"; name="root"; password="x5"; conn= DriverManager.getConnection(url,name,password); System.out.println("连接数据库"); return conn; } //关闭数据库 public static void close() throws Exception { if(stm!=null){ stm.close(); } if(pstm!=null){ pstm.close(); } if(conn!=null){ conn.close(); } System.out.println("关闭数据库"); } } 11.点击运行
12.运行成功