C访问MySQL数据库帮助类

　　MySQL数据库访问帮助类1。项目添加引用官方MySQL动态库MySql。Data。dll
　　下载地址：https：files。cnblogs。comfilesJiYFMySql。Data。zip（也可以到官网下载动态库）项目添加引用
　　这里有一个Mysql帮助类的使用例子可以参考
　　C简单三层结构设计UI、BLL、DAL2。web。config配置数据库连接字符串
　　1lt；？xmlversion1。0？2configuration34！连接字符串是否加密56！数据库连接字符串，（如果采用加密方式，上面一项要设置为true；加密工具，可在官方下载，7如果使用明文这样server127。0。0。1；database。。。。。，上面则设置为false。89appSettings10configuration
　　3。数据库字符串读取类（多一个加密算法，可以自己添加）
　　1publicclassPubConstant2｛3summary4获取连接字符串5summary6publicstaticstringConnectionString7｛8get9｛10stringconnectionStringConfigurationManager。AppSettings〔ConnectionString〕；11stringConStringEncryptConfigurationManager。AppSettings〔ConStringEncrypt〕；12if（ConStringEncrypttrue）13｛14connectionStringDESEncrypt。Decrypt（connectionString）；15｝16returnconnectionString；17｝18｝1920summary21得到web。config里配置项的数据库连接字符串。22summary23paramnameconfigNameparam24returnsreturns25publicstaticstringGetConnectionString（stringconfigName）26｛27stringconnectionStringConfigurationManager。AppSettings〔configName〕；28stringConStringEncryptConfigurationManager。AppSettings〔ConStringEncrypt〕；29if（ConStringEncrypttrue）30｛31connectionStringDESEncrypt。Decrypt（connectionString）；32｝33returnconnectionString；34｝353637｝
　　4。MySQL数据库访问类注意：对MySql。Data。MySqlClient引用
　　1usingSystem；2usingSystem。Collections；3usingSystem。Collections。Specialized；4usingSystem。Data；5usingMySql。Data。MySqlClient；6usingSystem。Configuration；7usingSystem。Data。Common；8usingSystem。Collections。Generic；9namespaceMaticsoft。DBUtility10｛11summary12数据访问抽象基础类13Copyright（C）Maticsoft14summary15publicabstractclassDbHelperMySQL16｛17数据库连接字符串（web。config来配置），可以动态更改connectionString支持多数据库。18publicstaticstringconnectionStringPubConstant。ConnectionString；19publicDbHelperMySQL（）20｛21｝2223region公用方法24summary25得到最大值26summary27paramnameFieldNameparam28paramnameTableNameparam29returnsreturns30publicstaticintGetMaxID（stringFieldName，stringTableName）31｛32stringstrsqlselectmax（FieldName）1fromTableName；33objectobjGetSingle（strsql）；34if（objnull）35｛36return1；37｝38else39｛40returnint。Parse（obj。ToString（））；41｝42｝43summary44是否存在45summary46paramnamestrSqlparam47returnsreturns48publicstaticboolExists（stringstrSql）49｛50objectobjGetSingle（strSql）；51intcmdresult；52if（（Object。Equals（obj，null））（Object。Equals（obj，System。DBNull。Value）））53｛54cmdresult0；55｝56else57｛58cmdresultint。Parse（obj。ToString（））；59｝60if（cmdresult0）61｛62returnfalse；63｝64else65｛66returntrue；67｝68｝69summary70是否存在（基于MySqlParameter）71summary72paramnamestrSqlparam73paramnamecmdParmsparam74returnsreturns75publicstaticboolExists（stringstrSql，paramsMySqlParameter〔〕cmdParms）76｛77objectobjGetSingle（strSql，cmdParms）；78intcmdresult；79if（（Object。Equals（obj，null））（Object。Equals（obj，System。DBNull。Value）））80｛81cmdresult0；82｝83else84｛85cmdresultint。Parse（obj。ToString（））；86｝87if（cmdresult0）88｛89returnfalse；90｝91else92｛93returntrue；94｝95｝96endregion9798region执行简单SQL语句99100summary101执行SQL语句，返回影响的记录数102summary103paramnameSQLStringSQL语句param104returns影响的记录数returns105publicstaticintExecuteSql（stringSQLString）106｛107using（MySqlConnectionconnectionnewMySqlConnection（connectionString））108｛109using（MySqlCommandcmdnewMySqlCommand（SQLString，connection））110｛111try112｛113connection。Open（）；114introwscmd。ExecuteNonQuery（）；115returnrows；116｝117catch（MySql。Data。MySqlClient。MySqlExceptione）118｛119connection。Close（）；120throwe；121｝122｝123｝124｝125126publicstaticintExecuteSqlByTime（stringSQLString，intTimes）127｛128using（MySqlConnectionconnectionnewMySqlConnection（connectionString））129｛130using（MySqlCommandcmdnewMySqlCommand（SQLString，connection））131｛132try133｛134connection。Open（）；135cmd。CommandTimeoutTimes；136introwscmd。ExecuteNonQuery（）；137returnrows；138｝139catch（MySql。Data。MySqlClient。MySqlExceptione）140｛141connection。Close（）；142throwe；143｝144｝145｝146｝147148summary149执行MySql和Oracle滴混合事务150summary151paramnamelistSQL命令行列表param152paramnameoracleCmdSqlListOracle命令行列表param153returns执行结果0由于SQL造成事务失败1由于Oracle造成事务失败1整体事务执行成功returns154publicstaticintExecuteSqlTran（ListCommandInfolist，ListCommandInfooracleCmdSqlList）155｛156using（MySqlConnectionconnnewMySqlConnection（connectionString））157｛158conn。Open（）；159MySqlCommandcmdnewMySqlCommand（）；160cmd。Connectionconn；161MySqlTransactiontxconn。BeginTransaction（）；162cmd。Transactiontx；163try164｛165foreach（CommandInfomyDEinlist）166｛167stringcmdTextmyDE。CommandText；168MySqlParameter〔〕cmdParms（MySqlParameter〔〕）myDE。Parameters；169PrepareCommand（cmd，conn，tx，cmdText，cmdParms）；170if（myDE。EffentNextTypeEffentNextType。SolicitationEvent）171｛172if（myDE。CommandText。ToLower（）。IndexOf（count（）1）173｛174tx。Rollback（）；175thrownewException（违背要求myDE。CommandText必须符合selectcount（。。的格式）；176return0；177｝178179objectobjcmd。ExecuteScalar（）；180boolisHavefalse；181if（objnullobjDBNull。Value）182｛183isHavefalse；184｝185isHaveConvert。ToInt32（obj）0；186if（isHave）187｛188引发事件189myDE。OnSolicitationEvent（）；190｝191｝192if（myDE。EffentNextTypeEffentNextType。WhenHaveContinemyDE。EffentNextTypeEffentNextType。WhenNoHaveContine）193｛194if（myDE。CommandText。ToLower（）。IndexOf（count（）1）195｛196tx。Rollback（）；197thrownewException（SQL：违背要求myDE。CommandText必须符合selectcount（。。的格式）；198return0；199｝200201objectobjcmd。ExecuteScalar（）；202boolisHavefalse；203if（objnullobjDBNull。Value）204｛205isHavefalse；206｝207isHaveConvert。ToInt32（obj）0；208209if（myDE。EffentNextTypeEffentNextType。WhenHaveContine！isHave）210｛211tx。Rollback（）；212thrownewException（SQL：违背要求myDE。CommandText返回值必须大于0）；213return0；214｝215if（myDE。EffentNextTypeEffentNextType。WhenNoHaveContineisHave）216｛217tx。Rollback（）；218thrownewException（SQL：违背要求myDE。CommandText返回值必须等于0）；219return0；220｝221continue；222｝223intvalcmd。ExecuteNonQuery（）；224if（myDE。EffentNextTypeEffentNextType。ExcuteEffectRowsval0）225｛226tx。Rollback（）；227thrownewException（SQL：违背要求myDE。CommandText必须有影响行）；228return0；229｝230cmd。Parameters。Clear（）；231｝232stringoraConnectionStringPubConstant。GetConnectionString（ConnectionStringPPC）；233boolresOracleHelper。ExecuteSqlTran（oraConnectionString，oracleCmdSqlList）；234if（！res）235｛236tx。Rollback（）；237thrownewException（执行失败）；238return1；239｝240tx。Commit（）；241return1；242｝243catch（MySql。Data。MySqlClient。MySqlExceptione）244｛245tx。Rollback（）；246throwe；247｝248catch（Exceptione）249｛250tx。Rollback（）；251throwe；252｝253｝254｝255summary256执行多条SQL语句，实现数据库事务。257summary258paramnameSQLStringList多条SQL语句param259publicstaticintExecuteSqlTran（ListStringSQLStringList）260｛261using（MySqlConnectionconnnewMySqlConnection（connectionString））262｛263conn。Open（）；264MySqlCommandcmdnewMySqlCommand（）；265cmd。Connectionconn；266MySqlTransactiontxconn。BeginTransaction（）；267cmd。Transactiontx；268try269｛270intcount0；271for（intn0；nSQLStringList。Count；n）272｛273stringstrsqlSQLStringList〔n〕；274if（strsql。Trim（）。Length1）275｛276cmd。CommandTextstrsql；277countcmd。ExecuteNonQuery（）；278｝279｝280tx。Commit（）；281returncount；282｝283catch284｛285tx。Rollback（）；286return0；287｝288｝289｝290summary291执行带一个存储过程参数的的SQL语句。292summary293paramnameSQLStringSQL语句param294paramnamecontent参数内容，比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加param295returns影响的记录数returns296publicstaticintExecuteSql（stringSQLString，stringcontent）297｛298using（MySqlConnectionconnectionnewMySqlConnection（connectionString））299｛300MySqlCommandcmdnewMySqlCommand（SQLString，connection）；301MySql。Data。MySqlClient。MySqlParametermyParameternewMySql。Data。MySqlClient。MySqlParameter（content，SqlDbType。NText）；302myParameter。Valuecontent；303cmd。Parameters。Add（myParameter）；304try305｛306connection。Open（）；307introwscmd。ExecuteNonQuery（）；308returnrows；309｝310catch（MySql。Data。MySqlClient。MySqlExceptione）311｛312throwe；313｝314finally315｛316cmd。Dispose（）；317connection。Close（）；318｝319｝320｝321summary322执行带一个存储过程参数的的SQL语句。323summary324paramnameSQLStringSQL语句param325paramnamecontent参数内容，比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加param326returns影响的记录数returns327publicstaticobjectExecuteSqlGet（stringSQLString，stringcontent）328｛329using（MySqlConnectionconnectionnewMySqlConnection（connectionString））330｛331MySqlCommandcmdnewMySqlCommand（SQLString，connection）；332MySql。Data。MySqlClient。MySqlParametermyParameternewMySql。Data。MySqlClient。MySqlParameter（content，SqlDbType。NText）；333myParameter。Valuecontent；334cmd。Parameters。Add（myParameter）；335try336｛337connection。Open（）；338objectobjcmd。ExecuteScalar（）；339if（（Object。Equals（obj，null））（Object。Equals（obj，System。DBNull。Value）））340｛341returnnull；342｝343else344｛345returnobj；346｝347｝348catch（MySql。Data。MySqlClient。MySqlExceptione）349｛350throwe；351｝352finally353｛354cmd。Dispose（）；355connection。Close（）；356｝357｝358｝359summary360向数据库里插入图像格式的字段（和上面情况类似的另一种实例）361summary362paramnamestrSQLSQL语句param363paramnamefs图像字节，数据库的字段类型为image的情况param364returns影响的记录数returns365publicstaticintExecuteSqlInsertImg（stringstrSQL，byte〔〕fs）366｛367using（MySqlConnectionconnectionnewMySqlConnection（connectionString））368｛369MySqlCommandcmdnewMySqlCommand（strSQL，connection）；370MySql。Data。MySqlClient。MySqlParametermyParameternewMySql。Data。MySqlClient。MySqlParameter（fs，SqlDbType。Image）；371myParameter。Valuefs；372cmd。Parameters。Add（myParameter）；373try374｛375connection。Open（）；376introwscmd。ExecuteNonQuery（）；377returnrows；378｝379catch（MySql。Data。MySqlClient。MySqlExceptione）380｛381throwe；382｝383finally384｛385cmd。Dispose（）；386connection。Close（）；387｝388｝389｝390391summary392执行一条计算查询结果语句，返回查询结果（object）。393summary394paramnameSQLString计算查询结果语句param395returns查询结果（object）returns396publicstaticobjectGetSingle（stringSQLString）397｛398using（MySqlConnectionconnectionnewMySqlConnection（connectionString））399｛400using（MySqlCommandcmdnewMySqlCommand（SQLString，connection））401｛402try403｛404connection。Open（）；405objectobjcmd。ExecuteScalar（）；406if（（Object。Equals（obj，null））（Object。Equals（obj，System。DBNull。Value）））407｛408returnnull；409｝410else411｛412returnobj；413｝414｝415catch（MySql。Data。MySqlClient。MySqlExceptione）416｛417connection。Close（）；418throwe；419｝420｝421｝422｝423publicstaticobjectGetSingle（stringSQLString，intTimes）424｛425using（MySqlConnectionconnectionnewMySqlConnection（connectionString））426｛427using（MySqlCommandcmdnewMySqlCommand（SQLString，connection））428｛429try430｛431connection。Open（）；432cmd。CommandTimeoutTimes；433objectobjcmd。ExecuteScalar（）；434if（（Object。Equals（obj，null））（Object。Equals（obj，System。DBNull。Value）））435｛436returnnull；437｝438else439｛440returnobj；441｝442｝443catch（MySql。Data。MySqlClient。MySqlExceptione）444｛445connection。Close（）；446throwe；447｝448｝449｝450｝451summary452执行查询语句，返回MySqlDataReader（注意：调用该方法后，一定要对MySqlDataReader进行Close）453summary454paramnamestrSQL查询语句param455returnsMySqlDataReaderreturns456publicstaticMySqlDataReaderExecuteReader（stringstrSQL）457｛458MySqlConnectionconnectionnewMySqlConnection（connectionString）；459MySqlCommandcmdnewMySqlCommand（strSQL，connection）；460try461｛462connection。Open（）；463MySqlDataReadermyReadercmd。ExecuteReader（CommandBehavior。CloseConnection）；464returnmyReader；465｝466catch（MySql。Data。MySqlClient。MySqlExceptione）467｛468throwe；469｝470471｝472summary473执行查询语句，返回DataSet474summary475paramnameSQLString查询语句param476returnsDataSetreturns477publicstaticDataSetQuery（stringSQLString）478｛479using（MySqlConnectionconnectionnewMySqlConnection（connectionString））480｛481DataSetdsnewDataSet（）；482try483｛484connection。Open（）；485MySqlDataAdaptercommandnewMySqlDataAdapter（SQLString，connection）；486command。Fill（ds，ds）；487｝488catch（MySql。Data。MySqlClient。MySqlExceptionex）489｛490thrownewException（ex。Message）；491｝492returnds；493｝494｝495publicstaticDataSetQuery（stringSQLString，intTimes）496｛497using（MySqlConnectionconnectionnewMySqlConnection（connectionString））498｛499DataSetdsnewDataSet（）；500try501｛502connection。Open（）；503MySqlDataAdaptercommandnewMySqlDataAdapter（SQLString，connection）；504command。SelectCommand。CommandTimeoutTimes；505command。Fill（ds，ds）；506｝507catch（MySql。Data。MySqlClient。MySqlExceptionex）508｛509thrownewException（ex。Message）；510｝511returnds；512｝513｝514515516517endregion518519region执行带参数的SQL语句520521summary522执行SQL语句，返回影响的记录数523summary524paramnameSQLStringSQL语句param525returns影响的记录数returns526publicstaticintExecuteSql（stringSQLString，paramsMySqlParameter〔〕cmdParms）527｛528using（MySqlConnectionconnectionnewMySqlConnection（connectionString））529｛530using（MySqlCommandcmdnewMySqlCommand（））531｛532try533｛534PrepareCommand（cmd，connection，null，SQLString，cmdParms）；535introwscmd。ExecuteNonQuery（）；536cmd。Parameters。Clear（）；537returnrows；538｝539catch（MySql。Data。MySqlClient。MySqlExceptione）540｛541throwe；542｝543｝544｝545｝546547548summary549执行多条SQL语句，实现数据库事务。550summary551paramnameSQLStringListSQL语句的哈希表（key为sql语句，value是该语句的MySqlParameter〔〕）param552publicstaticvoidExecuteSqlTran（HashtableSQLStringList）553｛554using（MySqlConnectionconnnewMySqlConnection（connectionString））555｛556conn。Open（）；557using（MySqlTransactiontransconn。BeginTransaction（））558｛559MySqlCommandcmdnewMySqlCommand（）；560try561｛562循环563foreach（DictionaryEntrymyDEinSQLStringList）564｛565stringcmdTextmyDE。Key。ToString（）；566MySqlParameter〔〕cmdParms（MySqlParameter〔〕）myDE。Value；567PrepareCommand（cmd，conn，trans，cmdText，cmdParms）；568intvalcmd。ExecuteNonQuery（）；569cmd。Parameters。Clear（）；570｝571trans。Commit（）；572｝573catch574｛575trans。Rollback（）；576throw；577｝578｝579｝580｝581summary582执行多条SQL语句，实现数据库事务。583summary584paramnameSQLStringListSQL语句的哈希表（key为sql语句，value是该语句的MySqlParameter〔〕）param585publicstaticintExecuteSqlTran（System。Collections。Generic。ListCommandInfocmdList）586｛587using（MySqlConnectionconnnewMySqlConnection（connectionString））588｛589conn。Open（）；590using（MySqlTransactiontransconn。BeginTransaction（））591｛592MySqlCommandcmdnewMySqlCommand（）；593try594｛intcount0；595循环596foreach（CommandInfomyDEincmdList）597｛598stringcmdTextmyDE。CommandText；599MySqlParameter〔〕cmdParms（MySqlParameter〔〕）myDE。Parameters；600PrepareCommand（cmd，conn，trans，cmdText，cmdParms）；601602if（myDE。EffentNextTypeEffentNextType。WhenHaveContinemyDE。EffentNextTypeEffentNextType。WhenNoHaveContine）603｛604if（myDE。CommandText。ToLower（）。IndexOf（count（）1）605｛606trans。Rollback（）；607return0；608｝609610objectobjcmd。ExecuteScalar（）；611boolisHavefalse；612if（objnullobjDBNull。Value）613｛614isHavefalse；615｝616isHaveConvert。ToInt32（obj）0；617618if（myDE。EffentNextTypeEffentNextType。WhenHaveContine！isHave）619｛620trans。Rollback（）；621return0；622｝623if（myDE。EffentNextTypeEffentNextType。WhenNoHaveContineisHave）624｛625trans。Rollback（）；626return0；627｝628continue；629｝630intvalcmd。ExecuteNonQuery（）；631countval；632if（myDE。EffentNextTypeEffentNextType。ExcuteEffectRowsval0）633｛634trans。Rollback（）；635return0；636｝637cmd。Parameters。Clear（）；638｝639trans。Commit（）；640returncount；641｝642catch643｛644trans。Rollback（）；645throw；646｝647｝648｝649｝650summary651执行多条SQL语句，实现数据库事务。652summary653paramnameSQLStringListSQL语句的哈希表（key为sql语句，value是该语句的MySqlParameter〔〕）param654publicstaticvoidExecuteSqlTranWithIndentity（System。Collections。Generic。ListCommandInfoSQLStringList）655｛656using（MySqlConnectionconnnewMySqlConnection（connectionString））657｛658conn。Open（）；659using（MySqlTransactiontransconn。BeginTransaction（））660｛661MySqlCommandcmdnewMySqlCommand（）；662try663｛664intindentity0；665循环666foreach（CommandInfomyDEinSQLStringList）667｛668stringcmdTextmyDE。CommandText；669MySqlParameter〔〕cmdParms（MySqlParameter〔〕）myDE。Parameters；670foreach（MySqlParameterqincmdParms）671｛672if（q。DirectionParameterDirection。InputOutput）673｛674q。Valueindentity；675｝676｝677PrepareCommand（cmd，conn，trans，cmdText，cmdParms）；678intvalcmd。ExecuteNonQuery（）；679foreach（MySqlParameterqincmdParms）680｛681if（q。DirectionParameterDirection。Output）682｛683indentityConvert。ToInt32（q。Value）；684｝685｝686cmd。Parameters。Clear（）；687｝688trans。Commit（）；689｝690catch691｛692trans。Rollback（）；693throw；694｝695｝696｝697｝698summary699执行多条SQL语句，实现数据库事务。700summary701paramnameSQLStringListSQL语句的哈希表（key为sql语句，value是该语句的MySqlParameter〔〕）param702publicstaticvoidExecuteSqlTranWithIndentity（HashtableSQLStringList）703｛704using（MySqlConnectionconnnewMySqlConnection（connectionString））705｛706conn。Open（）；707using（MySqlTransactiontransconn。BeginTransaction（））708｛709MySqlCommandcmdnewMySqlCommand（）；710try711｛712intindentity0；713循环714foreach（DictionaryEntrymyDEinSQLStringList）715｛716stringcmdTextmyDE。Key。ToString（）；717MySqlParameter〔〕cmdParms（MySqlParameter〔〕）myDE。Value；718foreach（MySqlParameterqincmdParms）719｛720if（q。DirectionParameterDirection。InputOutput）721｛722q。Valueindentity；723｝724｝725PrepareCommand（cmd，conn，trans，cmdText，cmdParms）；726intvalcmd。ExecuteNonQuery（）；727foreach（MySqlParameterqincmdParms）728｛729if（q。DirectionParameterDirection。Output）730｛731indentityConvert。ToInt32（q。Value）；732｝733｝734cmd。Parameters。Clear（）；735｝736trans。Commit（）；737｝738catch739｛740trans。Rollback（）；741throw；742｝743｝744｝745｝746summary747执行一条计算查询结果语句，返回查询结果（object）。748summary749paramnameSQLString计算查询结果语句param750returns查询结果（object）returns751publicstaticobjectGetSingle（stringSQLString，paramsMySqlParameter〔〕cmdParms）752｛753using（MySqlConnectionconnectionnewMySqlConnection（connectionString））754｛755using（MySqlCommandcmdnewMySqlCommand（））756｛757try758｛759PrepareCommand（cmd，connection，null，SQLString，cmdParms）；760objectobjcmd。ExecuteScalar（）；761cmd。Parameters。Clear（）；762if（（Object。Equals（obj，null））（Object。Equals（obj，System。DBNull。Value）））763｛764returnnull；765｝766else767｛768returnobj；769｝770｝771catch（MySql。Data。MySqlClient。MySqlExceptione）772｛773throwe；774｝775｝776｝777｝778779summary780执行查询语句，返回MySqlDataReader（注意：调用该方法后，一定要对MySqlDataReader进行Close）781summary782paramnamestrSQL查询语句param783returnsMySqlDataReaderreturns784publicstaticMySqlDataReaderExecuteReader（stringSQLString，paramsMySqlParameter〔〕cmdParms）785｛786MySqlConnectionconnectionnewMySqlConnection（connectionString）；787MySqlCommandcmdnewMySqlCommand（）；788try789｛790PrepareCommand（cmd，connection，null，SQLString，cmdParms）；791MySqlDataReadermyReadercmd。ExecuteReader（CommandBehavior。CloseConnection）；792cmd。Parameters。Clear（）；793returnmyReader；794｝795catch（MySql。Data。MySqlClient。MySqlExceptione）796｛797throwe；798｝799finally800｛801cmd。Dispose（）；802connection。Close（）；803｝804805｝806807summary808执行查询语句，返回DataSet809summary810paramnameSQLString查询语句param811returnsDataSetreturns812publicstaticDataSetQuery（stringSQLString，paramsMySqlParameter〔〕cmdParms）813｛814using（MySqlConnectionconnectionnewMySqlConnection（connectionString））815｛816MySqlCommandcmdnewMySqlCommand（）；817PrepareCommand（cmd，connection，null，SQLString，cmdParms）；818using（MySqlDataAdapterdanewMySqlDataAdapter（cmd））819｛820DataSetdsnewDataSet（）；821try822｛823da。Fill（ds，ds）；824cmd。Parameters。Clear（）；825｝826catch（MySql。Data。MySqlClient。MySqlExceptionex）827｛828thrownewException（ex。Message）；829｝830returnds；831｝832｝833｝834835836privatestaticvoidPrepareCommand（MySqlCommandcmd，MySqlConnectionconn，MySqlTransactiontrans，stringcmdText，MySqlParameter〔〕cmdParms）837｛838if（conn。State！ConnectionState。Open）839conn。Open（）；840cmd。Connectionconn；841cmd。CommandTextcmdText；842if（trans！null）843cmd。Transactiontrans；844cmd。CommandTypeCommandType。Text；cmdType；845if（cmdParms！null）846｛847848849foreach（MySqlParameterparameterincmdParms）850｛851if（（parameter。DirectionParameterDirection。InputOutputparameter。DirectionParameterDirection。Input）852（parameter。Valuenull））853｛854parameter。ValueDBNull。Value；855｝856cmd。Parameters。Add（parameter）；857｝858｝859｝860861endregion862863864865｝866867｝