課堂筆記spring事務(wù)傳播原理及數(shù)據(jù)庫操作

1、掌握Spring事務(wù)原理2、掌握基于Spring的數(shù)據(jù)庫事務(wù)操作原3、初步了解分布式1、適合有Spring開發(fā)經(jīng)驗(yàn)并且希望深度掌握事務(wù)控制原理的2、通過本章內(nèi)容的學(xué)習(xí)，能夠掌握基于SpringAOP的事務(wù)設(shè)計(jì)原理從Spring先看看Spring事務(wù)的基<<aop:aspectj-autoproxy-<bean <propertyname="dataSource"<tx:annotation-driventransaction-<!--<tx:methodname="add*"propagation="REQUIRED"<tx:methodname="remove*"propagation="REQUIRED"<tx:methodname="modify*"1rollback-rollback-<tx:methodname="login"<tx:methodname="query*"read-<aop:pointcutexpression="execution(public*com.gupaoedu.vip..*.service..*Service.*(..))"<aop:advisorpointcut-ref="transactionPointcut"advice-Spring事務(wù)管理基于AOP來實(shí)現(xiàn)，主要是封裝非功能性需求1、事務(wù)基本概點(diǎn)：事務(wù)是恢復(fù)和并發(fā)控制的基本單位。事務(wù)應(yīng)該具有4屬性：原子性、一致性、隔離性、持久性。這四個(gè)屬性通常稱為ACID特性。2對(duì)數(shù)據(jù)庫中數(shù)據(jù)的改變就應(yīng)該是性的。接下來的其他操作或故障不應(yīng)該對(duì)其有任何2、事務(wù)的基本原Spring事務(wù)的本質(zhì)其實(shí)就是數(shù)據(jù)庫對(duì)事務(wù)的支持，沒有數(shù)據(jù)庫的事務(wù)支持，Spring是無法提供事務(wù)功能的。對(duì)于純JDBC操作數(shù)據(jù)庫，想要用到事務(wù)，可以按照以下步驟進(jìn)行：1、獲取連接Connectioncon=DriverManager.getConnection()、開啟事務(wù) 3、執(zhí)行CRUD mit()/con.rollback();5、關(guān)閉連接conn.close();使用Spring的事務(wù)管理功能后，可以不再寫步驟2和4的代碼，而是由Spirng自動(dòng)完成。那么Spring是如何在書寫的CRUD之前和之后開啟事務(wù)和關(guān)閉事務(wù)的配置文件開啟注解驅(qū)動(dòng)，在相關(guān)的類和方法上通過注解@TransactionalSpring啟動(dòng)的時(shí)候會(huì)去解析生成相關(guān)的bean，這時(shí)候會(huì)查看擁有相關(guān)注解的類和方法，就在中為把相關(guān)的事務(wù)處理掉了（開啟正常提交事務(wù)，異常回滾事務(wù)）。真正的數(shù)據(jù)庫層的事務(wù)提交和回滾是通過binlog或者redolog實(shí)現(xiàn)的。3、Spring事務(wù)的屬3所謂spring事務(wù)的屬性，就是定義在存在多個(gè)事務(wù)同時(shí)存在的時(shí)候，spring應(yīng)該如常量名常量解默認(rèn)的事務(wù)的4DataSourceTransactionManager4、數(shù)據(jù)庫級(jí)級(jí)級(jí)別的導(dǎo)致的問0導(dǎo)致臟1避免臟讀，允許不可重復(fù)讀和Repeatable-2避免臟讀，不可重復(fù)讀，允許3串行化讀，事務(wù)只能一個(gè)一個(gè)執(zhí)行，避免總結(jié)5大多數(shù)的數(shù)據(jù)庫默認(rèn)級(jí)別為ReadCommited，比如SqlServer、Oracle少數(shù)數(shù)據(jù)庫默認(rèn)級(jí)別為：RepeatableRead比如：MySQL5、Spring中的級(jí)常解這是個(gè)PlatfromTransactionManager默認(rèn)的級(jí)別，使用數(shù)據(jù)庫默認(rèn)的事務(wù)級(jí)別。另外四個(gè)與JDBC的級(jí)別相應(yīng) 的一個(gè)級(jí)別會(huì)產(chǎn)生臟讀，不可重復(fù)讀和幻像保證一個(gè)事務(wù)修改的數(shù)據(jù)提交后才這是花費(fèi)最高代價(jià)但是最可靠的事務(wù)6、事務(wù)的嵌6點(diǎn)，接下來通過分析一些嵌套事務(wù)的場(chǎng)景，來深入理解Spring事務(wù)的機(jī)制。假設(shè)外層事務(wù)ServiceA的MethodA()調(diào)用內(nèi)層ServiceB的MethodB()PROPAGATION_REQUIRED(Spring默認(rèn))如果ServiceB.MethodB()的事務(wù)級(jí)別定義為PROPAGATION_REQUIRED，那么執(zhí)行ServiceA.MethodA()的時(shí)候Spring已經(jīng)起了事務(wù)，這時(shí)調(diào)用ServiceB.MethodB()，ServiceB.MethodB()看到自己已經(jīng)運(yùn)行在ServiceA.MethodA()的事務(wù)，就不再假如ServiceB.MethodB()運(yùn)行的時(shí)候發(fā)現(xiàn)自己沒有在事務(wù)中，他就會(huì)為自己分配一個(gè)這樣，在ServiceA.MethodA()或者在ServiceB.MethodB()內(nèi)的任何地方出現(xiàn)異常，比如設(shè)計(jì)ServiceA.MethodA()的事務(wù)級(jí)別為PROPAGATION_REQUIREDServiceB.MethodB()的事務(wù)級(jí)別為PROPAGATION_REQUIRES_NEW那么當(dāng)執(zhí)行到ServiceB.MethodB()的時(shí)候，ServiceA.MethodA()所在的事務(wù)就會(huì)掛起，ServiceB.MethodB()會(huì)起一個(gè)新的事務(wù)，等待ServiceB.MethodB()的事務(wù)完成他與PROPAGATION_REQUIRED的事務(wù)區(qū)別在于事務(wù)的回滾程度了。因?yàn)镾erviceB.MethodB()是新起一個(gè)事務(wù)，那么就是存在兩個(gè)不同的事務(wù)。如果ServiceB.MethodB()已經(jīng)提交，那么ServiceA.MethodA()失敗回滾，ServiceB.MethodB()是不會(huì)回滾的。如果ServiceB.MethodB()失敗回滾，如果他拋7出的異常被ServiceA.MethodA()獲，ServiceA.MethodA()事務(wù)仍然可能提交(主要看B拋出的異常是不是A會(huì)回滾的異常)。假設(shè)ServiceB.MethodB()的事務(wù)級(jí)別為PROPAGATION_SUPPORTS，那么當(dāng)執(zhí)行到ServiceB.MethodB()時(shí)，如果發(fā)現(xiàn)ServiceA.MethodA()已經(jīng)開啟了一個(gè)事務(wù)，則加入時(shí)候，方法的事務(wù)性完全依賴于最外層的事務(wù)。ServiceB.MethodB()的事務(wù)屬性被配置為PROPAGATION_NESTED,此時(shí)兩者之間又將如何協(xié)作呢?ServiceB.MethodB()如果rollback,那么事務(wù)(即ServiceB.MethodB())將回滾到它執(zhí)行前的SavePoint而外部事務(wù)(即ServiceA.MethodA())可以有以下兩種處理方式:void{try}void{try}catch(SomeException)執(zhí)行其他業(yè)務(wù)}}這種方式也是嵌套事務(wù)最有價(jià)值的地方,它起到了分支執(zhí)行的效果,如果ServiceB.MethodB()失敗,那么執(zhí)行ServiceC.MethodC(),而ServiceB.MethodB()已經(jīng)回滾到它執(zhí)行之前的SavePoint,所以不會(huì)產(chǎn)生臟數(shù)據(jù)(相當(dāng)于此方法從未執(zhí)行過),這種特性可以用在某些特殊的業(yè)務(wù)中,而PROPAGATION_REQUIRED和PROPAGATION_REQUIRES_NEW都沒有辦法做到這一點(diǎn)。8外部事務(wù)回滾/提交代碼不做任何修改,那么如果事務(wù)(ServiceB.MethodB())rollback,那么首先ServiceB.MethodB()回滾到它執(zhí)行之前的SavePoint(在任何情況下都會(huì)如此),外部事務(wù)(即ServiceA.MethodA())將根據(jù)具體的配置決定自己是commit還是rollback。另外三種事務(wù)屬性基本用不到，在此不做分析7、Spring務(wù)API使用Spring進(jìn)行基本的JDBC數(shù)據(jù)庫有多種選擇。Spring至少提供了三種不同的工作模式：JdbcTemplate,一個(gè)在Spring2.5中新提供的SimpleJdbc類能夠更好的處理數(shù)據(jù)庫元數(shù)據(jù);還有一種稱之為RDBMSObject的風(fēng)格的面象封裝方式,有點(diǎn)類似即使你選擇了其中的一種工作模式,你依然可以在你的代碼中混用其他任何一種模式以獲取其帶來的好處和優(yōu)勢(shì)。所有的工作模式都必須要求JDBC2.0以上的數(shù)據(jù)庫驅(qū)9動(dòng)的支持,其中一些高級(jí)的功能可能需要JDBC3.0以上的數(shù)據(jù)庫驅(qū)動(dòng)支持。JdbcTemplate-這是經(jīng)典的也是最常用的Spring對(duì)于JDBC的方案。這也是最低級(jí)別的封裝,其他的工作模式事實(shí)上在底層使用了JdbcTemplate作為其底層的實(shí)現(xiàn)基礎(chǔ)。JdbcTemplate在JDK1.4以上的環(huán)境上工作得很好。NamedParameterJdbcTemplateJdbcTemplate了封裝，提供了更加便捷的基于命名參數(shù)的使用方式而不是傳統(tǒng)的JDBC使用的“?”作為參數(shù)的占位符。這種方式在你需要為某個(gè)SQL許多個(gè)參數(shù)時(shí)，顯得更加直觀而易用。該特性必須工作在JDKSimpleJdbcTemplate-這個(gè)類結(jié)合了JdbcTemplate和所帶來的優(yōu)勢(shì)，例如泛型、varargsautoboxing從而提供了更加簡便API方式。需要工作在Java5以上的環(huán)境中。SimpleJdbcInsert和SimpleJdbcCall-這兩個(gè)類可以充分利用數(shù)據(jù)庫元數(shù)據(jù)的特性來簡化配置。通過使用這兩個(gè)類進(jìn)行編程，你可以僅僅提供數(shù)據(jù)庫表名或者過程的名稱以及一個(gè)Map作為參數(shù)。其中Map的key需要與數(shù)據(jù)庫表中的字段保持一致。這兩個(gè)類通常和SimpleJdbcTemplate合使用。這兩個(gè)類需要工JDK5上，同時(shí)數(shù)RDBMS對(duì)象包括MapSqlQuery,SqlUpdateandStoredProcedure-這種方式允許你在初始化你的數(shù)據(jù)層時(shí)創(chuàng)建可重用并且線程安全的對(duì)象。該對(duì)象在你定義了你的查詢語句，查詢參數(shù)并編譯相應(yīng)的Query之后被模型化。一旦模型化完成，任何執(zhí)行函數(shù)就可以傳入不同的參數(shù)對(duì)之進(jìn)行多次調(diào)用。這種方式需要工作在JDK1.4以異常處異常結(jié)構(gòu)如下SQLExceptionTranslator是一個(gè)接口，如果你需要 SQLException.springframework.dao.DataAccessException之間作轉(zhuǎn)換，那么必須實(shí)現(xiàn)該接口。轉(zhuǎn)換器類的實(shí)現(xiàn)可以采用一般通用的做法(比如使用JDBC的SQLStatecode)，如果為了使轉(zhuǎn)換更準(zhǔn)確，也可以進(jìn)行定制（比如使用Oracle的errorcode）。SQLErrorCodeSQLExceptionTranslator是SQLExceptionTranslator的默認(rèn)實(shí)現(xiàn)。該實(shí)現(xiàn)使用指定數(shù)據(jù)庫廠商的errorcode，比采用SQLState更精確。轉(zhuǎn)換過程基于一個(gè)JavaBean（類型為SQLErrorCodes）中的errorcode。 這個(gè)JavaBean由SQLErrorCodesFactory工廠類創(chuàng)建，其中的內(nèi)容來自于“sql-error-codes.xml”配置文件。該文件中的數(shù)據(jù)庫廠商代碼基于 DatabaseMetaData 信息中的SQLErrorCodeSQLExceptionTranslator使用以下的匹配規(guī)則：首先檢查是否存在完成定制轉(zhuǎn)換的子類實(shí)現(xiàn)。通常SQLErrorCodeSQLExceptionTranslator這個(gè)類可以作為一個(gè)具體類使用，不需要進(jìn)行接著將SQLException的errorcode與錯(cuò)誤代碼集中的errorcode進(jìn)行匹配。默認(rèn)情況下錯(cuò)誤代碼集將從SQLErrorCodesFactory取得。錯(cuò)誤代碼集來自classpath下的。使用fallback翻譯器。SQLStateSQLExceptionTranslator類是缺省的fallback翻譯器configNamespaceHandler接口，DefaultBeanDefinition Reader使用該接口來處理在springxml配置文件中自定義名空間。publicamespaceHandlerextendsNamespaceHandlerSupportpublicvoidinit()registerBeanDefinitionParser("embedded-database",newpublicamespaceHandlerextendsNamespaceHandlerSupportpublicvoidinit()registerBeanDefinitionParser("embedded-database",newEmbeddedDatabaseBeanDefinitionParser());registerBeanDefinitionParser("initialize-database",newInitializeDatabaseBeanDefinitionParser());}} BeanDefinitionParser，解析<embedded-database>元素，并使用EmbeddedDatabaseFactoryBean創(chuàng)建一個(gè)BeanDefinition。順便介紹一下用到的件 .w3c.dom包.w3c.dom:為文檔對(duì)象模型(DOM)提供接口，該模型是JavaAPIforXMLProcessing的組件API。該 ObjectModelLevel2CoreAPI允許程序動(dòng)Attr：Attr接口表示Element象中的屬性CDATASection：CDATA用于轉(zhuǎn)義文本塊，該文本塊包含的字符如果不轉(zhuǎn)義則會(huì)被CharacterData：CharacterData接口使用屬性集合和用于DOM中字符數(shù)據(jù)的Comment：此接口繼承自CharacterData示注釋的內(nèi)容，即起始結(jié)束>'之間的所有字符 接口表示整個(gè)HTML或XML文檔。 Fragment是“輕量級(jí)”或“最小” 對(duì)象。Type：每個(gè) 都有doctype屬性，該屬性的值可以為null，也可以為 Type對(duì)象。DOMConfiguration：該DOMConfiguration接口表示文檔的配置，并一個(gè)可識(shí)：DOMErrorHandler：DOMErrorHandler是在報(bào)告處理XML數(shù)據(jù)時(shí)發(fā)生的錯(cuò)誤或在進(jìn)行某些其他處理（如驗(yàn)證文檔）時(shí)DOM實(shí)現(xiàn)可以調(diào)用的回調(diào)接口。DOMImplementation：DOMImplementation口為執(zhí)行獨(dú)立于文檔對(duì)象模型的任DOMImplementationList：DOMImplementationList接口提供對(duì)DOM實(shí)現(xiàn)的有DOMImplementationSource：此接口允許DOM現(xiàn)程序根據(jù)請(qǐng)求的功能和版本提DOMLocator：DOMLocator是一個(gè)描述位置（如發(fā)生錯(cuò)誤的位置）的接口。DOMStringList：DOMStringList接口提供對(duì)DOMString的有序集合的抽象，沒Element：Element接口表示HTML或XML文檔中的一個(gè)元素。Entity：此接口表示在XML文檔中解析和未解析的已知實(shí)體。EntityReference：EntityReference節(jié)點(diǎn)可以用來在樹中表示實(shí)體。NamedNodeMap：實(shí)現(xiàn)NamedNodeMap口的對(duì)象用于表示可以通過名稱NameListNameList口提供對(duì)并行的名稱和名稱空間值對(duì)（可以為null值）的有序Node：該Node個(gè)文檔對(duì)象模型的主要數(shù)據(jù)類型NodeList：NodeList口提供對(duì)節(jié)點(diǎn)的有序集合的抽象，沒有定義或約束如何實(shí)現(xiàn)此Notation：此接口表示在DTD中的表示法ProcessingInstruction：ProcessingInstruction口表示“處理指令”，該指令作為一種在文檔的文本中保持特定于處理器的信息的方法在XML中使用。Text：該Text接口繼承自CharacterData，并且表示Element或Attr的文本（在XML中稱為字符數(shù)據(jù)）TypeInfo：TypeInfo接口表示從Element或Attr節(jié)點(diǎn)的類型，用與文檔相關(guān)UserDataHandler：當(dāng)使用Node.setUserData()一個(gè)對(duì)象與節(jié)點(diǎn)上的鍵相關(guān)聯(lián)時(shí)，JdbcTeamplate元數(shù)據(jù)metaData模本節(jié)中Spring應(yīng)用到工廠模式，結(jié)合代碼可以更具體CallMetaDataProviderFactory創(chuàng)建CallMetaDataProvider的工廠類，其代碼publicpublicstaticfinalList<String>supportedDatabaseProductsForProcedures=Arrays.asList("ApacheDerby", /**ListofsupporteddatabaseproductsforfunctioncallspublicstaticfinalList<String>supportedDatabaseProductsForFunctions=Arrays.asList("MySQL", SQLServer",staticpublicCallMetaDataProvidercreateMetaDataProvider(DataSourcedataSource,finalCallMetaD context){tryCallMetaDataProviderresult=(CallMetaDataProvider)JdbcUtils.extractDatabaseMetaData(dataSource,databaseMetaData->{StringdatabaseProductName= booleanaccessProcedureColumnMetaData=context.isAccessCallParameterMetaData();if(context.isFunction())if{if(logger.isWarnEnabled())""--supportedare:"+}if(accessProcedureColumnMetaData)logger.warn("Metadataprocessingdisabled-youmustspecifyallparametersexplicitly");accessProcedureColumnMetaData=false;}}}elseif{if(logger.isWarnEnabled())logger.warn(databaseProductName+"isnotoneofthedatabasesfullysupportedforcalls"}

