微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

Spring基础入门6 - Spring JDBC

分类：JDBC作者：编程之家原文地址

JDBC(Java DataBase Connectivity)是一套Java访问关系型数据库的标准, JDBC只定义接口，具体实现由各个厂商(框架)负责。 Spring使用的是javax.sql.DataSource接口获取数据库连接, DataSource代表一个数据源(获取数据库工厂)，相较于直接通过java.sql.Driver获取数据库连接(通常是通过DriverManager根据SPI规范查找Drive实现, 并调用匹配的Driver创建连接)，DataSource最大的优势就是可以实现连接池。

开始之前我们先创建一个MysqL的测试库:

create database learning;
use learning;
create table account (
    acct_id int           not null auto_increment,
    name    varchar(16)   not null,
	balance decimal(14,2) not null default 0.0,
    primary key (acct_id)
);
create user 'learning'@'%' identified by 'mypassword';
grant all on learning.* to 'learning'@'%';
show grants for 'learning'@'%';

insert into account(name, balance) values('Tuzki', 20000.00);
insert into account(name, balance) values('Judy', 40000.00);
insert into account(name, balance) values('Bugs', 13400.00);

1. 创建数据源(DataSource) Bean

DataSource只是一个接口，我们配置一个数据源Bean，需要指定具体实现，目前常用的连接池有
HikariCP, Druid, Apache Commons DBCP2, C3P0, … 我们先引入相关依赖:

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<maven.compiler.source>11</maven.compiler.source>
		<maven.compiler.target>11</maven.compiler.target>
	</properties>
	<dependencies>
		<!-- HikariCP dependency -->	
		<dependency>
			<groupId>com.zaxxer</groupId>
			<artifactId>HikariCP</artifactId>
			<version>5.0.1</version> <!-- 需要JDK 11+版本 -->
		</dependency>
		
		<!-- Alibaba Druid dependency -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.2.8</version>
		</dependency>
		
		<!-- Apache DBCP2 dependency -->
		<dependency>
			<groupId>org.apache.commons</groupId>
			<artifactId>commons-dbcp2</artifactId>
			<version>2.9.0</version>
		</dependency>

		<!-- C3P0 dependency -->
		<dependency>
			<groupId>com.mchange</groupId>
			<artifactId>c3p0</artifactId>
			<version>0.9.5.5</version>
		</dependency>
		
		<!-- MysqL JDBC driver -->
		<dependency>
			<groupId>MysqL</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<version>8.0.28</version>
		</dependency>
		...
	</dependencies>

1.1. 通过xml文件配置DataSource

每种连接池的定义的属性名不相同，但含义是相近的，可以自行在网上找。

<?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:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
	...
	<!--  <context:property-placeholder location="datasource.properties"/> -->
	<bean id="hikariDataSource" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close">
		<property name="driverClassName" value="com.MysqL.cj.jdbc.Driver" />
		<!--'&'字符转义: &amp; -->
		<property name="jdbcUrl" value="jdbc:MysqL://127.0.0.1:3306/learning?autoReconnect=true&amp;useUnicode=true" />
		<property name="username" value="learning" />
		<property name="password" value="mypassword" />
		<property name="connectionTestQuery" value="SELECT 1" />
		<property name="maximumPoolSize" value="10" />
	</bean>

	<bean id="druidDataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
		<property name="driverClassName" value="com.MysqL.cj.jdbc.Driver" />
		<property name="url" value="jdbc:MysqL://127.0.0.1:3306/learning?autoReconnect=true&amp;useUnicode=true" />
		<property name="username" value="learning" />
		<property name="password" value="mypassword" />
		<property name="validationQuery" value="SELECT 1" />
		<property name="maxActive" value="10" />
	</bean>

	<bean id="dbcp2DataSource" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
		<property name="driverClassName" value="com.MysqL.cj.jdbc.Driver" />
		<property name="url" value="jdbc:MysqL://127.0.0.1:3306/learning?autoReconnect=true&amp;useUnicode=true" />
		<property name="username" value="learning" />
		<property name="password" value="mypassword" />
		<property name="validationQuery" value="SELECT 1" />
		<property name="maxTotal" value="10" />
	</bean>

	<bean id="c3p0DataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
		<property name="driverClass" value="com.MysqL.cj.jdbc.Driver" />
		<property name="jdbcUrl" value="jdbc:MysqL://127.0.0.1:3306/learning?autoReconnect=true&amp;useUnicode=true" />
		<property name="user" value="learning" />
		<property name="password" value="mypassword" />
		<property name="preferredTestQuery" value="SELECT 1" />
		<property name="maxPoolSize" value="10" />
	</bean>
</beans>

附上测试使用代码:

package org.littlestar.learning.package7;

import java.sql.Connection;
import javax.sql.DataSource;

import org.junit.Assume;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.springrunner;

