JDBC 学习笔记(一)—— 基础知识 + 分页技术

本文目录:

      1、JDBC简介

      2、使用JDBC的步骤——第一个JDBC程序

      3、DriverManager ——加载数据库驱动

      4、数据库URL ——标识数据库的位置

      5、Connection ——代表数据库的链接

      6、Statement  ——向数据库发送SQL语句

      7、ResultSet  ——代表Sql语句的执行结果

      8、释放资源 ——释放与数据库进行交互的对象

      9、用JDBC对数据库进行CRUD 

      10、CRUD操作-create 示例Demo

      11、CRUD操作-updata 示例Demo

      12、CRUD操作-delete 示例Demo

      13、CRUD操作-read 示例Demo

      14、SQL 注入的防范

      15、PreparedStatement

      16、数据库分页——实现语句

      17、数据库分页—— 采用Dao工厂模式实现数据库分页原理图解

      18、数据库分页——执行流程中所需的类及代码

      19、数据库分页——QueryInfo类、PageBean类、QueryResult类 三个辅助类的内容

1、JDBC简介

    SUN公司为了简化、统一对数据库的操作,定义了一套Java操作数据库的规范,称之为JDBC。JDBC全称为:Java Data Base Connectivity(java数据库连接),它主要由接口组成。

    组成JDBC的2个包:java.sql、javax.sql

    开发JDBC应用需要以上2个包的支持外,还需要导入相应JDBC的数据库实现(即数据库驱动)。

JDBC 学习笔记(一)—— 基础知识 + 分页技术

2、使用JDBC的步骤——第一个JDBC程序

    需求:编程从user表中读取数据,并打印在命令行窗口中。

     (1) 搭建实验环境 :

         a、在mysql中创建一个库,并创建user表t同时插入数据到表中。

         b、新建一个Java工程,并导入数据库驱动。

    (2) 编写程序,在程序中加载数据库驱动

         a、方式一:DriverManager. registerDriver(Driver driver)

         b、方式二:Class.forName(“com.mysql.jdbc.Driver”);

    (3) 建立连接(Connection)

         Connection conn = DriverManager.getConnection(url,user,pass);

    (4) 创建用于向数据库发送SQL的Statement对象,并发送sql

         Statement st = conn.createStatement();

         ResultSet rs = st.excuteQuery(sql);

    (5) 从代表结果集的ResultSet中取出数据,打印到命令行窗口

    (6) 断开与数据库的连接,并释放相关资源

Demo样例:

JDBC 学习笔记(一)—— 基础知识 + 分页技术
 1 public static void main(String[] args) throws SQLException {
 2     String url = "jdbc:mysql://localhost:3306/day14";
 3     String username = "root";
 4     String password = "root";
 5     //1.加载驱动
 6     DriverManager.registerDriver(new com.mysql.jdbc.Driver()); 
 7     //2。获取链接
 8     Connection conn = DriverManager.getConnection(url, username, password); 
 9     //3.获取向数据库发sql语句的statament对象
10      Statement st = conn.createStatement(); 
11     //4.向数据库发送sql,获取数据库返回的结果集
12     ResultSet rs = st.executeQuery("select * from users"); 
13     //5.从结果集中获取数据
14     while(rs.next()){
15       System.out.println("id=" + rs.getObject("id"));
16       System.out.println("name=" + rs.getObject("name"));
17       System.out.println("password=" + rs.getObject("password"));
18       System.out.println("email=" + rs.getObject("email"));
19       System.out.println("birthday=" + rs.getObject("birthday"));
20     } 
21     //6.释放资源(释放链接)
22     rs.close();
23     st.close();
24     conn.close();
25   }
JDBC 学习笔记(一)—— 基础知识 + 分页技术

