devbox
正经夜光杯
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用JDBC连接并操作MySQL，SQL server，oracle三大数据库。以及分页查询展示_jdbc连接sql server数据库

作者：正经夜光杯 | 2024-08-02 13:40:48

赞

踩

jdbc连接sql server数据库

jdbc相关：

jdbc连接SQL server数据库：

首先要对SQL server的一些配置进行更改：

找到SQL server的配置管理器：然后点击进去。

找到SQL server网络配置下一级的mssqlserver的协议。把右边的，TCP/Ip的状态右击改为启动。
也可以点击属性设置，找到ip地址

把常用的ip10/ip6/ip4的地址改为本机。127.0.0.1
不能改成localhost

改完这些之后，重启SQL server服务
sqlserver(mssqlserver)

在java程序中连接SQL server：

新建一个类：

  1. public class SqlServerUtils {
  2.     public static Connection  con = null;
  3.     public static  Statement state = null;
  4.     public static  ResultSet rs = null;
  5. ​
  6.     static {
  7.         try {
  8.             Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
  9.         } catch (ClassNotFoundException e) {
  10.             e.printStackTrace();
  11.         }
  12.     }
  13.     //连接数据库
  14.     public static Connection getCon(){
  15.         String url = "jdbc:sqlserver://localhost:1433;databaseName=meitao";
  16.         //databaseName = 你要连接的数据库名字
  17.         String username = "sa"; //要连接的用户名
  18.         String password = "123"; //密码
  19.         try {
  20.             con = DriverManager.getConnection(url,username,password);
  21.         } catch (SQLException throwables) {
  22.             throwables.printStackTrace();
  23.         }
  24.         return con;
  25.     }
  26.     //关闭连接
  27.     public static void close(Connection con,Statement state,ResultSet rs){
  28.         try {
  29.             if (rs != null){
  30.                 rs.close();
  31.             }
  32.             if (state != null){
  33.                 state.close();
  34.             }
  35.             if (con != null){
  36.                 con.close();;
  37.             }
  38.         }catch (Exception e){
  39.             e.printStackTrace();
  40.         }
  41.     }
  42. }

