zoukankan      html  css  js  c++  java
  • JDBC技术总结(一)

    1. JDBC简介

            SUN公司为了简化、统一对数据库的操作,定义了一套Java操作数据库的规范,称之为JDBC,JDBC不能直接操作数据库,JDBC通过接口加载数据库的驱动,然后操作数据库。JDBC:Java Data Base Connectivity,它主要由接口组成。组成JDBC的2个包为java.sql和javax.sql。开发JDBC应用需要这2个包的支持外,还需要导入相应JDBC的数据库实现(即数据库驱动)。

    2. JDBC快速入门

            编程从user表中读取数据,并打印在控制台窗口中。

    2.1 搭建实验环境

    create database test Character set utf8 collate utf8_general_ci;  
    use test  
    create table user  
    (  
        id int primary Key,  
        name varchar(20),  
        password varchar(20),  
        email varchar(20),  
        birthday Date  
    );  
      
    insert into user(id,name,password,email,birthday) values(1,'zw','123','zw@sina.com','1990-09-19');  
    insert into user(id,name,password,email,birthday) values(2,'ls','123','ls@sina.com','1991-04-19');  
    insert into user(id,name,password,email,birthday) values(3,'ww','123','ww@sina.com','1992-06-19');  

    2.2 编写java程序

            新建一个java工程,并导入数据库驱动 MySQL-connector-java-5.1.20-bin.jar。

    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    import java.util.Date;
    public class Demo1 {
        
        public static void main(String[] args) throws Exception {
            String url="jdbc:mysql://localhost:3306/test";
            String username="root";
            String password="root";
            Connection conn=null;
            Statement st=null;
            ResultSet rs=null;
            
            try{  
                //1.加载驱动  
                //DriverManager.registerDriver(new Driver());  
                Class.forName("com.mysql.jdbc.Driver");  
                  
                //2.获取数据库的连接  
              conn = DriverManager.getConnection(url, username, password);  
                  
                //3.获得用于向数据库发送sql语句的statement对象  
                st = conn.createStatement();  
                  
                //4.向数据库发sql,并获取代表结果集的resultset  
                String sql = "select id,name,password,email,birthday from user";  
                 rs = st.executeQuery(sql);  
                  
                //取出结果集的数据  
                while(rs.next()){  
                    int id = (Integer) rs.getObject("id");  
                    String name = (String)rs.getObject("name");  
                    String pd = (String)rs.getObject("password");  
                    String email = (String)rs.getObject("email");  
                    Date birthday = (Date)rs.getObject("birthday");  
                    System.out.println(id+","+name+","+pd+","+email+","+birthday);  
                }  
            }
            //关闭连接  
            finally{  
                if(rs != null){  
                    try{  
                        rs.close();  
                    }catch(Exception e) {  
                        e.printStackTrace();  
                    }  
                }  
                if(st != null){  
                    try{  
                        st.close();  
                    }catch(Exception e) {  
                        e.printStackTrace();  
                    }  
                }  
                  
                if(conn != null){  
                    try{  
                        conn.close();  
                    }catch(Exception e) {  
                        e.printStackTrace();  
                    }  
                }  
            }  
        }
    }

       JDBC程序中的DriverManager用于加载驱动,并创建与数据库的连接,这个类的常用方法有:

    1. DriverManager.registerDriver(new Driver());  
    2. DriverManager.getConnection(URL, user, password);  

      注意:在实际开发中不推荐采用registerDriver方法注册驱动,原因有二:
            a. 查看Driver的源代码可以看到,如果采用此种方式,会导致驱动程序注册两次,也就是在内存中会有两个Driver对象;
            b. 程序依赖mysql的api,脱离mysql的jar包,程序将无法编译,将来程序切换底层数据库将会非常麻烦。
            推荐方式:Class.forName("com.mysql.jdbc.Driver");
            采用此种方式不会导致驱动对象在内存中重复出现,并且采用此种方式,程序仅仅只需要一个字符串,不需要依赖具体的驱动,使程序的灵活性更高。同样,在开发中也不建议采用具体的驱动类型指向getConnection方法返回的Connection对象。

     

    3. JDBC常用API

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

    1. createStatement();    //创建向数据库发送sql的statement对象  
    2. prepareStatement(sql); //创建向数据库发送预编译sql的prepareStatement对象。这个更常用  
    3. prepareCall(sql); //创建执行存储过程中的callableStatement对象  
    4. setAutoCommit(boolean autoCommit); //设置事物是否自动提交  
    5. commit(); //在链接上提交事物  
    6. rollback(); //在此链接上回滚事物 

      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. executeBath();  //向数据库发送一批sql语句执行  

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

    1. //获取任意类型的数据  
    2. getObject(int index);  //index表示列号  
    3. getObject(String columnName);  //columnName表示列名,建议用这种方法,更好维护  
    4. //获取指定类型的数据(int,String,Date等)  
    5. getString(int index);  
    6. getString(String columnName);  

     ResultSet除了提供get方法以外,还提供了对结果集进行滚动的方法:

    1. next();   //移动到下一行  
    2. previous();  //移动到前一行  
    3. absolute(int row);  //移动到指定行  
    4. beforeFirst();  //移动到resultSet的最前面  
    5. afterLast(); //移动到resultSet的最后面  

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

    4. JDBC实现增删改查

            JDBC技术主要是同数据库打交道,那么免不了增删改查,由上面的代码可以看出,在对数据库进行操作之前需要先建立连接,在操作之后都需要释放资源,所以我们可以把这两部分内容抽取出来,写到JDBCUtils类中来实现:

    public class JDBCUtils {  
          
        private static String driver = null;  
        private static String url = null;  
        private static String username = null;  
        private static String password = null;  
          
        //加载驱动  
        static{  
            try {  
                            //db.properties是一个配置文件,里面有连接数据库所需要的信息  
                InputStream in = JDBCUtils.class.getClassLoader().getResourceAsStream("db.properties");  
                Properties prop = new Properties();   
                prop.load(in);//加载配置文件  
                driver = prop.getProperty("driver");  
                url = prop.getProperty("url");  
                username = prop.getProperty("username");  
                password = prop.getProperty("password");  
                  
                Class.forName(driver);//加载驱动  
                  
            } catch (Exception e) {  
                throw new ExceptionInInitializerError(e);  
            }  
        }  
          
        public static Connection getConnection() throws SQLException{  
                      
            return DriverManager.getConnection(url, username, password);//获得connection  
        }  
          
        public static void release(Connection conn, Statement st, ResultSet rs){ //释放资源  
              
            if(rs != null){  
                try{  
                    rs.close();  
                }catch(Exception e) {  
                    e.printStackTrace();  
                }  
                rs = null;  
            }  
            if(st != null){  
                try{  
                    st.close();  
                }catch(Exception e) {  
                    e.printStackTrace();  
                }  
                st = null;  
            }  
              
            if(conn != null){  
                try{  
                    conn.close();  
                }catch(Exception e) {  
                    e.printStackTrace();  
                }  
                conn = null;  
            }     
        }  
      
    }  

      db.properties文件:

    1. driver=com.mysql.jdbc.Driver  
    2. url=jdbc:mysql://localhost:3306/day14  
    3. username=root  
    4. password=root  

     这样我们就完成了数据库的连接和资源的释放工具类。下面我们开始编写对数据库的增删改查:

    //使用JDBC对数据库的增删改查  
    public class Demo2 {  
          
        private Connection conn = null;  
        private Statement st = null;  
        private ResultSet rs = null;  
          
        @Test  
        public void insert(){  
          
            try {  
                conn = JDBCUtils.getConnection();  
                st = conn.createStatement();  
                String sql = "insert into user(id,name,password,email,birthday) values(3,'ww','123','ww@sina.com','1982-06-14');";  
                int num = st.executeUpdate(sql);//返回的是该sql语句会影响数据库的几行  
                if(num > 0){  
                    System.out.println(num);  
                    System.out.println("插入成功");  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
            }finally {  
                JDBCUtils.release(conn, st, rs);  
            }  
              
        }  
          
        @Test  
        public void delete(){  
                  
            try {  
                conn = JDBCUtils.getConnection();  
                st = conn.createStatement();  
                String sql = "delete from user where password='123'";  
                int num = st.executeUpdate(sql);  
                if(num > 0){  
                    System.out.println(num);  
                    System.out.println("删除成功");  
                }  
            } catch (Exception e) {  
      
                e.printStackTrace();  
            }finally {  
                JDBCUtils.release(conn, st, rs);  
            }  
              
        }  
          
        @Test  
        public void update(){  
                      
            try {  
                conn = JDBCUtils.getConnection();  
                st = conn.createStatement();  
                String sql = "update user set password='456' where name='ww'";  
                int num = st.executeUpdate(sql);  
                if(num > 0) {  
                    System.out.println(num);  
                    System.out.println("修改成功");  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
            }finally {  
                JDBCUtils.release(conn, st, rs);  
            }  
              
        }  
          
        @Test  
        public void find(){  
                      
            try {  
                conn = JDBCUtils.getConnection();  
                st = conn.createStatement();  
                String sql = "select id,name,password,email,birthday from user";  
                rs = st.executeQuery(sql);  
                while(rs.next()){  
                    int id = (Integer)rs.getObject("id");  
                    String name = (String)rs.getObject("name");  
                    String password = (String)rs.getObject("password");  
                    String email = (String)rs.getObject("email");  
                    Date birthday = (Date)rs.getObject("birthday");  
                    System.out.println(id+","+name+","+password+","+email+","+birthday);  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
            }finally {  
                JDBCUtils.release(conn, st, rs);  
            }  
              
        }  
      
    }  

      JDBC基本知识点就介绍到这,后面再介绍一些高级点的应用,如有错误之处,欢迎留言指正~

    1. DriverManager.registerDriver(new Driver());  
    2. DriverManager.getConnection(URL, user, password);  
  • 相关阅读:
    常见的医学影像数据格式
    如何加到可选Kernel中?(jupyter notebook)
    GITHUB(3.2)实际动手使用
    GITHUB(3.1)前期准备
    GITHUB(2.1-2.5)Git的导入
    GITHUB(1.5)GitHub提供的主要功能
    HTML
    python day21
    python day20
    python day19
  • 原文地址:https://www.cnblogs.com/shanheyongmu/p/5897176.html
Copyright © 2011-2022 走看看