再谈JDBC(从放弃到入门)

作者: LinkedIn | 来源:发表于2017-05-30 20:15 被阅读0次

    JDBC作为JavaEE的一部分,在web项目中都直接或者间接使用其来操作数据库,无需开发人员针对某种特别的数据库进行编程。下面文章描述数据库基本的操作,以及涉及JDBC 3.0的内容。
    技术群:466473786
    (1):基本使用方法

    • 载入数据库驱动 到使用的数据库官方下载jar包驱动
    • 建立数据库连接,获取Connection对象
    • 获取statement 对象或者preparedstatement(编译sql)
    • 根据SQL语句拿到拿到rusultset 进行操作
      -代码展示:
    package my.test.utils;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class MyJdbc {
        private static final String password = "123456";
        private static final String user = "root";
        private static final String url = "jdbc:mysql://localhost:3306/wsy_student";
    
        public static void main(String[] args) {
              // - 载入数据库驱动 到使用的数据库官方下载jar包驱动
              try {
                Class.forName("com.mysql.jdbc.Driver");
              // - 建立数据库连接,获取Connection对象
                Connection con = DriverManager.getConnection(url, user, password);
              // - 获取statement 对象或者preparedstatement(编译sql)
                Statement statement = con.createStatement();
              // - 根据SQL语句拿到拿到rusultset 进行操作
                ResultSet query = statement.executeQuery("select * from user");
                while (query.next()) {
                    System.out.println("删除成功"+ query.getString("username"));
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            }
             
        }
    }
    
    

    (2)preparedstatement的使用优点

    • 可维护性,可读性高
    • 能够最大地提高代码的执行效率
    • 能够提高程序的安全性
      -代码
          PreparedStatement ps = con.prepareStatement("insert into user(username,password) value(?,?)");
    //记住下标是从1开始
              ps.setString(1, "user1");
              ps.setString(2, "pass");
              ps.addBatch();
              ps.executeBatch();
    

    (3) 存储过程

    • 存储过程的callstatement是继承自preparedstatement,拥有以下其方法,再则 遇到有参数的存储过程,多了一个registerOutParameter注册拿到结果
          CallableStatement call = con.prepareCall("{call user procedurename(?,?,?)}");
              call.setString(1, "proce1");
              call.setString(2, "proce2");
              //有参数输出的执行过程
              call.registerOutParameter(3, java.sql.Types.INTEGER);
              call.execute();
              //拿到输出结果
              int int1 = call.getInt(3);
    

    (4)可更新的结果集(手动持久化)

    • 通过preparedstatement的executeQuery()拿到结果集
    • 移动结果集到当前行
    • 使用updatexxx 进行操作
    • 根据情况 执行持久化 inserrow(),deleterow(),updaterow()
    • 注意需要设置 可滚动,可更新
    ResultSet.TYPE_SCROLL_SENSITIVE,
    ResultSet.CONCUR_UPDATABLE
    

    -代码

        Connection con = DbUtils.getConnection();
            try {
                PreparedStatement ps = con.prepareStatement("select * from user",ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
                ResultSet executeQuery = ps.executeQuery();
                //移动游标的插入行
                executeQuery.moveToInsertRow();
                //使用updatexxx
                executeQuery.updateString(2, "use");
                //进行持久化操作
                executeQuery.insertRow();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
    

    (5) 行集

    • JDBC 3.0提出,解决了在可滚动,可更新的情况下connection资源紧张的问题。特点:断开数据库连接后,任然可以直接操作行集数据。
    • 是resultset的子接口 rowset ,可以像resultset一样操作,数据集合
    • 拥有五个不同的实现类,针对不同的问题选择不同的来处理数据
      -cacherowset ,数据库离线支持,缓存在内存中,提供序列化支持,可作为javabean在网络间传输,支持事件监听,分页等
    • webrowset ,提供rowset在xml间进行转化操作,相互操作。
    • filteredrowset 提供过滤支持,需要可重写,predicate接口,完成数据过滤
    • joinrowset ,可以提供连接查询,可以把不同的行集的数据结合起来
    • jdbcrowset,唯一一个必须保持connection连接的行集,可提供序列化支持。
      -下面简单列举,cacherowset的使用;
        @Test
        public void rowCollction() throws SQLException, ClassNotFoundException {
        Class.forName("com.mysql.jdbc.Driver");
        CachedRowSet crt=new CachedRowSetImpl();
        crt.setUrl("jdbc:mysql://localhost:3306/wsy_student");
        crt.setUsername("root");
        crt.setPassword("123456");
        //通过command来执行命令
        crt.setCommand("select * from user");
        crt.execute();
        //遍历行集
        while (crt.next()) {
            System.out.println(crt.getString("username"));
        }
            
        }
    

    (6) 事物处理
    系统学习过数据库的都是应该知道事物的,事物提出,按照软件开发的五个基本原则进行,commit ,rollback ,我认为主要是为了数据的安全性。步骤

    • 建议采用try cacth的方式进行管理异常,原因是可以回滚
    • 静止自动提交操作
    • 利用preparedstatement 执行操作,
    • 手动进行操作提交
    • 异常中管理回滚操作
      -代码
        Connection con = DbUtils.getConnection();
            try {
                con.setAutoCommit(false);
                PreparedStatement ps = con.prepareStatement("select * from user",ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
                ResultSet executeQuery = ps.executeQuery();
                //移动游标的插入行
                executeQuery.moveToInsertRow();
                //使用updatexxx
                executeQuery.updateString(2, "use");
                //进行持久化操作
                executeQuery.insertRow();
                //手动进行提交
                con.commit();
            } catch (SQLException e) {
                new Exception("出现了异常");
                e.printStackTrace();
            }
    

    (7) 数据源以及JNDI
    商业级别数据库应用,不会采用自己编写本次threadlcoal 的数据库连接池,一般会选择c3po,druid,dbcp,或者直接在tomcat共享一个数据源泉。
    JNDI(Java Naming and Directory Interface,Java命名和目录接口)是一组在Java应用中访问命名和目录服务的API。命名服务将名称和对象联系起来,使得我们可以用名称访问对象。目录服务是一种命名服务,在这种服务里,对象不但有名称,还有属性。

    (8) jdbcTemplate
    通过上面的jdbc的学习,你是否发现了,在写数据库代码时,我们实现一点业务逻辑,但是重复写了很多数据库连接,关闭的样板式代码。这样我们我们完全可以对齐进行封装把重复代码封装起来,对外提供业务方法。在spring中,除了核心组件外,提供很多配套组件供我们使用,当然这些组件不是必须的,你可以选择搭配其他数据源,hibernate等。这里我们使用 spring提供的封装。必须引入spring-jdbc-xxx .jar spring-tx-xxxx.jar ,在spring3.0以后不建议在用jdbctemplate做基本的使用方案,jdk5.0以后增加了自动装箱等功能,建议采用simplejdbctemplate做为使用方案。便于对于bean操作的jdbcdaosupport迁移到simplejdbcdaosupport(方便直接获取simplejdbctemplate() 进行操作)上来,对于多参数等类的调用按照管理类推。

    • 使用simplejdbcdaotemplate时注意配置文件对与你的dao类增加simplejdbctemplate索引

    • ApplicationContent.xml

    <!-- jdbc 数据配置 -->
         <bean id="datasource"  
            class="org.springframework.jdbc.datasource.DriverManagerDataSource">  
            <property name="driverClassName" value="com.mysql.jdbc.Driver" />  
            <!--注意一下&characterEncoding要修改为&characterEncoding-->  
        <property name="url" value="jdbc:mysql://localhost:3306/wsy_student?useUnicode=true&characterEncoding=utf-8"/>        
            <property name="username" value="root"/>  
            <property name="password" value="123456" />  
        </bean>      
       <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="datasource"></property>
       </bean>
    
    • 业务代码
    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
              //这里转向你所在配置文件声明的bean
        JdbcTemplate jdbc = (JdbcTemplate) context.getBean("jdbcTemplate");
        SqlRowSet set = jdbc.queryForRowSet("select * from user");
        while (set.next()) {
            System.out.println(set.getInt(1)+" ");
            System.out.print(set.getString("username"));
        }
        iService bean = context.getBean("jdk", iService.class);
        Animal animal = (Animal) context.getBean("Animal");
        animal.speak();
        bean.selectDao();
        //普通操作,样板式代码不见了,只出现了业务逻辑
    }
    
    - 当我们直接操作bean,使用业务更加清晰,spring为我们了rowmapper来做映射
    
    - 实现RowMapper,并且对于自己的bean进行操作
    
    
    
    package entiy;
    
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    import org.springframework.jdbc.core.RowMapper;
    
    /**
     * @author DGW
     * @date 2017 2017年6月1日 下午8:43:29
     * @filename userMapper.java  
     * @TODO user的映射
     */
    public class userMapper implements RowMapper<User>{
    
        @Override
        public User mapRow(ResultSet set, int arg1) throws SQLException {
            User user=new User();
            user.setUsername(set.getString("username"));
            user.setPassword(set.getString("password"));
            user.setQqnumber(set.getInt("qqnumber"));
            user.setTime(set.getDate("time"));
            return user;
        }
        
    
    }
    
    
    • 拿取数据显得尤为精炼,看下面代码:

    public class Main {
    @SuppressWarnings("resource")
    public static void main(String[] args) {
    ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
    JdbcTemplate jdbc = (JdbcTemplate) context.getBean("jdbcTemplate");
    List<User> list = jdbc.query("select * from user", new userMapper());
    for (User user : list) {
    System.out.println(user);
    }

        /*SqlRowSet set = jdbc.queryForRowSet("select * from user");
        while (set.next()) {
            System.out.println(set.getInt(1)+" ");
            System.out.print(set.getString("username"));
        }
        iService bean = context.getBean("jdk", iService.class);
        Animal animal = (Animal) context.getBean("Animal");
        animal.speak();
        bean.selectDao();
        //普通操作,样板式代码不见了,只出现了业务逻辑
    

    */ }

    相关文章

      网友评论

        本文标题:再谈JDBC(从放弃到入门)

        本文链接:https://www.haomeiwen.com/subject/khgrfxtx.html