"--supportedare:"+if(accessProcedureColumnMetaData)logger.warn("Metadataprocessingdisabled-youmustspecifyallparametersexplicitly");accessProcedureColumnMetaData=false;}}}CallMetaDataProviderif("Oracle".equals(databaseProductName))provider=new}elseif("DB2".equals(databaseProductName))provider=new}elseif("ApacheDerby".equals(databaseProductName))provider=new}elseif("PostgreSQL".equals(databaseProductName))provider=new}elseif("Sybase".equals(databaseProductName))provider=new}elseif SQL{provider=new}elseif("HDB".equals(databaseProductName))provider=new}elseprovider=new}if(logger.isDebugEnabled())logger.debug("Using"+}if(accessProcedureColumnMetaData){context.getCatalogName(),context.getSchemaName(),context.getProcedureName());}returnreturn}catch(MetaDataAccessExceptionex)thrownewDataAccessResourceFailureException("Errorretrievingdatabasemetadata",}}staticpublicCallMetaDataProvidercreateMetaDataProvider(DataSourcedataSource,staticpublicCallMetaDataProvidercreateMetaDataProvider(DataSourcedataSource,final {tryCallMetaDataProviderresult=(CallMetaDataProvider)JdbcUtils.extractDatabaseMetaData(dataSource,databaseMetaData->{StringdatabaseProductName= booleanaccessProcedureColumnMetaData=context.isAccessCallParameterMetaData();if(context.isFunction())if{if(logger.isWarnEnabled())""--supportedare:"+}if(accessProcedureColumnMetaData)logger.warn("Metadataprocessingdisabled-youmustspecifyallparametersexplicitly");accessProcedureColumnMetaData=false;}}}elseif{if(logger.isWarnEnabled())logger.warn(databaseProductName+"isnotoneofthedatabasesfullysupportedforcalls"}

"--supportedare:"+if(accessProcedureColumnMetaData)logger.warn("Metadataprocessingdisabled-youmustspecifyallparametersexplicitly");accessProcedureColumnMetaData=false;}}}CallMetaDataProviderif("Oracle".equals(databaseProductName))provider=new}elseif("DB2".equals(databaseProductName))provider=new}elseif("ApacheDerby".equals(databaseProductName))provider=new}elseif("PostgreSQL".equals(databaseProductName))provider=new}}elseif("Sybase".equals(databaseProductName))provider=new}elseif SQL{provider=new}elseif("HDB".equals(databaseProductName))provider=new}elseprovider=new}if(logger.isDebugEnabled())logger.debug("Using"+}if(accessProcedureColumnMetaData){context.getCatalogName(),context.getSchemaName(),context.getProcedureName());}returnreturn}catch(MetaDataAccessExceptionex)thrownewDataAccessResourceFailureException("Errorretrievingdatabasemetadata",}}使用SqlParameterSource提供參使用Map指定參數(shù)值有時(shí)候工作得非常好，但是這并不是最簡單的使用方式。Spring提供了一些其他的SqlParameterSource實(shí)現(xiàn)類來指定參數(shù)值。首先BeanPropertySqlParameterSource，這是一個(gè)非常簡便的指定參數(shù)的實(shí)現(xiàn)類，只要你有一個(gè)符合JavaBean規(guī)范的類就行了。它將使用其中的getter方法來獲取參數(shù)值。SqlParameter封裝了定義sql參數(shù)的對(duì)象。CallableStateMentCallback，PrePareStateMentCallback，StateMentCallback，ConnectionCallback回調(diào)類分別對(duì)應(yīng)JdbcTemplate中的不同處理方法。simple實(shí)Spring過DataSource取數(shù)據(jù)庫的連接。Datasource是jdbc范的一部分，它通過ConnectionFactory獲取。一個(gè)容器和框架可以在應(yīng)用代碼層中隱藏連接池和事當(dāng)使用springjdbc層，你可以通過JNDI來獲取DataSource，也可以通過你自己配置的第連接池實(shí)現(xiàn)來獲取。流行的第實(shí)現(xiàn)由apacheJakartaCommonsdbcp和c3p0。TransactionAwareDataSourceProxy作為目標(biāo)DataSource的一個(gè)，在對(duì)目標(biāo)DataSource裝的同時(shí)，還增Spring事務(wù)管理能這一點(diǎn)上，這個(gè)類的功能非常像J2EE服務(wù)器所提供的事務(wù)化的JNDIDataSource。該類幾乎很少被用到，除非現(xiàn)有代碼在被調(diào)用的時(shí)候需要一個(gè)JDBCDataSource接口實(shí)現(xiàn)作為參數(shù)。這種情況下，這個(gè)類可以使現(xiàn)有代碼參與Spring的事務(wù)管理。通常最好的做法是使用更的抽象來對(duì)數(shù)據(jù)源進(jìn)行管理，比如JdbcTemplate和DataSourceUtils等等。object?；藢?duì)JDBC的使用。它還可以幫助避免一些常見的錯(cuò)誤，比如忘記關(guān)閉數(shù)據(jù)庫連接。JdbcTemplate將完成JDBC處理/r/