新建dao层完成增删改查以adminDao为例：

  1. public class AdminDao {
  2. ​
  3.     //添加admin
  4.   public Integer addAdmin(Admin admin){
  5.       Connection con = SqlServerUtils.getCon();
  6.       PreparedStatement ps = null;
  7.       Integer result = null;
  8.       String sql = "insert into admin values(?,?,?)";
  9.       try {
  10.           ps = con.prepareStatement(sql);
  11.           //设置问号的值
  12.           ps.setInt(1,admin.getAdminId());
  13.           ps.setString(2,admin.getAdminName());
  14.           ps.setString(3,admin.getPwd());
  15.           //执行sql语句
  16.           int rows = ps.executeUpdate();
  17.           if (rows > 0){
  18.               return rows;
  19.           }else {
  20.               return 0;
  21.           }
  22.       } catch (SQLException throwables) {
  23.           throwables.printStackTrace();
  24.       }finally {
  25.          SqlServerUtils.close(con,ps,null);
  26.       }
  27.       return 0;
  28.   }
  29.     
  30.     //删除
  31.     public Integer delAdminById(Integer id){
  32.       Connection con = SqlServerUtils.getCon();
  33.       PreparedStatement ps = null;
  34.       ResultSet rs = null;
  35.       String sql = "delete from admin where adminid = ? ";
  36.         try {
  37.             ps = con.prepareStatement(sql);
  38.             ps.setInt(1,id);
  39.             int rows = ps.executeUpdate();
  40.             if (rows > 0){
  41.                 System.out.println("删除成功");
  42.             }else {
  43.                 System.out.println("删除失败");
  44.             }
  45.         } catch (SQLException throwables) {
  46.             throwables.printStackTrace();
  47.         }finally {
  48.             SqlServerUtils.close(con,ps,null);
  49.         }
  50.      
  51.     
  52.   //查找admin
  53.     public Admin getAdminByNameAndPwd(String name,String password){
  54.       Connection con = SqlServerUtils.getCon();
  55.       PreparedStatement ps = null;
  56.       ResultSet rs = null;
  57.       //String sql = "select * from admin where adminid = '"+id+"'";
  58.         String sql = "select * from admin where adminname = ? and password = ?";
  59.         try {
  60.             ps = con.prepareStatement(sql);
  61.             ps.setString(1,name);
  62.             ps.setString(2,password);
  63.             rs = ps.executeQuery();
  64.             if (rs.next()){
  65.                 int adminId = rs.getInt(1);
  66.                 String adminName = rs.getString(2);
  67.                 String pwd = rs.getString(3);
  68.                 return new Admin(adminId,adminName,pwd);
  69.             }
  70.         } catch (SQLException throwables) {
  71.             throwables.printStackTrace();
  72.         }finally {
  73.             SqlServerUtils.close(con,ps,rs);
  74.         }
  75.         return null;
  76.     }
  77. ​
  78.     //查询全部
  79.     public List<Admin> getAdminList(){
  80.         Connection con = SqlServerUtils.getCon();
  81.         PreparedStatement ps = null;
  82.         ResultSet rs = null;
  83.       String sql = "select * from admin";
  84.         try {
  85.             ps = con.prepareStatement(sql);
  86.              rs = ps.executeQuery();
  87.             while (rs.next()){
  88.                 int adminId = rs.getInt("adminid");
  89.                 String adminName = rs.getString("adminName");
  90.                 String pwd = rs.getString("password");
  91.                 System.out.println("编号："+adminId+" 姓名："+adminName+" 密码："+pwd);
  92.             }
  93.         } catch (SQLException throwables) {
  94.             throwables.printStackTrace();
  95.         }finally {
  96.             SqlServerUtils.close(con,ps,rs);
  97.         }
  98.         return  null;
  99.     }
  100. ​
  101.     //修改admin
  102.     public Integer updateAdmin(Admin admin){
  103.       Connection con = SqlServerUtils.getCon();
  104.       PreparedStatement ps = null;
  105.       Integer result = null;
  106.       String sql = "update admin set adminname = ? , password = ? where adminid = ?";
  107.         try {
  108.             ps = con.prepareStatement(sql);
  109.             ps.setString(1,admin.getAdminName());
  110.             ps.setString(2,admin.getPwd());
  111.             ps.setInt(3,admin.getAdminId());
  112.             result = ps.executeUpdate();
  113.         } catch (SQLException throwables) {
  114.             throwables.printStackTrace();
  115.         }finally {
  116.             SqlServerUtils.close(con,ps,null);
  117.         }
  118.         return result;
  119.     }
  120. }

新建测试类进行测试：

  1. public class sqlServiceTest {
  2.     public static void main(String[] args) {
  3.        //getAll();
  4. //        Admin admin = new Admin(3,"里哈哈","133232");
  5. //        updateAdmin(admin);
  6.         //getAdminByNameAndPwd("孙道恩","111");
  7.         delById(3);
  8.     }
  9. ​
  10.     //添加数据
  11.     public static void addAdmin(){
  12.         Admin admin = new Admin(3,"浮动","8989");
  13.         AdminDao adminDao = new AdminDao();
  14.         Integer rows = adminDao.addAdmin(admin);
  15.         if (rows > 0){
  16.             System.out.println("添加成功");
  17.         }else {
  18.             System.out.println("添加失败");
  19.         }
  20.     }
  21. ​
  22.     //单个查询
  23.     public static void getAdminByNameAndPwd(String name,String pwd){
  24.         AdminDao adminDao = new AdminDao();
  25.         Admin adminByNameAndPwd = adminDao.getAdminByNameAndPwd(name, pwd);
  26.         System.out.println(adminByNameAndPwd);
  27.     }
  28. ​
  29.     //查询全部
  30.     public static void getAll(){
  31.         AdminDao adminDao = new AdminDao();
  32.         List<Admin> adminList = adminDao.getAdminList();
  33.     }
  34.     //修改信息
  35.     public static void updateAdmin(Admin admin){
  36.         Integer rows = new AdminDao().updateAdmin(admin);
  37.         if (rows > 0){
  38.             System.out.println("修改成功");
  39.         }else {
  40.             System.out.println("修改失败");
  41.         }
  42.     }
  43.     //根据id删除
  44.     public static void delById(Integer id){
  45.         AdminDao adminDao = new AdminDao();
  46.         adminDao.delAdminById(id);
  47.     }
  48. }

jdbc连接Oracle数据库：

在utils包中创建一个OracleUtils类：
​

  1. import java.sql.Connection;
  2. import java.sql.DriverManager;
  3. import java.sql.SQLException;
  4. ​
  5. public class OracleUtils{
  6.     public static final String URL = "jdbc:oracle:thin:@127.0.0.1:1521/PDBORCL"; 
  7.     //后面的PDBORCl是要操作的pdb
  8.     //在navicate里面使用select name,open_mode from v$pdbs;查询全部找到这个pdb
  9.     //然后在执行下面的语句让此pdb打开alter pluggable database PDBORCL open;
  10.     public static final String USER = "c##sde2";
  11.     public static final String PASSWORD = "orcl";
  12.     
  13.     public static Connection getConnection(){
  14.         //加载驱动
  15.         try {
  16.             Class.forName("oracle.jdbc.OracleDriver");
  17.         }catch (ClassNotFoundException e){
  18.             e.printStackTrace();
  19.         }
  20.         //连接数据库
  21.         Connection con = null;
  22.         try {
  23.             con = DriverManager.getConnection(URL,USER,PASSWORD);
  24.         }catch (SQLException e){
  25.             e.printStackTrace();
  26.         }
  27.         System.out.println("连接成功");
  28.         return con;
  29.     }
  30. }
  31. ​
  32. //关闭连接
  33.     public static void close(Connection con, Statement state,ResultSet rs){
  34.         if (rs != null){
  35.             try {
  36.                 rs.close();
  37.             } catch (SQLException throwables) {
  38.                 throwables.printStackTrace();
  39.             }
  40.         }
  41.         if (state != null){
  42.             try {
  43.                 state.close();
  44.             } catch (SQLException throwables) {
  45.                 throwables.printStackTrace();
  46.             }
  47.         }
  48.         if (con != null){
  49.             try {
  50.                 con.close();
  51.             } catch (SQLException throwables) {
  52.                 throwables.printStackTrace();
  53.             }
  54.         }
  55.     }

方式2：

创建一个OracleCon类：

  1. import java.sql.Connection;
  2. import java.sql.DriverManager;
  3. ​
  4. public class OracleCon {
  5.     public static Connection getConnection() {
  6.         String driver = "oracle.jdbc.driver.OracleDriver";
  7.         String url = "jdbc:oracle:thin:@127.0.0.1:1521:ORCLPDB";
  8.         String user = "c##daoen"; //用户
  9.         String password = "orcl"; //此用户密码
  10.         return getConnection(driver, url, user, password);
  11.     }
  12. ​
  13.     public static Connection getConnection(String driver, String url, String user, String password) {
  14.         Connection conn = null;
  15.         try {
  16.             Class.forName(driver); // 加载数据库驱动
  17.             conn = DriverManager.getConnection(url, user, password); // 获取数据库连接
  18.         } catch (Exception e) {
  19.             System.out.println(e);
  20.         }
  21.         System.out.println("连接成功");
  22.         return conn;
  23.     }
  24. }
新建dao层完成增删改查的案例：
  1. public class OracleDao {
  2. ​
  3.     //查询全部
  4.     public List<Emp> getEmpList(){
  5.         Connection con = OracleUtils.getConnection();
  6.         Statement state = null;
  7.         ResultSet rs = null;
  8.         String sql = "select * from c##EMP";
  9.         try {
  10.             state = con.createStatement();
  11.             rs = state.executeQuery(sql);
  12.             while (rs.next()){
  13.                 int empId = rs.getInt(1);
  14.                 String adminName = rs.getString(2);
  15.                 String pwd = rs.getString(3);
  16.                 Date birthday = rs.getDate(4);
  17.                 System.out.println("编号："+empId+" 姓名："+adminName+" 密码"+pwd+" 日期："+birthday);
  18.             }
  19.         } catch (SQLException throwables) {
  20.             throwables.printStackTrace();
  21.         }finally {
  22.             OracleUtils.close(con,state,rs);
  23.         }
  24.         return null;
  25.     }
  26.     //根据姓名和密码查询
  27.     public Emp getEmpByNameAndPwd(String userName,String pwd){
  28.         Connection con = OracleUtils.getConnection();
  29.         PreparedStatement ps = null;
  30.         ResultSet rs = null;
  31.         String sql = "select * from c##EMP where empName = ? and password = ?";
  32.         try {
  33.             ps = con.prepareStatement(sql);
  34.             ps.setString(1,userName);
  35.             ps.setString(2,pwd);
  36.             rs = ps.executeQuery();
  37.             if (rs.next()){
  38.                 int empId = rs.getInt("empid");
  39.                 String empName = rs.getString("empname");
  40.                 String password = rs.getString("password");
  41.                 Date birthday = rs.getDate("birthday");
  42.                 System.out.println("编号："+empId+" 姓名："+empName+" 密码："+password+" 日期："+birthday);
  43.             }
  44.         } catch (SQLException throwables) {
  45.             throwables.printStackTrace();
  46.         }finally {
  47.             OracleUtils.close(con,ps,rs);
  48.         }
  49.         return null;
  50.     }
  51. ​
  52.     //删除
  53.     public Integer delEmp(Integer id){
  54.         Connection con = OracleUtils.getConnection();
  55.         PreparedStatement ps = null;
  56.         Integer rs = null;
  57.         String sql = "delete from c##EMP where empId = ?";
  58.         try {
  59.             ps = con.prepareStatement(sql);
  60.             ps.setInt(1,id);
  61.             rs = ps.executeUpdate();
  62.             if (rs > 0){
  63.                 System.out.println("删除成功");
  64.             }else {
  65.                 System.out.println("删除失败");
  66.             }
  67.         } catch (SQLException throwables) {
  68.             throwables.printStackTrace();
  69.         }finally {
  70.             OracleUtils.close(con,ps,null);
  71.         }
  72.         return 0;
  73.     }
  74.     //添加
  75.     public Integer addEmp(Emp emp){
  76.         Connection con = OracleUtils.getConnection();
  77.         PreparedStatement ps = null;
  78.         Integer rs = null;
  79.         String sql = "insert into c##EMP values(?,?,?,to_date(?,'yyyy-mm-dd'))";
  80.         try {
  81.             ps = con.prepareStatement(sql);
  82.             ps.setInt(1,emp.getEmpId());
  83.             ps.setString(2,emp.getEmpName());
  84.             ps.setString(3,emp.getPassword());
  85.             java.util.Date date = new java.util.Date(String.valueOf(emp.getBirthday()));
  86.             SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
  87.             String time = format.format(date);
  88.             ps.setString(4,time);
  89.             int rows = ps.executeUpdate();
  90.             if (rows > 0){
  91.                 System.out.println("添加成功");
  92.             }else {
  93.                 System.out.println("添加失败");
  94.             }
  95.         } catch (SQLException throwables) {
  96.             throwables.printStackTrace();
  97.         }finally {
  98.             OracleUtils.close(con,ps,null);
  99.         }
  100.         return 0;
  101.     }
  102. ​
  103.     //修改
  104.     public Integer updateEmp(Emp emp){
  105.         Connection con = OracleUtils.getConnection();
  106.         PreparedStatement ps = null;
  107.         Integer rs = null;
  108.         String sql = "update c##EMP set empname = ?,password = ?,birthday = to_date(?,'yyyy-mm-dd') where empId = ?";
  109.         try {
  110.             ps = con.prepareStatement(sql);
  111.             ps.setString(1,emp.getEmpName());
  112.             ps.setString(2,emp.getPassword());
  113.             java.util.Date date = new java.util.Date(String.valueOf(emp.getBirthday()));
  114.             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  115.             String time = dateFormat.format(date);
  116.             ps.setString(3,time);
  117.             ps.setInt(4,emp.getEmpId());
  118.             int rows = ps.executeUpdate();
  119.             if (rows > 0){
  120.                 System.out.println("修改成功");
  121.             }else {
  122.                 System.out.println("修改失败");
  123.             }
  124.         } catch (SQLException throwables) {
  125.             throwables.printStackTrace();
  126.         }finally {
  127.             OracleUtils.close(con,ps,null);
  128.         }
  129.         return 0;
  130.     }
  131. }
新建测试类测试：
  1. public class OracleTest {
  2.     public static void main(String[] args) {
  3.             //getEmpByNameAndPwd("孙道恩","111");
  4.            // deleteEmpById(2);
  5.        // getEmpList();
  6.         SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  7.         Date date = null;
  8. //        try {
  9. //             date = dateFormat.parse("2012-09-12");
  10. //        } catch (ParseException e) {
  11. //            e.printStackTrace();
  12. //        }
  13. //        Emp emp = new Emp(5, "理想玩", "23df3", date);
  14. //        addEmp(emp);
  15.         try {
  16.           date = dateFormat.parse("2002-02-04");
  17.         } catch (ParseException e) {
  18.             e.printStackTrace();
  19.         }
  20.         Emp emp = new Emp(5, "普罗理想国", "88888888", date);
  21.         updateEmp(emp);
  22.     }
  23. ​
  24.     //查询全部
  25.     public static void   getEmpList(){
  26.         OracleDao oracleDao = new OracleDao();
  27.         List<Emp> empList = oracleDao.getEmpList();
  28.     }
  29.     //根据名字和密码查询
  30.     public static  void  getEmpByNameAndPwd(String name,String pwd){
  31.         OracleDao oracleDao = new OracleDao();
  32.         oracleDao.getEmpByNameAndPwd(name, pwd);
  33.     }
  34.     //根据id删除
  35.     public static void deleteEmpById(Integer id){
  36.         OracleDao oracleDao = new OracleDao();
  37.         oracleDao.delEmp(id);
  38.     }
  39.     //插入数据
  40.     public static void  addEmp(Emp emp){
  41.         OracleDao oracleDao = new OracleDao();
  42.         oracleDao.addEmp(emp);
  43.     }
  44.     //修改
  45.     public static void updateEmp(Emp emp){
  46.         OracleDao oracleDao = new OracleDao();
  47.         oracleDao.updateEmp(emp);
  48.     }
  49. }

jdbc连接MySQL数据库：

创建一个mysqlUtils类连接数据库：
  1. public class MysqlUtils {
  2.     public static Connection con = null;
  3.     public static Statement state = null;
  4.     public static ResultSet rs = null;
  5. ​
  6.     static {
  7.         try {
  8.             Class.forName("com.mysql.cj.jdbc.Driver");
  9.         } catch (ClassNotFoundException e) {
  10.             e.printStackTrace();
  11.         }
  12.     }
  13. ​
  14.     //连接数据库
  15.     public static Connection getCon() {
  16.         String url = "jdbc:mysql://localhost:3306/meitao?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=false";
  17.         String username = "root";
  18.         String pwd = "root";
  19.         try {
  20.             con = DriverManager.getConnection(url, username, pwd);
  21.         } catch (SQLException throwables) {
  22.             throwables.printStackTrace();
  23.         }
  24.         System.out.println("连接成功");
  25.         return con;
  26.     }
  27. ​
  28.     //关闭连接
  29.     public static void close(Connection con,Statement state,ResultSet rs){
  30.         try {
  31.             if (rs != null){
  32.                 rs.close();
  33.             }
  34.             if (state != null){
  35.                 state.close();
  36.             }
  37.             if (con != null){
  38.                 con.close();;
  39.             }
  40.         }catch (Exception e){
  41.             e.printStackTrace();
  42.         }
  43.     }
  44. }
编写mysqlDao层完成增删改查的案例：
  1. public class MysqlAdminDao {
  2.     //查询全部
  3.     public  List<Admins> getAdminList(){
  4.         Connection con = MysqlUtils.getCon();
  5.         PreparedStatement ps = null;
  6.         ResultSet rs = null;
  7.         String sql = "select * from admins";
  8.         try {
  9.             ps = con.prepareStatement(sql);
  10.             ResultSet resultSet = ps.executeQuery();
  11.             while (resultSet.next()){
  12.                 int adminId = resultSet.getInt("adminId");
  13.                 String adminName = resultSet.getString("adminName");
  14.                 String pwd = resultSet.getString("pwd");
  15.                 Date birthday = resultSet.getDate("birthday");
  16.                 System.out.println("编号："+adminId+" 姓名："+adminName+" 密码："+pwd+"生日："+birthday);
  17.             }
  18.         } catch (SQLException throwables) {
  19.             throwables.printStackTrace();
  20.         }finally {
  21.             MysqlUtils.close(con,ps,rs);
  22.         }
  23.         return null;
  24.     }
  25. ​
  26.     //根据name和密码查询
  27.     public Admins getAdminsByIdAndName(String name,String pwd){
  28.         Connection con = MysqlUtils.getCon();
  29.         PreparedStatement ps= null;
  30.         ResultSet rs = null;
  31.         String sql = "select * from admins where adminname = ? and pwd = ?";
  32.         try {
  33.             ps = con.prepareStatement(sql);
  34.             ps.setString(1,name);
  35.             ps.setString(2,pwd);
  36.             ResultSet set = ps.executeQuery();
  37.             while (set.next()){
  38.                 int adminId = set.getInt("adminId");
  39.                 String adminName = set.getString("adminName");
  40.                 String password = set.getString("pwd");
  41.                 Date birthday = set.getDate("birthday");
  42.                 System.out.println("编号："+adminId+" 姓名："+adminName+" 密码："+password+"生日："+birthday);
  43.             }
  44.         } catch (SQLException throwables) {
  45.             throwables.printStackTrace();
  46.         }finally {
  47.             MysqlUtils.close(con,ps,rs);
  48.         }
  49.         return null;
  50.     }
  51. ​
  52.     //根据id删除
  53.     public Integer delAdminById(Integer id){
  54.         Connection con = MysqlUtils.getCon();
  55.         PreparedStatement ps = null;
  56.         ResultSet rs = null;
  57.         String sql = "delete from admins where adminid = ?";
  58.         try {
  59.             ps = con.prepareStatement(sql);
  60.             ps.setInt(1,id);
  61.             int rows = ps.executeUpdate();
  62.             if (rows > 0){
  63.                 System.out.println("删除成功");
  64.             }else {
  65.                 System.out.println("删除失败");
  66.             }
  67.         } catch (SQLException throwables) {
  68.             throwables.printStackTrace();
  69.         }finally {
  70.             MysqlUtils.close(con,ps,rs);
  71.         }
  72.         return 0;
  73.     }
  74. ​
  75.     //添加数据
  76.     public Integer addAdmins(Admins admins){
  77.             Connection con = MysqlUtils.getCon();
  78.             PreparedStatement ps = null;
  79.             ResultSet rs = null;
  80.             String sql = "insert into admins values(?,?,?,?)";
  81.         try {
  82.             ps = con.prepareStatement(sql);
  83.             ps.setInt(1,admins.getAdminId());
  84.             ps.setString(2,admins.getAdminName());
  85.             ps.setString(3,admins.getPwd());
  86.             java.util.Date date = new java.util.Date(String.valueOf(admins.getBirthday()));
  87.             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  88.             String time = dateFormat.format(date);
  89.             ps.setString(4,time);
  90.             int rows = ps.executeUpdate();
  91.             if (rows > 0){
  92.                 System.out.println("添加成功");
  93.             }else {
  94.                 System.out.println("添加失败");
  95.             }
  96.         } catch (SQLException throwables) {
  97.             throwables.printStackTrace();
  98.         }finally {
  99.             MysqlUtils.close(con,ps,null);
  100.         }
  101.         return 0;
  102.     }
  103. ​
  104.     //修改数据
  105.     public Integer updateAdmins(Admins admins){
  106.         Connection con = MysqlUtils.getCon();
  107.         PreparedStatement ps = null;
  108.         ResultSet rs = null;
  109.         String sql = "update admins set adminname = ?,pwd = ?,birthday = ? where adminid = ?";
  110.         try {
  111.             ps = con.prepareStatement(sql);
  112.             ps.setString(1,admins.getAdminName());
  113.             ps.setString(2,admins.getPwd());
  114.             java.util.Date date = new java.util.Date(String.valueOf(admins.getBirthday()));
  115.             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  116.             String time = dateFormat.format(date);
  117.             ps.setString(3,time);
  118.             ps.setInt(4,admins.getAdminId());
  119.             int rows = ps.executeUpdate();
  120.             if (rows > 0){
  121.                 System.out.println("修改成功");
  122.             }else {
  123.                 System.out.println("修改失败");
  124.             }
  125.         } catch (SQLException throwables) {
  126.             throwables.printStackTrace();
  127.         }finally {
  128.             MysqlUtils.close(con,ps,null);
  129.         }
  130.         return 0;
  131.     }
  132. }
新建测试类进行测试：
  1. public class MysqlTest {
  2.     public static void main(String[] args) {
  3.       //  getList();
  4.       //  getAdminsByNameAndPwd("孙道恩","666");
  5.       //  deleteById(3);
  6.         SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  7.         Date date = null;
  8.         try {
  9.              date = dateFormat.parse("2015-02-04");
  10.         } catch (ParseException e) {
  11.             e.printStackTrace();
  12.         }
  13.         Admins admins = new Admins(3,"小金刚","sfd434",date);
  14.         //addAdmins(admins);
  15.         updateAdmins(admins);
  16.     }
  17.     //查找全部
  18.     public static void getList(){
  19.         MysqlAdminDao mysqlAdminDao = new MysqlAdminDao();
  20.         mysqlAdminDao.getAdminList();
  21.     }
  22.     //感觉name和pwd查找
  23.     public static void getAdminsByNameAndPwd(String name,String pwd){
  24.         MysqlAdminDao mysqlAdminDao = new MysqlAdminDao();
  25.         mysqlAdminDao.getAdminsByIdAndName(name, pwd);
  26.     }
  27.     //单个删除
  28.     public static void deleteById(Integer id){
  29.         MysqlAdminDao mysqlAdminDao = new MysqlAdminDao();
  30.         mysqlAdminDao.delAdminById(id);
  31.     }
  32.     //添加数据
  33.     public static void addAdmins(Admins admins){
  34.         MysqlAdminDao mysqlAdminDao = new MysqlAdminDao();
  35.         mysqlAdminDao.addAdmins(admins);
  36.     }
  37. ​
  38.     //修改数据
  39.     public static void updateAdmins(Admins admins){
  40.         MysqlAdminDao mysqlAdminDao = new MysqlAdminDao();
  41.         mysqlAdminDao.updateAdmins(admins);
  42.     }
  43. }

手写分页：

PagerUtil类：
  1. /**
  2.  * 分页Bean
  3.  *
  4.  * @author sde
  5.  */
  6. public class PagerUtil {
  7. ​
  8.     /**
  9.      * 当前页码数
  10.      */
  11.     private int currentPage = 1;
  12. ​
  13.     /**
  14.      * 每页显示记录条数, 默认为 2
  15.      */
  16.     private int sizePerPage = 2;
  17. ​
  18.     /**
  19.      * 总页数
  20.      */
  21.     private int totalPage;
  22. ​
  23.     /**
  24.      * 需要分页的长字符串
  25.      */
  26.     @SuppressWarnings("unchecked")
  27.     private List topicSelect;
  28. ​
  29.     public PagerUtil() {
  30.     }
  31. ​
  32.     /**
  33.      * 返回当前页的文本
  34.      *
  35.      * @return
  36.      */
  37.     @SuppressWarnings("unchecked")
  38.     public List getCurrentPagedText() {
  39.         try {
  40.             if (getCurrentPage() < getTotalPage()) {
  41.                 return getTopicSelect().subList(
  42.                         (getCurrentPage() - 1) * getSizePerPage(), getCurrentPage() * getSizePerPage());
  43.             } else if (getTotalPage() > 0) {
  44.                 return getTopicSelect().subList((getCurrentPage() - 1) * getSizePerPage(), getTopicSelect().size());
  45.             }
  46.         } catch (Exception e) {
  47.             e.printStackTrace();
  48.         }
  49.         return null;
  50.     }
  51. ​
  52.     /**
  53.      * @return Returns the 当前页码数.
  54.      */
  55.     public int getCurrentPage() {
  56.         if (currentPage <= 0)
  57.             currentPage = 1;
  58.         return currentPage;
  59.     }
  60. ​
  61.     /**
  62.      * 设置当前页码, 从 1 开始.
  63.      *
  64.      * @param currentPage The 当前页码数 to set.
  65.      */
  66.     public void setCurrentPage(int currentPage) {
  67.         if (currentPage <= 0) {
  68.             currentPage = 1;
  69.         }
  70.         this.currentPage = currentPage;
  71.     }
  72. ​
  73.     /**
  74.      * @return Returns the 总页码数, 如果没有数据, 就返回 1.
  75.      */
  76.     public int getTotalPage() {
  77.         if (getTopicSelect() == null)
  78.             totalPage = 0;
  79.         totalPage = (int) Math.ceil(1.0 * getTopicSelect().size()
  80.                 / getSizePerPage()); // 总页面数
  81. ​
  82.         if (totalPage == 0)
  83.             totalPage = 1;
  84.         return totalPage;
  85.     }
  86. ​
  87.     /**
  88.      * @param totalPage The totalPage to set.
  89.      */
  90.     public void setTotalPage(int totalPage) {
  91.         this.totalPage = totalPage;
  92.     }
  93. ​
  94.     /**
  95.      * @return Returns the 每页显示行数.
  96.      */
  97.     public int getSizePerPage() {
  98.         return sizePerPage;
  99.     }
  100. ​
  101.     /**
  102.      * @param sizePerPage The 每页显示行数to set.
  103.      */
  104.     public void setSizePerPage(int sizePerPage) {
  105.         this.sizePerPage = sizePerPage;
  106.     }
  107. ​
  108.     /**
  109.      * @return Returns the 需要分页的文本.
  110.      */
  111.     @SuppressWarnings("unchecked")
  112.     public List getTopicSelect() {
  113.         return topicSelect;
  114.     }
  115. ​
  116.     @SuppressWarnings("unchecked")
  117.     public void setTopicSelect(List topicSelect) {
  118.         this.topicSelect = topicSelect;
  119.     }
  120. }
servlet：
  1. case "pageList":
  2.                 //当前是第几页
  3.                 int currentPage = 1;
  4.                 //判断当前页码是否为空
  5.                 if (req.getParameter("currentPage") != null){
  6.                     //不为空在页面中用户在请求分页
  7.                     currentPage = Integer.parseInt(req.getParameter("currentPage"));
  8.                 }
  9.                     //一共多少页
  10.                     int maxPage;
  11.                     List<Employss> list = employeesService.getList();
  12.                 System.out.println(list);
  13.                     //创建分页对象
  14.                     PagerUtil pager = new PagerUtil();
  15.                     //需要分页的文本
  16.                     pager.setTopicSelect(list);
  17.                     //设置每行显示的行数
  18.                     pager.setSizePerPage(3);
  19.                     //获取最大页数
  20.                     maxPage = pager.getTotalPage();
  21.                     //获取当前页
  22.                     pager.setCurrentPage(currentPage);
  23.                     //存值
  24.                 System.out.println(pager.toString());
  25.                     req.setAttribute("lists",pager);
  26.                     req.getRequestDispatcher("list.jsp").forward(req,resp);
  27. ​
  28.                 break;
前端展示和分页查询：
  1. <c:forEach var="user" items="${lists.currentPagedText}">
  2.             <tr>
  3.                 <td>${user.empId}</td>
  4.                 <td>${user.empName}</td>
  5.                 <td>${user.birthday}</td>
  6.                 <td>${user.address}</td>
  7.                 <td>${user.tel}</td>
  8.                 <td>${user.deptName}</td>
  9.                 <td onclick="delById(${user.empId})" style="cursor: pointer">删除</td>
  10.                 <td style="cursor: pointer" onclick="updateById(${user.empId})">修改</td>
  11.             </tr>
  12.         </c:forEach>
  13.             
  14.             
  15. <c:if test="${lists.currentPage==1}">
  16.         <c:out value="首页 上一页"></c:out>
  17.     </c:if>
  18. ​
  19.     <c:if test="${lists.currentPage != 1}">
  20.         <a href="loginServlet?method=pageList2&currentPage = 1">首页</a>
  21.         <a href="loginServlet?method=pageList2&currentPage=${lists.currentPage - 1}">上一页</a>
  22.     </c:if>
  23. ​
  24.     <c:if test="${lists.currentPage==lists.totalPage}">
  25.         <c:out value="下一页 尾页"></c:out>
  26.     </c:if>
  27. ​
  28.     <c:if test="${lists.currentPage != lists.totalPage}">
  29.         <a href="loginServlet?method=pageList2&currentPage=${lists.currentPage + 1}">下一页</a>
  30.         <a href="loginServlet?method=pageList2&currentPage=${lists.totalPage}">末页</a>
  31.     </c:if>
  32.     <span>每页显示 ${lists.sizePerPage} 条</span>
  33.     <span>第 ${lists.currentPage} 页</span>
  34.     <span>共 ${lists.totalPage} 页</span>            

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号