JdbcTemplate基本使用

JDBC已经能够满足大部分用户最基本的需求，但是在使用JDBC时，必须自己来管理数据库资源如：获取PreparedStatement，设置SQL语句参数，关闭连接等步骤。
JdbcTemplate是Spring对JDBC的封装，目的是使JDBC更加易于使用。JdbcTemplate是Spring的一部分。JdbcTemplate处理了资源的建立和释放。他帮助我们避免一些常见的错误，比如忘了总要关闭连接。他运行核心的JDBC工作流，如Statement的建立和执行，而我们只需要提供SQL语句和提取结果。

示例数据表

  1. CREATE TABLE `test` (
  2.   `id` int(11) NOT NULL AUTO_INCREMENT,
  3.   `name` varchar(100) DEFAULT NULL,
  4.   PRIMARY KEY (`id`)
  5. ) ENGINE=InnoDB  DEFAULT CHARSET=utf8mb4;

pom.xml文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  7.     <groupId>yubing</groupId>
  8.     <artifactId>jdbc</artifactId>
  9.     <version>1.0-SNAPSHOT</version>
  10.     <build>
  11.         <plugins>
  12.             <plugin>
  13.                 <groupId>org.apache.maven.plugins</groupId>
  14.                 <artifactId>maven-compiler-plugin</artifactId>
  15.                 <configuration>
  16.                     <source>8</source>
  17.                     <target>8</target>
  18.                 </configuration>
  19.             </plugin>
  20.         </plugins>
  21.     </build>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>mysql</groupId>
  25.             <artifactId>mysql-connector-java</artifactId>
  26.             <version>5.1.47</version>
  27.             <scope>runtime</scope>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>junit</groupId>
  31.             <artifactId>junit</artifactId>
  32.             <version>4.12</version>
  33.             <scope>test</scope>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.springframework</groupId>
  37.             <artifactId>spring-jdbc</artifactId>
  38.             <version>5.2.12.RELEASE</version>
  39.         </dependency>
  40.     </dependencies>
  42. </project>

DB封装类

  1. import org.springframework.jdbc.core.JdbcTemplate;
  2. import org.springframework.jdbc.datasource.DriverManagerDataSource;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.util.Properties;
  8. public class Db {
  10.     public static JdbcTemplate getJdbcTemplate() {
  12.         // 创建Properties类对象
  13.         Properties properties = new Properties();
  15.         try
  16.         {
  17.             // 读取properties属性文件到输入流中
  18.             InputStream is = Db.class.getResourceAsStream("/db.properties");
  19.             // 从输入流中加载属性列表
  20.             properties.load(is);
  21.         }
  22.         catch (IOException e) {
  23.             e.printStackTrace();
  24.         }
  26.         // 获取spring的JdbcTemplate
  27.         DriverManagerDataSource dataSource = new DriverManagerDataSource();
  28.         dataSource.setDriverClassName(properties.getProperty("db.driverClass"));
  29.         dataSource.setUrl(properties.getProperty("db.url"));
  30.         dataSource.setUsername(properties.getProperty("db.user"));
  31.         dataSource.setPassword(properties.getProperty("db.password"));
  32.         return  new JdbcTemplate(dataSource);
  33.     }
  35. }

实现增删改查

  1. import org.springframework.jdbc.core.JdbcTemplate;
  3. import java.util.List;
  4. import java.util.Map;
  7. public class Demo04 {
  9.     public static void main(String[] args) {
  11.         JdbcTemplate jdbcTemplate = Db.getJdbcTemplate();
  12. //  查询
  13.         String sql = "select * from test";
  14.         List<Map<String, Object>> users = jdbcTemplate.queryForList(sql);
  15.         for(Map<String, Object> user:users){
  16.             System.out.println(user);
  17.         }
  19. //        查询为字符串
  20.         String sql  = "select name from test";
  21.         List<String> list = jdbcTemplate.queryForList(sql,String.class);
  22.         for(String str:list){
  23.             System.out.println(str);
  24.         }
  26. //        增加记录
  27.         String sql = "insert into test set name=?";
  28.         jdbcTemplate.update(sql,"dfa");
  30.         //修改记录
  31.         String sql = "update test set name=? where id=?";
  32.         jdbcTemplate.update(sql,"fdsdf",3);
  33.     }
  34. }