Spring03Spring的连接数据库以及JDBC模板

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Spring03Spring的连接数据库以及JDBC模板相关的知识,希望对你有一定的参考价值。

前言

今天介绍的是关于Spring的数据库连接以及Jdbc模板的相关API方法,虽然在学习了hibernate之后,会知道实现数据库连接一般都是使用hibernate等持久化框架来实现的。但是,很多时候一些涉及到事务的东西使用这些框架并不能够实现,所以我们还需要结合spring来实现相关的需要。

一、创建工程、导包

要想使用Spring的jdbc模板前,还需要导入相关的jar包:

技术分享

二、进行相关的bean的创建以及工具类的编写

2.1在数据库中创建了两张表,使用spring的jdbcTemplate中的API方法对这两张表进行操作

CREATE TABLE `t_dept` (
  `deptid` int(11) NOT NULL,
  `deptname` varchar(20) CHARACTER SET utf8 DEFAULT NULL,
  `remark` varchar(30) CHARACTER SET utf8 DEFAULT NULL,
  PRIMARY KEY (`deptid`)
) ENGINE=InnoDB DEFAULT CHARSET=gbk COLLATE=gbk_bin;
CREATE TABLE `user` (
  `USER_ID` int(11) NOT NULL,
  `USER_NAME` varchar(11) DEFAULT NULL,
  `USER_PASSWORD` varchar(11) DEFAULT NULL,
  `USER_ADDRESS` varchar(25) DEFAULT NULL,
  PRIMARY KEY (`USER_ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2.2创建实体bean

package com.bean;
/**
 * 创建t_dept表对应的表
 * @author 夜孤寒
 * @version 1.1.1
 *
 */
public class DeptBean {
    private int deptid;
    private String deptname;
    private String remark;
    public DeptBean() {
        super();
    }
    public DeptBean(int deptid, String deptname, String remark) {
        super();
        this.deptid = deptid;
        this.deptname = deptname;
        this.remark = remark;
    }
    public int getDeptid() {
        return deptid;
    }
    public void setDeptid(int deptid) {
        this.deptid = deptid;
    }
    public String getDeptname() {
        return deptname;
    }
    public void setDeptname(String deptname) {
        this.deptname = deptname;
    }
    public String getRemark() {
        return remark;
    }
    public void setRemark(String remark) {
        this.remark = remark;
    }
}

2.3创建spring的工具类——SpringUtil.java

package com.util;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * 读取配置文件的工具类,实现了类似工厂模式的方式
 * 
 * @author 夜孤寒
 * @version 1.1.1
 */
public class SpringUtil {
    // 定义属性
    private static ApplicationContext context;
    // 读取配置文件
    static {
        context = new ClassPathXmlApplicationContext("spring.xml");
    }

    // 定义一个方法,判断bean是否为空,如果不为空的,获取这个bean
    public static Object getBean(String beanName) {
        // 定义一个空对象
        Object obj = null;
        // 如果beanName不为空的话,那么根据这个beanName获取到bean对象,赋值给obj并返回
        if (beanName != null && !beanName.equals("")) {
            obj = context.getBean(beanName);
        }
        return obj;
    }
}

2.4进行配置文件的相关配置——spring.xml文件的配置

因为要介绍的API方法可能比较多,所以一次性将写过的xml全部粘贴了,读者可以根据对应的配置,去对应到相应的类中:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context     
    http://www.springframework.org/schema/context/spring-context-3.0.xsd
    http://www.springframework.org/schema/tx 
    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    http://www.springframework.org/schema/aop 
    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
    
    <!-- 方式一:
            配置使用IOC:直接引用
     -->
     <!-- 首先需要引入一个驱动,然後到這驱动类下面,去查看他的源代码,一下是mysql需要注入的对象 -->
     <bean name="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
         <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
         <property name="url" value="jdbc:mysql://localhost:3306/spring_jdbc_test"></property>
         <property name="username" value="root"></property>
         <property name="password" value="root"></property>
     </bean>
     
     <!-- 使用DI注入的构造方法注入的方式来注入,并且查询我们的数据库中的数据。
              注意这里我们还需要一我们之前的dataSource作为引用
      -->
      <bean name="testMain_2" class="com.jdbc.TestMain_2">
          <property name="dataSource" ref="dataSource"></property>
      </bean>

      <!-- 使用我们的模板来获取我们的数据库中的数据 -->
      <bean name="testMain_3" class="com.jdbc.TestMain_3">
          <!-- 首先我们还是需要引入我们的数据库资源,也就是我们之前已经配置过的dataSource -->
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      
      <!-- 方式四 -->
      <!-- 配置我们模板,然后在类就只要将这个模板用构造方法的方式注入就可以了 -->
      <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      <!-- 配置我们的testMain_4,然后引用我们上面配置的模板 -->
      <bean name="testMain_4" class="com.jdbc.TestMain_4">
          <property name="jdbcTemplate" ref="jdbcTemplate"></property>
      </bean>
      
      <!-- 方式五:
                直接继承JdbcDaoSupport这个父类,然后用里面的方法获取到模板,
                从而获取到数据。
                备注:这个是最完美的获取数据的方式,以后一般都是使用这种方式!!!
       -->
      <bean name="testMain_5" class="com.jdbc.TestMain_5">
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      
      <!-- 使用spring配置的方式操作我们的DDL语句 -->
      <bean name="testMain_6" class="com.jdbc.TestMain_6">
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      
      <!-- 使用spring配置的方式操作我们的DML语句 -->
      <bean name="testMain_7" class="com.jdbc.TestMain_7">
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      
      <!-- 使用JdbcTemplate模板中的命名参数来操作我们的DML语句 -->
      <bean name="testMain_8" class="com.jdbc.TestMain_8">
          <property name="dataSource" ref="dataSource"></property> 
      </bean>
      
      <!-- 使用JdbcTemplate模板对于查询语句的封装 -->
      <bean name="testMain_9" class="com.jdbc.TestMain_9">
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      
</beans>

2.5介绍spring对于jdbc的模板的支持

(1)数据库的连接

对应xml中的配置为:

    <!-- 方式一:
            配置使用IOC:直接引用
     -->
     <!-- 首先需要引入一个驱动,然後到這驱动类下面,去查看他的源代码,一下是mysql需要注入的对象 -->
     <bean name="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
         <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
         <property name="url" value="jdbc:mysql://localhost:3306/spring_jdbc_test"></property>
         <property name="username" value="root"></property>
         <property name="password" value="root"></property>
     </bean>

对应的测试类:

package com.jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.util.SpringUtil;
/**
 * 连接数据库的测试类
 * @author 夜孤寒
 * @version 1.1.1
 *
 */
public class TestMain_1 {
    public static void main(String[] args) {
        /*
         * 本来需要用applicationContext获取到我们的bean对象,
         * 这里使用工厂类的方法将之独立出来,具体使用见SpringUtil.java
         */
        DataSource datasource=(DataSource)SpringUtil.getBean("dataSource");
        Connection conn=null;
        try{
            conn=datasource.getConnection();
        }catch(SQLException e){
            e.printStackTrace();
        }
        System.out.println(conn);//测试是否能够输出连接
    }
}

测试结果:

技术分享

由此可见测试成功可以获取到相应的数据库连接。

(2)测试从创建的user表中查询出相应的数据

对应xml配置为:

     <!-- 使用DI注入的构造方法注入的方式来注入,并且查询我们的数据库中的数据。
              注意这里我们还需要一我们之前的dataSource作为引用
      -->
      <bean name="testMain_2" class="com.jdbc.TestMain_2">
          <property name="dataSource" ref="dataSource"></property>
      </bean>

对应的测试类为:

package com.jdbc;

import java.sql.Connection;
import java.sql.ResultSet;

import javax.sql.DataSource;

import com.mysql.jdbc.Statement;
import com.util.SpringUtil;

/**
 * 从创建的user表中查询相关的数据
 * 
 * @author 夜孤寒
 * @version 1.1.1
 */
public class TestMain_2 {
    // 使用构造方法注入
    public DataSource datasource;

    public void setDataSource(DataSource datasource) {
        this.datasource = datasource;
    }

    /**
     *  从user表中获取所有数据
     */
    public void list() {
        /*
         * 在我们的main方法中获取到我们的datasource, 然后就能够获取连接,并且获取到数据库中的数据。
         */
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        String sql = "select * from user";
        try {
            conn = datasource.getConnection();
            stmt = (Statement) conn.createStatement();
            rs = stmt.executeQuery(sql);
            while (rs.next()) {
                System.out.println(rs.getInt("user_id") + "\\t" + rs.getString("user_name") + "\\t"
                        + rs.getString("user_password") + "\\t" + rs.getString("user_address"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            /*
             * 需要自己关闭资源
             */
        }
    }

    public static void main(String[] args) {
        // 获取到我们bean对象
        TestMain_2 testMain_2 = (TestMain_2) SpringUtil.getBean("testMain_2");
        // 调用我们的list方法
        testMain_2.list();
    }
}

测试结果:

技术分享

备注:本测试类,使用的是常用的纯粹的jdbc获取数据的方式。

(3)使用JdbcTemplate这个类来获取到后端的数据

对应的xml文件的配置为:

      <!-- 使用我们的模板来获取我们的数据库中的数据 -->
      <bean name="testMain_3" class="com.jdbc.TestMain_3">
          <!-- 首先我们还是需要引入我们的数据库资源,也就是我们之前已经配置过的dataSource -->
          <property name="dataSource" ref="dataSource"></property>
      </bean>

对应的测试类:

package com.jdbc;


import java.util.List;
import java.util.Map;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;

import com.util.SpringUtil;
/**
 * 使用jdbcTemplate这个类来获取后台数据
 * @author 夜孤寒
 *
 */
public class TestMain_3 {
    // 使用构造方法注入
    public DataSource datasource;

    public void setDataSource(DataSource datasource) {
        this.datasource = datasource;
    }

    public void list() {
        /*
         * 使用我们JdbcTemplate模板来获取我们的数据
         */
        JdbcTemplate jdbcTemplate=new JdbcTemplate(this.datasource);
        String sql="select * from user";
        List<Map<String, Object>>userlist=jdbcTemplate.queryForList(sql);
        for(Map<String, Object>rowMap:userlist){
            System.out.println(rowMap);
        }
    }
    
    public static void main(String[] args) {
        //获取到我们bean对象
        TestMain_3 testMain_3=(TestMain_3)SpringUtil.getBean("testMain_3");
        //调用我们的list方法
        testMain_3.list();
    }
}

测试的结果:

技术分享

这种方式的话每次我们都要创建一个JdbcTemplate实例,这样子比较复杂,所以考虑能不能将这个类让Spring自己创建,然后在bean配置文件中引用数据源来达到目的。这就是下面要介绍的第四种方式。

(4)在配置文件中配置我们的模板类,让Spring生成需要的bean

对应的xml配置文件为:

      <!-- 方式四 -->
      <!-- 配置我们模板,然后在类就只要将这个模板用构造方法的方式注入就可以了 -->
      <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
          <property name="dataSource" ref="dataSource"></property>
      </bean>
      <!-- 配置我们的testMain_4,然后引用我们上面配置的模板 -->
      <bean name="testMain_4" class="com.jdbc.TestMain_4">
          <property name="jdbcTemplate" ref="jdbcTemplate"></property>
      </bean>

对应的测试类为:

package com.jdbc;

import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.JdbcTemplate;

import com.util.SpringUtil;

/**
 * 在配置文件中配置模板,让spring去创建模板类
 * 
 * @author 夜孤寒
 * @version 1.1.1
 */
public class TestMain_4 {
    // 使用构造方法的方式注入template
    public JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void list() {
        /*
         * 使用我们IOC注入模板,然后引用这个使用IOC注入的模板, 最后取出我们的数据
         */
        String sql = "select USER_NAME from user";
        List<Map<String, Object>> userlist = this.jdbcTemplate.queryForList(sql);
        for (Map<String, Object> rowMap : userlist) {
            System.out.println(rowMap);
        }
    }

    public static void main(String[] args) {
        // 获取到我们bean对象
        TestMain_4 testMain_4 = (TestMain_4) SpringUtil.getBean("testMain_4");
        // 调用我们的list方法
        testMain_4.list();
    }
}

测试结果:

技术分享

这种方式仍旧需要在xml中配置,而在spring中还有一种更加方便的方式就是直接继承JdbcDaoSupport这个类,这种方式是最简单的,也是最常用的方式。下面笔者就简单介绍一下这种方式的使用。

(5)继承JdbcDaoSupport类来获取数据库中的数据

对应的xml文件中的配置为:

      <!-- 方式五:
                直接继承JdbcDaoSupport这个父类,然后用里面的方法获取到模板,
                从而获取到数据。
                备注:这个是最完美的获取数据的方式,以后一般都是使用这种方式!!!
       -->
      <bean name="testMain_5" class="com.jdbc.TestMain_5">
          <property name="dataSource" ref="dataSource"></property>
      </bean>

对应的测试类为:

package com.jdbc;

import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.util.SpringUtil;
/**
 * 继承JdbcDaoSupport来获取模板,再通过模板来获取数据
 * @author 夜孤寒
 * @version 1.1.1
 *
 */
public class TestMain_5 extends JdbcDaoSupport {
    /*
     * 不使用DI注入的方式,直接继承一个上述的父类, 观察上述的父类,发现在这个父类里面已经实现了类似注入JdbcTemplate模板。
     */

    public void list() {
        String sql = "select * from user";
        List<Map<String, Object>> userlist = this.getJdbcTemplate().queryForList(sql);
        for (Map<String, Object> rowMap : userlist) {
            System.out.println(rowMap);
        }
    }

    public static void main(String[] args) {
        // 获取到我们bean对象
        TestMain_5 testMain_5 = (TestMain_5) SpringUtil.getBean("testMain_5");
        // 调用我们的list方法
        testMain_5.list();
    }
}

测试结果为:

技术分享

(6)使用Spring注入的方式来操作DDL语句

对应xml文件中的配置为:

      <!-- 使用spring配置的方式操作我们的DDL语句 -->
      <bean name="testMain_6" class="com.jdbc.TestMain_6">
          <property name="dataSource" ref="dataSource"></property>
      </bean>

对应的测试类为:

package com.jdbc;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.util.SpringUtil;

/**
 * 使用spring注入的方式进行DDL操作
 * 
 * @author 夜孤寒
 * @version 1.1.1
 *
 */
public class TestMain_6 extends JdbcDaoSupport {
    /*
     * 创建表
     */
    public void create() {
        StringBuffer createSQL = new StringBuffer();
        createSQL.append("create table T_Temp_XX(id int,testname varchar(30))");
        this.getJdbcTemplate().execute(createSQL.toString());
    }

    /*
     * 修改表,这里面可以添加或者删除某一个属性列
     */
    public void alter() {
        StringBuffer alterSQL = new StringBuffer();
        alterSQL.append("alter table T_Temp_XX add testpassword varchar(30)");
        this.getJdbcTemplate().execute(alterSQL.toString());
    }

    /*
     * 删除一张表
     */
    public void drop() {
        StringBuffer dropSQL = new StringBuffer();
        dropSQL.append("drop table T_Temp_XX");
        this.getJdbcTemplate().execute(dropSQL.toString());
    }

    /*
     * 测试方法
     */
    public static void main(String[] args) {
        // 获取到我们bean对象
        TestMain_6 testMain_6 = (TestMain_6) SpringUtil.getBean("testMain_6");
        // 调用我们的方法,一次调用一个方法,打开数据库观察数据库是不是已经变化了
        // testMain_6.create();
        // testMain_6.alter();
        testMain_6.drop();
    }
}

经过测试可以进行DDL操作。

(7)使用spring注入的方式进行DML操作

对应xml文件中的配置:

      <!-- 使用spring配置的方式操作我们的DML语句 -->
      <bean name="testMain_7" class="com.jdbc.TestMain_7">
          <property name="dataSource" ref="dataSource"></property>
      </bean>

对应测试类:

package com.jdbc;

import java.sql.PreparedStatement;
import java.sql.SQLException;

import org.springframework.jdbc.core.PreparedStatementSetter;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.util.SpringUtil;

/**
 * 使用spring配置的方式操作我们的DML语句
 * 
 * @author 夜孤寒
 * @version 1.1.1
 */

public class TestMain_7 extends JdbcDaoSupport {
    /*
     * statement的写法
     */
    public void insert() {
        int deptid = 1;
        String deptname = "zhangsan";
        String remark = "zhangsanzhenshuai";
        StringBuffer insertSQL = new StringBuffer();
        insertSQL.append("Insert Into T_Dept(");
        insertSQL.append("deptid,deptname");
        insertSQL.append(",remark");
        insertSQL.append(") values(");
        insertSQL.append("" + deptid + ",");
        insertSQL.append("‘" + deptname + "‘,");
        insertSQL.append("‘" + remark + "‘");
        insertSQL.append("");
        insertSQL.append(")");
        int rowCount = this.getJdbcTemplate().update(insertSQL.toString());
        System.out.println("rowCount影响的行数= " + rowCount);
    }

    /*
     * prepareStatement的写法
     */
    public void update() {
        StringBuffer updateSQL = new StringBuffer();
        updateSQL.append("update t_dept set ");
        updateSQL.append("deptname = ?,");
        updateSQL.append("remark = ?");
        updateSQL.append(" where deptid=?");
        int rowCount = this.getJdbcTemplate().update(updateSQL.toString(), new PreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps) throws SQLException {
                ps.setString(1, "lisi");
                ps.setString(2, "lisizhenshuai");
                ps.setInt(3, 1);
            }
        });
        System.out.println("rowCount影响的行数=" + rowCount);
    }

    /*
     * prepareStatement的写法
     */
    public void delete() {
        StringBuffer deleteSQL = new StringBuffer();
        deleteSQL.append("delete from t_dept");
        deleteSQL.append(" where deptid=?");
        /*
         * 关于对象数组的使用:对象数组的第一个元素对应的是SQL语句中的第一个参数问号
         */
        Object[] obj = { 1 };
        int rowCount = this.getJdbcTemplate().update(deleteSQL.toString(), obj);
        System.out.println("rowCount影响的行数=" + rowCount);
    }

    public static void main(String[] args) {
        // 获取到bean对象
        TestMain_7 testMain_7 = (TestMain_7) SpringUtil.getBean("testMain_7");
        // 测试方法
        // testMain_7.insert();
        // testMain_7.update();
        testMain_7.delete();
    }
}

经测试,可以实现DML操作中的增删改查。

(8)使用JdbcTemplate模板中的命名参数来操作我们的DML语句

对应xml中的配置为:

      <!-- 使用JdbcTemplate模板中的命名参数来操作我们的DML语句 -->
      <bean name="testMain_8" class="com.jdbc.TestMain_8">
          <property name="dataSource" ref="dataSource"></property> 
      </bean>

对应的测试类:

package com.jdbc;

import java.util.HashMap;
import java.util.Map;

import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcDaoSupport;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;

import com.bean.DeptBean;
import com.util.SpringUtil;

/**
 * 使用JdbcTemplate模板中的命名参数来操作我们的DML语句
 * 
 * @author 夜孤寒
 * @version 1.1.1
 */
public class TestMain_8 extends NamedParameterJdbcDaoSupport {
    /*
     * statement的写法
     */
    public void insert(boolean flag_1, boolean flag_2) {
        int deptid = 1;
        String deptname = "zhangsan";
        String remark = "zhangsanzhenshuai";
        StringBuffer insertSQL = new StringBuffer();
        insertSQL.append("insert into T_Dept(deptid");
        if (flag_1) {
            insertSQL.append(",deptname");
        }
        if (flag_2 == true) {
            insertSQL.append(",remark");
        }
        insertSQL.append(") values(");
        insertSQL.append(":deptid");
        if (flag_1 == true) {
            insertSQL.append(",:deptname");
        }
        if (flag_2 == true) {
            insertSQL.append(",:remark");
        }
        insertSQL.append(")");
        // 将数据放进我们的map中 备注:map中key的名称==命名参数的名称
        Map<String, Object> paramMap = new HashMap<String, Object>();
        paramMap.put("deptid", deptid);
        paramMap.put("deptname", deptname);
        paramMap.put("remark", remark);
        int rowCount = this.getNamedParameterJdbcTemplate().update(insertSQL.toString(), paramMap);
        System.out.println("rowCount影响的行数= " + rowCount);
    }

    /*
     * prepareStatement的写法
     */
    public void update() {
        StringBuffer updateSQL = new StringBuffer();
        updateSQL.append("update T_Dept set");
        updateSQL.append(" deptname = :deptname,");
        updateSQL.append(" remark = :remark");
        updateSQL.append(" where deptid = :deptid");
        updateSQL.append("");
        // 获取到模板
        NamedParameterJdbcTemplate template = this.getNamedParameterJdbcTemplate();
        // 将数据放置到bean里面去
        DeptBean deptbean = new DeptBean();
        deptbean.setDeptid(1);
        deptbean.setDeptname("lisi");
        deptbean.setRemark("lisizhenshuai");
        // 使用一个bean工厂的方法将预处理我们的bean
        BeanPropertySqlParameterSource paramSource = new BeanPropertySqlParameterSource(deptbean);
        // 调用模板方法更新数据
        int rowCount = template.update(updateSQL.toString(), paramSource);
        // 输出影响的行数
        System.out.println("影响的行数rowCount=" + rowCount);
    }

    public static void main(String[] args) {
        // 获取到bean对象
        TestMain_8 testMain_8 = (TestMain_8) SpringUtil.getBean("testMain_8");
        // 测试方法
        // testMain_8.insert(true,true);//由这个参数来控制是不是插入某一个属性列的数据
        testMain_8.update();
    }
}

(9)JdbcTemplate模板对于查询语句的封装

对应的xml文件的配置:

      <!-- 使用JdbcTemplate模板对于查询语句的封装 -->
      <bean name="testMain_9" class="com.jdbc.TestMain_9">
          <property name="dataSource" ref="dataSource"></property>
      </bean>

对应的测试类:

package com.jdbc;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import java.util.Vector;

import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.ColumnMapRowMapper;
import org.springframework.jdbc.core.PreparedStatementSetter;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.bean.DeptBean;
import com.util.SpringUtil;
/**
 * JdbcTemplate模板对于查询语句的封装测试类
 * @author 夜孤寒
 * @version 1.1.1
 */
public class TestMain_9 extends JdbcDaoSupport{
    /*
     * 最简单的一个查询
     */
    public void one(){
        System.out.println("==============================");
        System.out.println("1:返回所有的对象");
        String sql="select * from t_dept order by deptid asc";
        List<Map<String, Object>>deptList=this.getJdbcTemplate().queryForList(sql);
        for(Map<String, Object>rowMap:deptList){
            System.out.println(rowMap);
        }
        System.out.println("==============================");
        System.out.println("2:返回一条对象");
        /*
         * 返回一条对象,将返回的对象使用Map的方式来接收
         */
        sql="select * from t_dept where deptid=1";
        Map<String, Object>rowMap=this.getJdbcTemplate().queryForMap(sql);
        if(rowMap!=null){
            System.out.println(rowMap);
        }
        /*
         * 使用queryForObject方法来接收一个对象:
         *     1、如果方法的第二个参数是class类型的话,表示SQL只能返回一行一列。相当于RowMapper中的SingleColumnRowMapper;
         *     2、如果方法的第二个参数是rowMapper类型的话,表示SQL语句只能返回一行多列。
         *     一行多列,默认是返回queryForMap,但是Spring允许可以对返回的行数据进行自定义的映射
         */
        /*
         * 方式一:返回的class类型
         */
        sql="select count(1) from t_dept where deptid=1";//什么意思?
        Integer dept_count=this.getJdbcTemplate().queryForObject(sql, Integer.class);
        System.out.println("dept_count="+dept_count);
        /*
         * 方式二:返回的是rowMapper的类型
         */
        sql="select * from t_dept where deptid=1";
        BeanPropertyRowMapper<DeptBean>rowMapper=new BeanPropertyRowMapper<DeptBean>(DeptBean.class);
        //需要将返回的数据转换成bean对象
        DeptBean deptbean=this.getJdbcTemplate().queryForObject(sql, rowMapper);
        System.out.println(deptbean.getDeptid()+"\\t"+deptbean.getDeptname()+"\\t"+deptbean.getRemark());
        System.out.println("==============================");
        
    }
    /*
     * 复杂的查询queryForXX:
     * 这个是模板封装好的查询方法
     */
    @SuppressWarnings({ "unchecked", "rawtypes" })
    public void two(){
        //1、处理有预编译的语句
        String sql="select * from t_dept where deptname like ? order by deptid asc";
        List<Map<String, Object>>deptList=this.getJdbcTemplate().query(sql, new PreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps) throws SQLException {
                //查询带有"l"这个字符的所有对象
                ps.setString(1, "%l%");
            }
        },new ColumnMapRowMapper());//这里代表返回的是一个什么类型
        System.out.println(deptList);
        //2、处理带有预编译的语句,并且返回的是一个javabean
        List<DeptBean>deptList_2 = this.getJdbcTemplate().query(
                sql, new PreparedStatementSetter() {
                    @Override
                    public void setValues(PreparedStatement ps)
                            throws SQLException {
                        ps.setString(1, "%l%");

                    }
                }, new BeanPropertyRowMapper(DeptBean.class));
        System.out.println(deptList_2);
        //3、直接处理resultSet???????什么意思
        List<Vector<String>>deptList_3=this.getJdbcTemplate().query(sql, new PreparedStatementSetter() {
            
            @Override
            public void setValues(PreparedStatement ps) throws SQLException {
                ps.setString(1, "%l%");
            }
        },new RowMapper() {
            @Override
            public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
                int deptid = rs.getInt("deptid");
                String deptname = rs.getString("deptname");
                Vector<String> vector = new Vector<String>();
                vector.add(String.valueOf(deptid));
                vector.add(deptname);
                return vector;
            }
        });
        System.out.println(deptList_3);
    }
    
    /*
     * 使用命名参数的查询:
     * 前提是首先要实例化命名参数查询的对象
     */
    public void three(){//传一个bean条件,返回结果
        //实例化一个对象
        NamedParameterJdbcTemplate template=new NamedParameterJdbcTemplate(this.getDataSource());
        
        //如果参数是javabean,那么返回值也就是javabean
        String sql="select * from t_dept where deptname like :deptname and remark like :remark";
        //创建一个bean,设置好查询的条件
        DeptBean parambean=new DeptBean();
        parambean.setDeptname("%l%");
        parambean.setRemark("%shuai%");
        //将创建好的bean放到查询语句的池子里面
        BeanPropertySqlParameterSource paramSource=new BeanPropertySqlParameterSource(parambean);
        BeanPropertyRowMapper<DeptBean> rowBean = new BeanPropertyRowMapper<DeptBean>(
                DeptBean.class);
        List<DeptBean>deptList=template.query(sql, paramSource, rowBean);
        for(DeptBean deptbean:deptList){
            System.out.println(deptbean.getDeptname()+"\\t"+deptbean.getRemark());
        }
    }
    public static void main(String[] args) {
        //获取到bean对象
        TestMain_9 testMain_9=(TestMain_9)SpringUtil.getBean("testMain_9");
        //测试方法
//        testMain_9.one();
//        testMain_9.two();
        testMain_9.three();
    }
}

今日笔者就将Spring中的JdbcTemplate模板介绍到这。

以上是关于Spring03Spring的连接数据库以及JDBC模板的主要内容,如果未能解决你的问题,请参考以下文章

Spring简介以及简单使用

Spring 对象的获取,以及数据库连接应用

Spring 对DAO 的支持

spring注入问题空指针

Spring Boot 集成 Mybatis(druid 数据库连接池 以及 分页配置)

Spring 事务相关