3、DriverManager ——加载数据库驱动

    Jdbc程序中的DriverManager用于加载驱动,并创建与数据库的链接,这个API的常用方法:

    DriverManager.registerDriver(new Driver())

    DriverManager.getConnection(url, user, password), 

    注意:在实际开发中并不推荐采用registerDriver方法注册驱动。原因有二:

      一、查看Driver的源代码可以看到,如果采用此种方式,会导致驱动程序注册两次,也就是在内存中会有两个Driver对象。

      二、程序依赖mysql的api,脱离mysql的jar包,程序将无法编译,将来程序切换底层数据库将会非常麻烦。 

     推荐方式:Class.forName(“com.mysql.jdbc.Driver”);

      采用此种方式不会导致驱动对象在内存中重复出现,并且采用此种方式,程序仅仅只需要一个字符串,不需要依赖具体的驱动,使程序的灵活性更高。   

      同样,在开发中也不建议采用具体的驱动类型指向getConnection方法返回的connection对象。

Demo:数据库JDBC开发使用的模版(Statement对象。):

JDBC 学习笔记(一)—— 基础知识 + 分页技术
 1     String url = "jdbc:mysql:///day14";
 2     String username = "root";
 3     String password = "root";
 4 
 5     Connection conn = null;
 6     Statement st = null;
 7     ResultSet rs  = null;
 8 
 9     try{
10           Class.forName("com.mysql.jdbc.Driver");
11           conn = DriverManager.getConnection(url, username, password);
12           st = conn.createStatement();  //throw  
13 
14           CRUD操作……
15 
16     }finally{
17           if(rs!=null){
18                 try{
19                       rs.close();   //throw new 
20                 }catch (Exception e) {
21 
22                       e.printStackTrace();
23                 }
24                 rs = null;
25           }
26           if(st!=null){
27                 try{
28                        st.close();
29                 }catch (Exception e) {
30                       e.printStackTrace();
31                 }
32                 st = null;
33           }
34           if(conn!=null){
35                 try{
36                       conn.close();
37                 }catch (Exception e) {
38                       e.printStackTrace();
39                 }
40           }     
41     }
JDBC 学习笔记(一)—— 基础知识 + 分页技术

4、数据库URL ——标识数据库的位置

    URL用于标识数据库的位置,程序员通过URL地址告诉JDBC程序连接哪个数据库,MySql 数据库的URL写法为: jdbc:mysql:[]//localhost:3306/test ?参数名:参数值

  URL图解

JDBC 学习笔记(一)—— 基础知识 + 分页技术

  常用数据库URL地址的写法:

        Oracle写法:jdbc:oracle:thin:@localhost:1521:sid

        SqlServer—jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid

        MySql—jdbc:mysql://localhost:3306/sid

        Mysql的url地址的简写形式: jdbc:mysql:///sid

        常用属性:useUnicode=true&characterEncoding=UTF-8

5、Connection ——代表数据库的链接

    Jdbc程序中的Connection,它用于代表数据库的链接。Connection 是数据库编程中最重要的一个对象,客户端与数据库所有交互都是通过Connection 对象完成的,这个对象的常用方法:

        (1) createStatement():创建向数据库发送sql的statement对象。

        (2) prepareStatement(sql) :创建向数据库发送预编译sql的PrepareSatement对象。

        (3) prepareCall(sql):创建执行存储过程的callableStatement对象。

        (4) setAutoCommit(boolean autoCommit):设置事务是否自动提交。

        (5) commit() :在链接上提交事务。

        (6) rollback() :在此链接上回滚事务。

6、Statement  ——向数据库发送SQL语句

    Jdbc程序中的Statement对象用于向数据库发送SQL语句, Statement对象常用方法:

        (1) executeQuery(String sql) :用于向数据库发送查询语句。

        (2) executeUpdate(String sql):用于向数据库发送insert、update或delete语句

        (3) execute(String sql):用于向数据库发送任意sql语句

        (4) addBatch(String sql) :把多条sql语句放到一个批处理中。

        (5) executeBatch():向数据库发送一批sql语句执行。

        (6) clearBatch() :清空此 Statement 对象的当前 SQL 命令列表。