@RunWith(springrunner.class) //SpringJUnit4ClassRunner requires JUnit 4.12 or higher.
@ContextConfiguration(locations={"classpath:org/littlestar/learning/package6/package6-bean-config.xml"})
public class SpringJdbcTest {
	
	@Autowired
	@Qualifier("hikariDataSource")
	DataSource hikariDataSource;
	@Test
	public void testHikariDataSource() throws Exception {
		try(Connection connection =  hikariDataSource.getConnection()){
			Assume.assumeTrue(connection.isValid(60));
		}
	}
	
	@Autowired
	@Qualifier("druidDataSource")
	DataSource druidDataSource;
	@Test
	public void testDruidDataSource() throws Exception {
		try(Connection connection =  druidDataSource.getConnection()){
			Assume.assumeTrue(connection.isValid(60));
		}
	}
	
	@Autowired
	@Qualifier("dbcp2DataSource")
	DataSource dbcp2DataSource;
	@Test
	public void testDbcp2DataSource() throws Exception {
		try(Connection connection =  dbcp2DataSource.getConnection()){
			Assume.assumeTrue(connection.isValid(60));
		}
	}
	
	@Autowired
	@Qualifier("c3p0DataSource")
	DataSource c3p0DataSource;
	@Test
	public void testc3p0DataSource() throws Exception {
		try(Connection connection =  c3p0DataSource.getConnection()){
			Assume.assumeTrue(connection.isValid(60));
		}
	}
}

1.2. 通过配置类配置DataSource

也可通过Spring配置类进行配置:

package org.littlestar.learning.package6;

import javax.sql.DataSource;

import org.apache.commons.dbcp2.BasicDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;

import com.alibaba.druid.pool.DruidDataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.zaxxer.hikari.HikariDataSource;

@Configuration
@PropertySource({"classpath:org/littlestar/learning/package6/datasource.properties"})
public class DataSourceConfig {
	@Value("${spring.jdbc.driverClassName}")
	private String driverClassName;
	
	@Value("${spring.jdbc.url}")
	private String url;

	@Value("${spring.jdbc.username}")
	private String username;

	@Value("${spring.jdbc.password}")
	private String password;
	
	@Value("${spring.jdbc.connectionTestQuery}")
	private String connectionTestQuery;
	
	@Value("${spring.jdbc.maxPoolSize}")
	private int maxPoolSize;
	
	@Bean(name = "hikariDataSource", destroyMethod="close")
	public DataSource hikariDataSource() {
		HikariDataSource dataSource = new HikariDataSource();
		dataSource.setDriverClassName(driverClassName);
		dataSource.setJdbcUrl(url);
		dataSource.setUsername(username);
		dataSource.setPassword(password);
		dataSource.setConnectionTestQuery(connectionTestQuery);
		dataSource.setMaximumPoolSize(maxPoolSize);
		return dataSource;
	}
	
	@Bean(name = "druidDataSource", destroyMethod="close")
	public DataSource druidDataSource() {
		DruidDataSource dataSource = new DruidDataSource();
		dataSource.setDriverClassName(driverClassName);
		dataSource.setUrl(url);
		dataSource.setUsername(username);
		dataSource.setPassword(password);
		dataSource.setValidationQuery(connectionTestQuery);
		dataSource.setMaxActive(maxPoolSize);
		return dataSource;
	}
	
	@Bean(name = "dbcp2DataSource", destroyMethod="close")
	public DataSource dbcp2DataSource() {
		BasicDataSource dataSource = new BasicDataSource();
		dataSource.setDriverClassName(driverClassName);
		dataSource.setUrl(url);
		dataSource.setUsername(username);
		dataSource.setPassword(password);
		dataSource.setValidationQuery(connectionTestQuery);
		dataSource.setMaxTotal(maxPoolSize);
		return dataSource;
	}
	
	@Bean(name = "c3p0DataSource", destroyMethod="close")
	public DataSource c3p0DataSource() throws Exception {
		ComboPooledDataSource dataSource = new ComboPooledDataSource();
		dataSource.setDriverClass(driverClassName);
		dataSource.setJdbcUrl(url);
		dataSource.setUser(username);
		dataSource.setPassword(password);
		dataSource.setPreferredTestQuery(connectionTestQuery);
		dataSource.setMaxPoolSize(maxPoolSize);
		return dataSource;
	}
}

对应的配置文件:org/littlestar/learning/package6/datasource.properties

spring.jdbc.driverClassName=com.MysqL.cj.jdbc.Driver
spring.jdbc.url=jdbc:MysqL://127.0.0.1:3306/learning?autoReconnect=true&useUnicode=true
spring.jdbc.username=learning
spring.jdbc.password=mypassword
spring.jdbc.connectionTestQuery=select 1
spring.jdbc.maxPoolSize=10

测试类只需指定配置类即可:

package org.littlestar.learning.package7;
...
@RunWith(springrunner.class) //SpringJUnit4ClassRunner requires JUnit 4.12 or higher.
//@ContextConfiguration(locations={"classpath:org/littlestar/learning/package6/package6-bean-config.xml"})
@ContextConfiguration(classes = DataSourceConfig.class) // --> 指向我们的配置类即可
public class SpringJdbcTest {
	//...
}

