再谈JDBC(从放弃到入门)

2017-05-30 本文已影响0人 LinkedIn

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(从放弃到入门)

猜你喜欢

热点阅读