7、ResultSet  ——代表Sql语句的执行结果

  Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时,采用的类似于表格的方式。 ResultSet 对象维护了一个指向表格数据行的游标,初始的时候,游标在第一行之前,调用ResultSet.next() 方法,可以使游标指向具体的数据行,进行调用方法获取该行的数据。

    (1) ResultSet提供了对结果集进行滚动的方法:

            a、next():移动到下一行

            b、Previous():移动到前一行

            c、absolute(int row):移动到指定行

            d、beforeFirst():移动resultSet的最前面。

            e、 afterLast() :移动到resultSet的最后面。

    (2) ResultSet既然用于封装执行结果的,所以该对象提供了用于获取数据的get方法:

       获取任意类型的数据

                getObject(int index)

                getObject(string columnName)

        获取指定类型的数据,例如:

                getString(int index)

                getString(String columnName)

                其他获取指定类型数据的方法见下表:

常用数据类型转换表:

JDBC 学习笔记(一)—— 基础知识 + 分页技术

8、释放资源 ——释放与数据库进行交互的对象 

        Jdbc程序运行完后,切记要释放程序在运行过程中,创建的那些与数据库进行交互的对象,这些对象通常是ResultSet, Statement和Connection对象。 

        特别是Connection对象,它是非常稀有的资源,用完后必须马上释放,如果Connection不能及时、正确的关闭,极易导致系统宕机。Connection的使用原则是尽量晚创建,尽量早的释放。

        为确保资源释放代码能运行,资源释放代码也一定要放在finally语句中。

9、用JDBC对数据库进行CRUD 

        Jdbc中的statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需要通过这个对象向数据库发送增删改查语句即可。 

        Statement对象的executeUpdate方法,用于向数据库发送增、删、改的sql语句,executeUpdate执行完后,将会返回一个int整数(即增删改语句导致了数据库几行数据发生了变化)。 

        Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象。  

10、CRUD操作-create 示例Demo

    使用executeUpdate(String sql)方法完成数据添加操作,示例操作:

             Class.forName("com.mysql.jdbc.Driver");

             conn = DriverManager.getConnection(url, username, password);

             Statement st = conn.createStatement();

             String sql = "insert into user(….) values(…..) ";  

             int num = st.executeUpdate(sql);

             if(num>0){

                   System.out.println("插入成功!!!");

             } 