执行测试:

在这里插入图片描述

2. 使用JdbcTemplate

JdbcTemplate是Spring对JDBC的封装，类似于dbutils。JdbcTemplate包含在spring-jdbc中，需要先引入依赖:

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jdbc</artifactId>
			<version>5.3.15</version>
		</dependency>

通过xml配置JdbcTemplate Bean:

	...
	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
		<constructor-arg name="dataSource" ref="hikariDataSource" />
	</bean>
	...

或者通过配置类配置JdbcTemplate Bean:

@RunWith(springrunner.class) //SpringJUnit4ClassRunner requires JUnit 4.12 or higher.
//@ContextConfiguration(locations={"classpath:org/littlestar/learning/package6/package6-bean-config.xml"})
@ContextConfiguration(classes = DataSourceConfig.class)
public class SpringJdbcTest {
	...
	@Autowired
	@Qualifier("hikariDataSource")
	DataSource jdbcTemplateDataSource;
	@Bean
	public JdbcTemplate jdbcTemplate() {
		return new JdbcTemplate(jdbcTemplateDataSource);
	}
	...

使用JdbcTemplate操作数据库:

	@Autowired
	JdbcTemplate jdbcTemplate;
	// Query
	@Test 
	public void jdbcTemplate_query() {
		List<Account> accounts = jdbcTemplate.query("select * from learning.account", 
				new RowMapper<Account>() {
			@Override
			public Account mapRow(ResultSet rs, int rowNum) throws sqlException {
				Account account = new Account();
				account.setId(rs.getLong("acct_id"));
				account.setName(rs.getString("name"));
				account.setBalance(rs.getDouble("balance"));
				return account;
			}
		});
		
		for(Account account : accounts) {
			System.out.println(account.getName());
		}
	}
	
	// Update 
	@Test 
	public void jdbcTemplate_update() {
		int row = jdbcTemplate.update("update account set name=? where acct_id=?", new Object[] { "rubbit", 1 });
		Assume.assumeTrue(row == 1);
	}
	
	// Delete
	@Test
	public void jdbcTemplate_delete() {
		int row = jdbcTemplate.update("delete from account where acct_id=?", 1);
		Assume.assumeTrue(row == 1);
	}
	
	// Insert
	@Test
	public void jdbcTemplate_insert() {
		int row = jdbcTemplate.update("insert into account(acct_id, name, balance) values (?, ?, ?)", 1, "Tuzki", 20000.00);
		Assume.assumeTrue(row == 1);
	}
}

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

讲解JDBC
连接数据库的方式：第一种方式：ODBC：开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分，是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口，便于语言和数据库通信以及语言对数据库的各种操作。第二种方式：JDBC（本章重点）在Java中，
Jmeter 数据库请求
JDBCRequest 使用VariableNamesmysql：数据库连接池对象variousname：设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#：代表行数a_1：第1行、第1列b_2：第2行、第2列
抽取基本JDBC中的基本操作与数据连接池
 1.JDBCDBC(JavaDataBaseConnectivity)：Java数据库连接技术：具体讲就是通过Java连接广泛的数据库，并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型：增删改基本操作：（1）获取连接：Connectionconnection=
JDBC操作流程
1.需要jar包的支持：java.sqljavax.sqlmysql-conneter-java...连接驱动（必须要导入）<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
Activiti可视化流程管理器
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理，工作流，服务协作等领域的一个开源，灵活的，易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流，我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件，包含有一系列
0811JDBC随笔
1.JDBC体系系统一组规范：接口JDBC接口（API）包括两个层次：面向应用的API：JavaAPI，抽象接口，供应用开发人员使用（连接数据库，执行SQL语句，获得结果）面向数据库的API：JavaDriverAPI，供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口，java程序员只需要面向这套接
JDBC的基本概念
原文链接JDBC一般指Java数据库连接（JavaDatabaseConnectivity）api应用程序接口（API）：可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口（SPI）：需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
Shardingsphere-ShardingSphere-JDBC-Spring Boot配置-分片规则
spring.shardingsphere.datasource.names=#省略数据源配置，请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表，分隔符为点，多个数据节点用逗号分隔，支持内联表达式。Absent表示仅对数据库进行分片
20220814 idea_springboot_启动 Cannot load driver class: com.mysql.cj.jdbc.Driver
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先，去查看项目中MySQL的版本如果找不到，说明可能还没有jdbc驱动，需要配置或者引入       （1）如果是直接引用的jar包，就去lib文件夹中查看，后缀是版
JDBC
JDBC一、JDBC概述什么是JDBC？JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码，真正执行的是各个数据库的实现类（驱动）。全称：（JavaDataBaseConnectivity）Java数据库连接。JDBC的好处面向接口编
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native