溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》
您好，登錄后才能下訂單哦！
本篇內(nèi)容主要講解“JDBC Template如何使用”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“JDBC Template如何使用”吧!
Spring為開發(fā)者提供了JDBCTemplate，可以簡化很多數(shù)據(jù)庫操作相關(guān)的代碼，本文主要介紹JDBCTemplate的使用以及事務(wù)管理功能。
JDBC Template配置的話主要配置以下幾項：
數(shù)據(jù)源：org.springframework.jdbc.datasource.DriverManager.DataSource
數(shù)據(jù)庫驅(qū)動：com.cj.mysql.jdbc.Driver，這里采用的是MySQL 8，注意MySQL 5.7以下的驅(qū)動名字不同，另外若是其他數(shù)據(jù)庫請對應(yīng)修改
數(shù)據(jù)庫URL：jdbc:mysql://localhost:3306/test，MySQL默認的3306端口，數(shù)據(jù)庫test
數(shù)據(jù)庫用戶名
數(shù)據(jù)庫密碼
JDBC模板：org.springframework.jdbc.core.jdbcTemplate
參考配置如下：
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/test"/> <property name="username" value="test"/> <property name="password" value="test"/> </bean> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dataSource"/> </bean> <context:component-scan base-package="pers.dao"/>
int update(String sql,Object args[])：增/刪/改操作，使用args設(shè)置其中的參數(shù)，返回更新的行數(shù)
List<T> query(String sql,RowMapper<T> rowMapper,Object []args)：查詢操作，rowMapper將結(jié)果集映射到用戶自定義的類中
首先導(dǎo)入依賴：
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>5.2.9.RELEASE</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.21</version> </dependency>
MySQL的版本請根據(jù)個人需要更改，或使用其他數(shù)據(jù)庫的驅(qū)動。
完整配置文件如下：
<?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" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd"> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/test"/> <property name="username" value="test"/> <property name="password" value="test"/> </bean> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dataSource"/> </bean> <context:component-scan base-package="pers.dao"/> </beans>
public class MyUser {
private Integer id;
private String uname;
private String usex;
}添加@Repository以及@RequiredArgsConstructor：
@Repository
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class TestDao {
private final JdbcTemplate template;
public int update(String sql,Object[] args)
{
return template.update(sql,args);
}
public List<MyUser> query(String sql, Object[] args)
{
RowMapper<MyUser> mapper = new BeanPropertyRowMapper<>(MyUser.class);
return template.query(sql,mapper,args);
}
}因為直接使用@Autowired的話會提示不推薦：
所以利用了Lombok的注解@RequiredArgsConstructor，效果相當如下構(gòu)造方法，只不過是簡化了一點：
@Autowired
public TestDao(JdbcTemplate template)
{
this.template = template;
}測試之前先建表：
create table MyUser( id INT AUTO_INCREMENT PRIMARY KEY , uname varchar(20), usex varchar(20) )
測試類：
public class Main {
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
TestDao dao = (TestDao)context.getBean("testDao");
String insertSql = "insert into MyUser(uname,usex) values(?,?)";
String[] param1 = {"chenhengfa1","男"};
String[] param2 = {"chenhengfa2","男"};
String[] param3 = {"chenhengfa3","男"};
String[] param4 = {"chenhengfa4","男"};
dao.update(insertSql,param1);
dao.update(insertSql,param2);
dao.update(insertSql,param3);
dao.update(insertSql,param4);
String selectSql = "select * from MyUser";
List<MyUser> list = dao.query(selectSql,null);
for(MyUser mu:list)
{
System.out.println(mu);
}
}
}輸出：
如果出現(xiàn)異?；虿迦氩怀晒Φ绕渌闆r，請檢查SQL語句是否編寫正確，包括表名以及字段名。
Spring中的事務(wù)管理有兩種方法：
編程式事務(wù)管理：代碼中顯式調(diào)用beginTransaction、commit、rollback等就是編程式事務(wù)管理
聲明式事務(wù)管理：通過AOP實現(xiàn)，不需要通過編程方式管理事務(wù)，因此不需要再業(yè)務(wù)邏輯代碼中摻雜事務(wù)處理的代碼，開發(fā)更加簡單，便于后期維護
下面先來看一下編程式事務(wù)管理的實現(xiàn)。
編程式事務(wù)管理的配置又有兩種方法：
基于底層API
基于TransactionTemplate
需要的依賴如下：
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>5.2.9.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-expression</artifactId> <version>5.2.9.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>5.2.9.RELEASE</version> </dependency> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> <version>1.9.6</version> <scope>runtime</scope> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>5.2.9.RELEASE</version> </dependency>
API實現(xiàn)根據(jù)PlatformTransactionManager、TransactionDefinition、TransactionStatus幾個核心接口，通過編程方式進行事務(wù)管理，首先配置事務(wù)管理器：
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean>
接著修改數(shù)據(jù)庫訪問類：
@Repository
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class TestDao {
private final JdbcTemplate template;
private final DataSourceTransactionManager manager;
public int update(String sql,Object[] args)
{
return template.update(sql,args);
}
public List<MyUser> query(String sql,Object[] args)
{
RowMapper<MyUser> mapper = new BeanPropertyRowMapper<>(MyUser.class);
return template.query(sql,mapper,args);
}
public void testTransaction()
{
TransactionDefinition definition = new DefaultTransactionDefinition();
TransactionStatus status = manager.getTransaction(definition);
String message = "執(zhí)行成功，沒有事務(wù)回滾";
try
{
String sql1 = "delete from MyUser";
String sql2 = "insert into MyUser(id,uname,usex) values(?,?,?)";
Object [] param2 = {1,"張三","男"};
template.update(sql1);
template.update(sql2,param2);
template.update(sql2,param2);
manager.commit(status);
}
catch (Exception e)
{
e.printStackTrace();
manager.rollback(status);
message = "主鍵重復(fù)，事務(wù)回滾";
}
System.out.println(message);
}
}TransactionDefinition是事務(wù)定義，是一個接口：
主要定義了：
事務(wù)隔離級別
事務(wù)傳播行為
事務(wù)超時時間
是否為只讀事務(wù)
而DefaultTransactionDefinition就是上面屬性的一些默認配置，比如：
也就是定義了：
傳播行為為0：也就是常量PROPAGATION_REQUIREDE，表示如果當前存在一個事務(wù)，則加入當前事務(wù)，如果不存在任何事務(wù)，就創(chuàng)建一個新事務(wù)
隔離級別為-1：這個也是TransactionDefinition的默認參數(shù)，表示使用數(shù)據(jù)庫的默認隔離級別，通常情況下為Read Committed
超時為-1：默認設(shè)置不超時，如需要設(shè)置超時請調(diào)用setTimeout方法，比如如果設(shè)置為了60，那么相當于如果操作時間超過了60s，而且后面還涉及到CRUD操作，那么會拋出超時異常并回滾，如果超時操作的后面沒有涉及到CRUD操作，那么不會回滾
只讀事務(wù)為false：默認為false，但是該變量不是表明“不能”進行修改等操作，而是一種暗示，如果不包含修改操作，那么JDBC驅(qū)動和數(shù)據(jù)庫就有可能針對該事務(wù)進行一些特定的優(yōu)化
具體執(zhí)行流程如下：
定義事務(wù)：實例類為DefaultTransactionDefinition
開啟事務(wù)：通過getTransaction(TransactionDefinition)開啟
執(zhí)行業(yè)務(wù)方法
根據(jù)業(yè)務(wù)方法是否出現(xiàn)異常手動調(diào)用DataSourceTransaction的commit(TransactionStatus)進行提交
出現(xiàn)異常調(diào)用rollback(TransactionStatus)進行回滾
測試如下：
TransactionTemplate步驟：
通過調(diào)用TransactionTemplate的execute實現(xiàn)
execute接受一個TransactionCallback接口參數(shù)
TransactionCallback定義了一個doInTransaction方法
通常以匿名內(nèi)部類的方式實現(xiàn)TransactionCallback接口，在其中的doInTransaction編寫業(yè)務(wù)邏輯代碼
doInTransaction有一個TransactionStatus的參數(shù)，可以調(diào)用setRollbackOnly進行回滾
默認的回滾規(guī)則如下：
如果拋出未檢查異?；蛘呤謩诱{(diào)用setRollbackOnly，則回滾
如果執(zhí)行完成或拋出檢查異常，則提交事務(wù)
示例如下，首先編寫配置文件對Bean進行注入：
<!--事務(wù)管理器--> <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!--事務(wù)模板--> <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate"> <property name="transactionManager" ref="txManager"/> </bean>
其次修改數(shù)據(jù)訪問類，添加一個測試方法：
public void testTransactionTemplate()
{
System.out.println(transactionTemplate.execute((TransactionCallback<Object>) transactionStatus -> {
String deleteSql = "delete from MyUser";
String insertSql = "insert into MyUser(id,uname,usex) values(?,?,?)";
Object[] parm = {1, "張三", "男"};
try {
template.update(deleteSql);
template.update(insertSql, parm);
template.update(insertSql, parm);
} catch (Exception e) {
message = "主鍵重復(fù)，事務(wù)回滾";
e.printStackTrace();
}
return message;
}));
}大部分代碼與第一個例子類似就不解釋了，結(jié)果也是因為主鍵重復(fù)出現(xiàn)異常，造成事務(wù)回滾：
Spring聲明式事務(wù)管理通過AOP實現(xiàn)，本質(zhì)是在方法前后進行攔截，在目標方法開始之前創(chuàng)建或加入一個事務(wù)，執(zhí)行目標方法完成之后根據(jù)執(zhí)行情況提交或回滾事務(wù)。相比起編程式事務(wù)管理，聲明式最大的優(yōu)點就是不需要通過編程的方式管理事務(wù)，業(yè)務(wù)邏輯代碼無需混雜事務(wù)代碼，但是唯一不足的地方就是最細粒度只能作用到方法上，而不能做到代碼塊級別。
實現(xiàn)方式有如下兩種：
基于XML實現(xiàn)
基于@Transactional實現(xiàn)
XMLSpring提供了tx命令空間來配置事務(wù)：
<tx:advice>：配置事務(wù)通知，一般需要指定id以及transaction-manager
<tx:attributes>：配置多個<tx:method>指定執(zhí)行事務(wù)的細節(jié)
完整配置文件如下：
<?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" xmlns:cache="http://www.springframework.org/schema/cache" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd" > <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/test"/> <property name="username" value="test"/> <property name="password" value="test"/> </bean> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dataSource"/> </bean> <context:component-scan base-package="pers.dao"/> <!--事務(wù)管理器--> <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate"> <property name="transactionManager" ref="txManager"/> </bean> <!--聲明式事務(wù)--> <tx:advice id="myAdvice" transaction-manager="txManager"> <tx:attributes> <!--任意方法--> <tx:method name="*" /> </tx:attributes> </tx:advice> <!--aop配置，具體可以看筆者之前的文章--> <aop:config> <!--定義切點，執(zhí)行testXMLTranscation()時進行增強--> <aop:pointcut id="txPointCut" expression="execution(* pers.dao.TestDao.testXMLTransaction())"/> <!--切面--> <aop:advisor advice-ref="myAdvice" pointcut-ref="txPointCut"/> </aop:config> </beans>
測試方法如下：
public void testXMLTransaction()
{
String deleteSql = "delete from MyUser";
String saveSql = "insert into MyUser(id,uname,usex) values(?,?,?)";
Object [] parm = {1,"張三","男"};
template.update(deleteSql);
template.update(saveSql,parm);
template.update(saveSql,parm);
}運行結(jié)果：
可以看到提示主鍵重復(fù)了。
@Transactional@Transactional一般作用于類上，使得該類所有public方法都具有該類型的事務(wù)屬性。下面創(chuàng)建一個示例。
將上一個例子中的<aop:config>以及<tx:advice>注釋掉，同時添加：
<!--事務(wù)管理的注解驅(qū)動器--> <tx:annotation-driven transaction-manager="txManager"/>
測試方法與上一個例子一致，結(jié)果也是如此：
到此，相信大家對“JDBC Template如何使用”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學習！
免責聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。
億速云公眾號
手機網(wǎng)站二維碼