11、CRUD操作-updata 示例Demo

    使用executeUpdate(String sql)方法完成数据修改操作,示例操作:

             Class.forName("com.mysql.jdbc.Driver");

             conn = DriverManager.getConnection(url, username, password);

             Statement st = conn.createStatement();     

             String sql = “update user set name=‘ ’ where name=‘ ’  ";     

             int num = st.executeUpdate(sql);     

             if(num>0){

                   System.out.println(“修改成功!!!");

             } 

12、CRUD操作-delete 示例Demo

    使用executeUpdate(String sql)方法完成数据删除操作,示例操作: 

             Class.forName("com.mysql.jdbc.Driver");

             conn = DriverManager.getConnection(url, username, password);

             Statement st = conn.createStatement(); 

             String sql = "delete from user where id=1"; 

             int num = st.executeUpdate(sql); 

             if(num>0){

                   System.out.println(“删除成功!!!");

             }

13、CRUD操作-read 示例Demo

    使用executeQuery(String sql)方法完成数据查询操作,示例操作: 

             Class.forName("com.mysql.jdbc.Driver");

             conn = DriverManager.getConnection(url, username, password);

             Statement st = conn.createStatement();

             String sql = “select * from user where id=1 “; 

             ResultSet rs = st.executeUpdate(sql); 

             while(rs.next()){

                   //根据获取列的数据类型,分别调用rs的相应方法

                   //映射到java对象中

             } 

14、SQL 注入的防范

    SQL 注入是用户利用某些系统没有对输入数据进行充分的检查,从而进行恶意破坏的行为。

        1、statement存在sql注入攻击问题,例如登陆用户名采用‘ or 1=1 or username=‘

        2、对于防范 SQL 注入,可以采用PreparedStatement取代Statement。

    备注:本例只是最基本的防止SQL注入方式,其他情况还请查阅资料。

15、PreparedStatement

    PreperedStatement是Statement的孩子,它的实例对象可以通过调用Connection.preparedStatement()方法获得,相对于Statement对象而言的优势:

    (1) 防止SQL注入:PreperedStatement可以避免SQL注入的问题。

    (2) 预编译SQL语句:Statement会使数据库频繁编译SQL,可能造成数据库缓冲区溢出。PreparedStatement 可对SQL进行预编译,从而提高数据库的执行效率。

    (3) 使用占位符简化语句:并且PreperedStatement对于sql中的参数,允许使用占位符的形式进行替换,简化sql语句的编写。 (例如多次循环插入数据)

 Demo样例:

JDBC 学习笔记(一)—— 基础知识 + 分页技术
 1 public List<Customer> getAll(){
 2         Connection conn = null;
 3         PreparedStatement st = null;
 4         ResultSet rs = null;
 5         try{
 6               conn = JdbcUtils.getConnection();
 7               String sql = "select * from customer";
 8               st = conn.prepareStatement(sql);
 9               rs = st.executeQuery();
10               List list = new ArrayList();
11               while(rs.next()){
12                     Customer c = new Customer();
13                     c.setBirthday(rs.getDate("birthday"));
14                     c.setCellphone(rs.getString("cellphone"));
15                     c.setDescription(rs.getString("description"));
16                     c.setEmail(rs.getString("email"));
17                     c.setGender(rs.getString("gender"));
18                     c.setId(rs.getString("id"));
19                     c.setName(rs.getString("name"));
20                     c.setPreference(rs.getString("preference"));
21                     c.setType(rs.getString("type"));
22                     list.add(c);
23               }
24               return list;
25         }catch (Exception e) {
26               throw new DaoException(e);
27         }finally{
28               JdbcUtils.release(conn, st, rs);
29         }
30   }
JDBC 学习笔记(一)—— 基础知识 + 分页技术

16、数据库分页——实现语句

    (1) MySQL分页

        MySQL分页的实现语句:

            Select * from table limit M,N

        M:记录开始索引位置

        N:取多少条记录。 

        完成WEB页面的分页显示的步骤:

            (a) 先获得需分页显示的记录总数,然后在web页面中显示页码。

            (b) 根据页码,从数据库中查询相应的记录显示在web页面中。

        以上两项操作通常使用Page对象进行封装。

    (2) Oracle分页 

        Oracle分页的实现语句: 

            select * from (

                 select rownum r_, row_.*  from (

                     select * from student order by id

                 ) row_ where rownum <=5

                      ) where r_>=1 

        1位置:起始索引位置。

        5位置:结束索引位置。

     备注:关于Oracle的分页,此处仅是简单讲解,会在Oracle 专题博文中详述。

17、数据库分页—— 采用Dao工厂模式实现数据库分页原理图解

    (1) dao工厂模式的原理示意图

JDBC 学习笔记(一)—— 基础知识 + 分页技术

  (2) 数据库分页 原理图解 

JDBC 学习笔记(一)—— 基础知识 + 分页技术

18、数据库分页——执行流程中所需的类及代码

 (1)Servlet层:ListCustomerServlet .java

JDBC 学习笔记(一)—— 基础知识 + 分页技术
         //处理用户分页请求
        public class ListCustomerServlet extends HttpServlet { 
             public void doGet(HttpServletRequest request, HttpServletResponse response)
                 throws ServletException, IOException { 
                       try{
                            QueryInfo info = WebUtils.request2Bean(request, QueryInfo.class);  
                            BusinessService service = new BusinessServiceImpl(); 
                            PageBean pagebean = service.pageQuery(info);
                            request.setAttribute("pagebean", pagebean);
                            request.getRequestDispatcher("/WEB-INF/jsp/listcustomer.jsp").forward(request, response);13 
                      }catch (Exception e) {
                            e.printStackTrace();
                            request.setAttribute("message", "查看客户失败!!"); 
                 request.getRequestDispatcher("/message.jsp").forward(request, response);
                       }
              }
              public void doPost(HttpServletRequest request, HttpServletResponse response)
                 throws ServletException, IOException {
                         doGet(request, response);
              } 
         }     
JDBC 学习笔记(一)—— 基础知识 + 分页技术

(2) Service层:BusinessServiceImpl.java

JDBC 学习笔记(一)—— 基础知识 + 分页技术
   public class BusinessServiceImpl implements BusinessService {
            public PageBean pageQuery(QueryInfo queryInfo){ 
                        //调用dao获取到页面数据
                        QueryResult qr = dao.pageQuery(queryInfo.getStartindex(), queryInfo.getPagesize()); 
                        //根据dao查询结果,生成页面显示需要pagebean
                        PageBean bean = new PageBean();                 
           bean.setCurrentpage(queryInfo.getCurrentpage()); bean.setList(qr.getList()); bean.setPagesize(queryInfo.getPagesize()); bean.setTotalrecord(qr.getTotalrecord());
return bean; } }
JDBC 学习笔记(一)—— 基础知识 + 分页技术

 (3)Dao层:CustomerDaoImpl.java   

JDBC 学习笔记(一)—— 基础知识 + 分页技术
public class CustomerDaoImpl implements CustomerDao {
        //获取到页面数据和页面大小
          public QueryResult pageQuery(int startindex,int pagesize){        
                    Connection conn = null;
                    PreparedStatement st = null;
                    ResultSet rs = null;
                    QueryResult qr = new QueryResult();
                    try{
                          conn = JdbcUtils.getConnection();
                          String sql = "select * from customer limit ?,?";
                          st = conn.prepareStatement(sql);
                          st.setInt(1, startindex);
                          st.setInt(2, pagesize);
                          rs = st.executeQuery();
                          List list = new ArrayList();
                          while(rs.next()){
                                Customer c = new Customer();
                                c.setBirthday(rs.getDate("birthday"));
                                c.setCellphone(rs.getString("cellphone"));
                                c.setDescription(rs.getString("description"));
                                c.setEmail(rs.getString("email"));
                                c.setGender(rs.getString("gender"));
                                c.setId(rs.getString("id"));
                                c.setName(rs.getString("name"));
                                c.setPreference(rs.getString("preference"));
                                c.setType(rs.getString("type"));
                                list.add(c);
                          }
                          qr.setList(list);
                          sql = "select count(*) from customer";
                          st = conn.prepareStatement(sql);
                          rs = st.executeQuery();
                          if(rs.next()){
                                qr.setTotalrecord(rs.getInt(1));
                          }
                          return qr; 
                    }catch (Exception e) {
                          throw new DaoException(e);
                    }finally{
                          JdbcUtils.release(conn, st, rs);
                    }
          }   
}

 
JDBC 学习笔记(一)—— 基础知识 + 分页技术

19、数据库分页——QueryInfo类、PageBean类、QueryResult类 三个辅助类的内容

(1)QueryInfo.java 类中的内容:

JDBC 学习笔记(一)—— 基础知识 + 分页技术
 public class QueryInfo { 
             private int currentpage = 1;  //用户当前看的页
             private int pagesize = 5;     //记住用户想看的页面大小
             private int startindex;     //记住用户看的页的数据在数据库的起始位置 
             public int getCurrentpage() {
                  return currentpage;
             }
             public void setCurrentpage(int currentpage) {
                  this.currentpage = currentpage;
             }
             public int getPagesize() {
                  return pagesize;
             }
             public void setPagesize(int pagesize) {
                  this.pagesize = pagesize;
             }
             public int getStartindex() {
                  this.startindex = (this.currentpage-1)*this.pagesize;
                  return startindex;
             }
    }

 
JDBC 学习笔记(一)—— 基础知识 + 分页技术

(2)PageBean.java  类中的内容:

JDBC 学习笔记(一)—— 基础知识 + 分页技术
        public class PageBean {
          private List list;
          private int totalrecord;
          private int pagesize;
          private int totalpage;
          private int currentpage;
          private int previouspage;
          private int nextpage;
          private int[] pagebar; 

          public List getList() {
            return list;

          }
          public void setList(List list) {
            this.list = list;
          }
          public int getTotalrecord() {
            return totalrecord;

          }
          public void setTotalrecord(int totalrecord) {
            this.totalrecord = totalrecord;
          }
          public int getPagesize() {
            return pagesize;
          }
          public void setPagesize(int pagesize) {
            this.pagesize = pagesize;
          }
          public int getTotalpage() {
            //100   5   20
            //101   5   21
            //99    5   20
            if(this.totalrecord%this.pagesize==0){
              this.totalpage = this.totalrecord/this.pagesize;
            }else{
              this.totalpage = this.totalrecord/this.pagesize+1;
            }         
            return totalpage;
          }         
          public int getCurrentpage() {
            return currentpage;
          }
          public void setCurrentpage(int currentpage) {
            this.currentpage = currentpage;
          }
          public int getPreviouspage() {
            if(this.currentpage-1<1){
              this.previouspage = 1;
            }else{
              this.previouspage = this.currentpage-1;
            }
            return previouspage;
          }
          public int getNextpage() {
            if(this.currentpage+1>=this.totalpage){
              this.nextpage = this.totalpage;
            }else{
              this.nextpage = this.currentpage +1;
            }
            return nextpage;
          }

          public int[] getPagebar() {
                    int startpage;
                    int endpage;
                    int pagebar[] = null;
                    if(this.totalpage<=10){
                          pagebar = new int[this.totalpage];
                          startpage = 1;
                          endpage = this.totalpage;
                    }else{
                              pagebar = new int[10];
                              startpage = this.currentpage - 4;
                              endpage = this.currentpage + 5;
                              //总页数=30      3    -1
                              //总页数=30      29   34   21   30
                              if(startpage<1){
                                    startpage = 1;
                                    endpage = 10;
                              }             
                              if(endpage>this.totalpage){
                                    endpage = this.totalpage;
                                    startpage = this.totalpage - 9;
                              }
                    }
                    int index = 0;
                    for(int i=startpage;i<=endpage;i++){
                              pagebar[index++] = i;
                    }      
                    this.pagebar = pagebar;
                    return this.pagebar;
                    /*int pagebar[] = new int[this.totalpage];
                    for(int i=1;i<=this.totalpage;i++){
                          pagebar[i-1] = i;
                    }
                    this.pagebar = pagebar;
                    return pagebar;*/
              } 
        }
JDBC 学习笔记(一)—— 基础知识 + 分页技术

(3)QueryResult.java  类中的内容: 

JDBC 学习笔记(一)—— 基础知识 + 分页技术
  public class QueryResult { 
              private List list;   //记住用户看的页的数据
              private int totalrecord;    //记往总记录数
              public List getList() {
                    return list;
              }
              public void setList(List list) {
                    this.list = list;
              }
              public int getTotalrecord() {
                    return totalrecord;
              }
              public void setTotalrecord(int totalrecord) {
                    this.totalrecord = totalrecord;
              }
        }  
JDBC 学习笔记(一)—— 基础知识 + 分页技术

JDBC 学习笔记(一)—— 基础知识 + 分页技术

上一篇:微信朋友圈营销方案


下一篇:PS利用图层蒙板制作漂亮的天空之城意境图