12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883 |
- using System;
- using System.Data;
- using System.Data.SqlClient;
- using System.Collections;
- using System.Collections.Generic;
- using Common.Model;
- namespace ZcPeng.PublicLibrary
- {
-
-
-
-
-
-
-
- public static class DataAccess
- {
-
-
-
-
- public static int NTextSize = 100000000;
-
-
-
- public static string connectionString;
-
-
-
- public static int BulkCopyTimeout = 60;
-
-
-
-
-
-
-
- public static bool GetDataTable(string selectCommandText, DataTable dt, out string result)
- {
- bool bSuccessed = false;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- if (dt == null)
- {
- bSuccessed = false;
- result = "参数错误:dt不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlDataAdapter da = new SqlDataAdapter(selectCommandText, conn);
- try
- {
- conn.Open();
- da.SelectCommand.CommandType = CommandType.Text;
- da.Fill(dt);
- bSuccessed = true;
- result = "已经成功的获取了数据表。";
- }
- catch (Exception e)
- {
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
-
- public static bool GetDataTable(string strConn, string selectCommandText, DataTable dt, SqlParameter[] parameters, out string result)
- {
- bool bSuccessed = false;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- if (dt == null)
- {
- bSuccessed = false;
- result = "参数错误:dt不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(strConn);
- SqlDataAdapter da = new SqlDataAdapter(selectCommandText, conn);
- try
- {
- conn.Open();
- da.SelectCommand.CommandType = CommandType.Text;
- if (parameters != null && parameters.Length > 0)
- da.SelectCommand.Parameters.AddRange(parameters);
- da.Fill(dt);
- bSuccessed = true;
- result = "已经成功的获取了数据表。";
- }
- catch (Exception e)
- {
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (da != null && da.SelectCommand != null && da.SelectCommand.Parameters.Count > 0)
- da.SelectCommand.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
-
-
- public static int GetDataTable(List<string> connectionStringList, string selectCommandText, ref DataTable dt, List<SqlParameter> parameters, out string result)
- {
- int successedServerCount = 0;
- result = "";
- if (selectCommandText == "")
- {
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- if (connectionStringList == null || connectionStringList.Count == 0)
- {
- result = "数据库连接字符串列表不能为空。";
- }
- else
- {
- dt = null;
- foreach (string connectionString in connectionStringList)
- {
- DataTable dtTemp = new DataTable();
- if (GetDataTable(connectionString, selectCommandText, dtTemp, (parameters != null && parameters.Count > 0) ? parameters.ToArray() : null, out result))
- {
- if (dtTemp != null)
- {
- if (DataTableEx.Merge(ref dt, dtTemp))
- successedServerCount++;
- }
- }
- }
- }
- }
- return successedServerCount;
- }
-
-
-
-
-
-
-
-
-
-
-
- public static int GetDataTable(List<string> connectionStringList, string selectCommandText, ref DataTable dt, List<SqlParameter> parameters, out string result, string keyColumnName)
- {
- List<string> keyColumnNames = new List<string>(1);
- keyColumnNames.Add(keyColumnName);
- return GetDataTable(connectionStringList, selectCommandText, ref dt, parameters, out result, keyColumnNames);
- }
-
-
-
-
-
-
-
-
-
-
-
- public static int GetDataTable(List<string> connectionStringList, string selectCommandText, ref DataTable dt, List<SqlParameter> parameters, out string result, List<string> keyColumnNames)
- {
- int successedServerCount = 0;
- result = "";
- if (selectCommandText == "")
- {
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- if (connectionStringList == null || connectionStringList.Count == 0)
- {
- result = "数据库连接字符串列表不能为空。";
- }
- else if (keyColumnNames == null || keyColumnNames.Count == 0)
- {
- result = "关键列列表不能为空。";
- }
- else
- {
- dt = null;
- foreach (string connectionString in connectionStringList)
- {
- DataTable dtTemp = new DataTable();
- if (GetDataTable(connectionString, selectCommandText, dtTemp, (parameters != null && parameters.Count > 0) ? parameters.ToArray() : null, out result))
- {
- if (dtTemp != null)
- {
- if (DataTableEx.Summarize(ref dt, dtTemp, keyColumnNames))
- successedServerCount++;
- }
- }
- }
- }
- }
- return successedServerCount;
- }
-
-
-
-
-
-
-
-
- public static bool GetDataTable(string selectCommandText, DataTable dt, SqlParameter[] parameters, out string result)
- {
- bool bSuccessed = false;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- if (dt == null)
- {
- bSuccessed = false;
- result = "参数错误:dt不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlDataAdapter da = new SqlDataAdapter(selectCommandText, conn);
- try
- {
- conn.Open();
- da.SelectCommand.CommandType = CommandType.Text;
- if (parameters != null && parameters.Length > 0)
- da.SelectCommand.Parameters.AddRange(parameters);
- da.Fill(dt);
- bSuccessed = true;
- result = "已经成功的获取了数据表。";
- }
- catch (Exception e)
- {
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (da != null && da.SelectCommand != null && da.SelectCommand.Parameters.Count > 0)
- da.SelectCommand.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
- public static bool GetDataTable(string selectCommandText, DataTable dt, List<SqlParameter> parameters, out string result)
- {
- return GetDataTable(selectCommandText, dt, parameters.ToArray(), out result);
- }
-
-
-
-
-
-
-
-
- public static bool GetOneValue(string selectCommandText, out object objValue, out string result,SqlConnection conn = null, SqlTransaction trans = null, bool needTransOut = false)
- {
- bool bSuccessed = false;
- objValue = null;
- result = "";
-
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- conn = new SqlConnection(connectionString);
- conn.Open();
- trans = conn.BeginTransaction();
- SqlCommand cmd = new SqlCommand(selectCommandText, conn, trans);
- try
- {
- cmd.CommandType = CommandType.Text;
- objValue = cmd.ExecuteScalar();
- bSuccessed = true;
- result = "已经成功的获取了数据。";
- if(!needTransOut)
- trans.Commit();
- }
- catch (Exception e)
- {
- trans.Rollback();
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (needTransOut)
- {
- }
- else {
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
-
- public static bool GetOneValue(string selectCommandText, SqlParameter[] parameters, out object objValue, out string result)
- {
- bool bSuccessed = false;
- objValue = null;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- conn.Open();
- SqlTransaction trans = conn.BeginTransaction();
- SqlCommand cmd = new SqlCommand(selectCommandText, conn, trans);
- try
- {
- cmd.CommandType = CommandType.Text;
- if (parameters != null && parameters.Length > 0)
- cmd.Parameters.AddRange(parameters);
- objValue = cmd.ExecuteScalar();
- bSuccessed = true;
- result = "已经成功的获取了数据。";
- trans.Commit();
- }
- catch (Exception e)
- {
- trans.Rollback();
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
-
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
- public static bool GetOneValue(string selectCommandText, SqlParameter[] parameters, out object objValue, out string result, out SqlConnection conn, out SqlTransaction trans, bool needTransOut = false)
- {
- bool bSuccessed = false;
- objValue = null;
- result = "";
- conn = null;
- trans = null;
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- conn = new SqlConnection(connectionString);
- conn.Open();
- trans = conn.BeginTransaction();
- SqlCommand cmd = new SqlCommand(selectCommandText, conn, trans);
- try
- {
- cmd.CommandType = CommandType.Text;
- if (parameters != null && parameters.Length > 0)
- cmd.Parameters.AddRange(parameters);
- objValue = cmd.ExecuteScalar();
- bSuccessed = true;
- result = "已经成功的获取了数据。";
- if (!needTransOut)
- trans.Commit();
- }
- catch (Exception e)
- {
- trans.Rollback();
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (needTransOut)
- {
- }
- else
- {
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
-
- public static bool GetOneValue(string strConn, string selectCommandText, SqlParameter[] parameters, out object objValue, out string result)
- {
- bool bSuccessed = false;
- objValue = null;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(strConn);
- SqlCommand cmd = new SqlCommand(selectCommandText, conn);
- try
- {
- conn.Open();
- cmd.CommandType = CommandType.Text;
- if (parameters != null && parameters.Length > 0)
- cmd.Parameters.AddRange(parameters);
- objValue = cmd.ExecuteScalar();
- bSuccessed = true;
- result = "已经成功的获取了数据。";
- }
- catch (Exception e)
- {
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
- public static bool GetOneValue(string selectCommandText, List<SqlParameter> parameters, out object objValue, out string result)
- {
- return GetOneValue(selectCommandText, parameters.ToArray(), out objValue, out result);
- }
-
-
-
-
-
-
-
- public static int ExecuteCommand(string connectionString,string commandText, out string result)
- {
- int recordsAffected = 0;
- result = "";
- if (commandText == "")
- {
- result = "参数错误:SQL语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlCommand cmd = new SqlCommand(commandText, conn);
- try
- {
- conn.Open();
- cmd.CommandType = CommandType.Text;
- recordsAffected = cmd.ExecuteNonQuery();
- if (recordsAffected > 0)
- result = "已经成功的影响了" + recordsAffected + "条记录。";
- }
- catch (Exception e)
- {
- result = "在执行数据操作时发生错误。\r\nSQL语句:" + commandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return recordsAffected;
- }
-
-
-
-
-
-
-
- public static int ExecuteCommand( string commandText, out string result)
- {
- return ExecuteCommand(connectionString,commandText, out result);
- }
-
-
-
-
-
-
-
-
- public static int ExecuteCommand(string connectionString,string commandText, List<SqlParameter> parameters, out string result)
- {
- int recordsAffected = 0;
- result = "";
- if (commandText == "")
- {
- result = "参数错误:SQL语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlCommand cmd = new SqlCommand(commandText, conn);
- try
- {
- conn.Open();
- cmd.CommandType = CommandType.Text;
- if (parameters != null && parameters.Count > 0)
- cmd.Parameters.AddRange(parameters.ToArray());
- recordsAffected = cmd.ExecuteNonQuery();
- if (recordsAffected > 0)
- result = "已经成功的影响了" + recordsAffected + "条记录。";
- }
- catch (Exception e)
- {
- result = "在执行数据操作时发生错误。\r\nSQL语句:" + commandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return recordsAffected;
- }
-
-
-
-
-
-
-
-
- public static int ExecuteCommand(string commandText, List<SqlParameter> parameters, out string result)
- {
- return ExecuteCommand(connectionString,commandText, parameters,out result);
- }
-
-
-
-
-
-
-
-
- public static int ExecuteCommand(string commandText, SqlParameter[] parameters, out string result)
- {
- return ExecuteCommand(commandText, new List<SqlParameter>(parameters), out result);
- }
-
-
-
-
-
-
-
-
- public static int ExecuteCommand(string connectionString, string commandText, SqlParameter[] parameters, out string result)
- {
- return ExecuteCommand(connectionString,commandText, new List<SqlParameter>(parameters), out result);
- }
-
-
-
-
-
-
-
-
- public static int ExecuteCommand(string commandText, List<SqlParameter> parameters, CommandType commandType, out string result)
- {
- int recordsAffected = 0;
- result = "";
- if (commandText == "")
- {
- result = "参数错误:SQL语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlCommand cmd = new SqlCommand(commandText, conn);
- try
- {
- conn.Open();
- cmd.CommandType = commandType;
- if (parameters != null && parameters.Count > 0)
- cmd.Parameters.AddRange(parameters.ToArray());
- recordsAffected = cmd.ExecuteNonQuery();
- if (recordsAffected > 0)
- result = "已经成功的影响了" + recordsAffected + "条记录。";
- }
- catch (Exception e)
- {
- result = "在执行数据操作时发生错误。\r\nSQL语句:" + commandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return recordsAffected;
- }
-
-
-
-
-
-
-
-
-
-
- public static int ExecuteCommand(string strConn, string commandText, List<SqlParameter> parameters, CommandType commandType, out string result)
- {
- int recordsAffected = 0;
- result = "";
- if (commandText == "")
- {
- result = "参数错误:SQL语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(strConn);
- SqlCommand cmd = new SqlCommand(commandText, conn);
- try
- {
- conn.Open();
- cmd.CommandType = commandType;
- if (parameters != null && parameters.Count > 0)
- cmd.Parameters.AddRange(parameters.ToArray());
- recordsAffected = cmd.ExecuteNonQuery();
- if (recordsAffected > 0)
- result = "已经成功的影响了" + recordsAffected + "条记录。";
- }
- catch (Exception e)
- {
- result = "在执行数据操作时发生错误。\r\nSQL语句:" + commandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return recordsAffected;
- }
-
-
-
-
-
-
-
-
-
- public static List<int> ExecuteCommand(List<string> connectionStringList, DataAccessCommand dac, bool needAllDone, out string result)
- {
- result = "";
- if (connectionStringList == null || connectionStringList.Count == 0)
- {
- result = "数据库连接字符串列表为空。";
- return null;
- }
-
- int serverCount = connectionStringList.Count;
- List<SqlConnection> connList = new List<SqlConnection>(serverCount);
- List<SqlTransaction> transList = new List<SqlTransaction>(serverCount);
- List<SqlCommand> cmdList = new List<SqlCommand>(serverCount);
- List<int> recordsAffectedList = new List<int>(serverCount);
- bool transCommit = true;
-
- for (int i = 0; i < serverCount; i++)
- {
- connList.Add(null);
- transList.Add(null);
- cmdList.Add(null);
- recordsAffectedList.Add(0);
- try
- {
- if (string.IsNullOrEmpty(connectionStringList[i]))
- {
- result = string.Format("第{0}个数据库连接字符串为空。", i);
- }
- else
- {
- connList[i] = new SqlConnection(connectionStringList[i]);
- connList[i].Open();
- transList[i] = connList[i].BeginTransaction();
- cmdList[i] = new SqlCommand(dac.CommandText, connList[i], transList[i]);
- cmdList[i].CommandType = dac.CommandType;
- if (dac.ParamList != null && dac.ParamList.Count > 0)
- cmdList[i].Parameters.AddRange(dac.ParamList.ToArray());
- recordsAffectedList[i] = cmdList[i].ExecuteNonQuery();
- }
- }
- catch (Exception e)
- {
- result = "在服务器(" + connectionStringList[i] + ")执行数据操作时发生错误。\r\nSQL语句:" + dac.CommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmdList[i] != null && cmdList[i].Parameters.Count > 0)
- cmdList[i].Parameters.Clear();
- }
- if (needAllDone)
- {
- if (dac.RecordsAffectedLargeThanZeroIsSuccessful && recordsAffectedList[i] <= 0)
- {
- transCommit = false;
- break;
- }
- }
- }
-
- foreach (SqlTransaction trans in transList)
- {
- if (trans != null)
- {
- if (transCommit)
- trans.Commit();
- else
- trans.Rollback();
- }
- }
- foreach (SqlConnection conn in connList)
- {
- if (conn != null && conn.State != ConnectionState.Closed)
- conn.Close();
- }
- return recordsAffectedList;
- }
-
-
-
-
-
-
-
- public static bool ExecuteBatchCommands(List<DataAccessCommand> commands, out string result, SqlConnection conn1 = null, SqlTransaction trans1 = null,bool needCommitNow = true)
- {
- bool successed = false;
- result = "";
- SqlConnection conn;
- SqlTransaction trans = null;
- if (conn1 == null) {
- conn = new SqlConnection(connectionString);
- }else
- {
- conn = conn1;
- }
-
- SqlCommand cmd = new SqlCommand("", conn,trans);
- try
- {
- if (conn1 == null)
- {
- conn.Open();
- }
- if (trans1 == null)
- {
- trans = conn.BeginTransaction();
- }
- else
- {
- trans = trans1;
- }
- cmd.Transaction = trans;
- int executedCommands = 0;
- int i = 1;
-
- foreach (DataAccessCommand command in commands)
- {
- cmd.CommandType = command.CommandType;
- cmd.CommandText = command.CommandText;
- cmd.Parameters.Clear();
- if (command.ParamList != null && command.ParamList.Count > 0)
- cmd.Parameters.AddRange(command.ParamList.ToArray());
- int recordsAffected = cmd.ExecuteNonQuery();
- if (recordsAffected <= 0)
- result += $"在执行第{i}条返回false。\r\n recordsAffected:" + recordsAffected +"/n ";
- i++;
- if (command.RecordsAffectedLargeThanZeroIsSuccessful)
- {
-
- if (recordsAffected > 0)
- executedCommands++;
- else
- break;
- }
- else
- executedCommands++;
- }
- if (needCommitNow)
- {
- if (executedCommands == commands.Count)
- {
- trans.Commit();
- successed = true;
- }
- else
- trans.Rollback();
- }
- result += $"需要执行{commands.Count}条 /n";
- result += $"共执行了{executedCommands}条 /n";
- }
- catch (Exception e)
- {
- result = "在执行数据操作时发生错误。\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- try
- {
- if (needCommitNow)
- {
- trans.Rollback();
- }
- }
- catch
- {
- }
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (needCommitNow)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return successed;
- }
-
-
-
-
-
-
-
- public static bool ExecuteBatchCommands(string strConn, List<DataAccessCommand> commands, out string result)
- {
- bool successed = false;
- result = "";
- SqlConnection conn = new SqlConnection(strConn);
- SqlTransaction trans = null;
- SqlCommand cmd = new SqlCommand("", conn);
- try
- {
- conn.Open();
- trans = conn.BeginTransaction();
- cmd.Transaction = trans;
- int executedCommands = 0;
- foreach (DataAccessCommand command in commands)
- {
- cmd.CommandType = command.CommandType;
- cmd.CommandText = command.CommandText;
- cmd.Parameters.Clear();
- if (command.ParamList != null && command.ParamList.Count > 0)
- cmd.Parameters.AddRange(command.ParamList.ToArray());
- int recordsAffected = cmd.ExecuteNonQuery();
- if (command.RecordsAffectedLargeThanZeroIsSuccessful)
- {
-
- if (recordsAffected > 0)
- executedCommands++;
- else
- break;
- }
- else
- executedCommands++;
- }
- if (executedCommands == commands.Count)
- {
- trans.Commit();
- successed = true;
- }
- else
- trans.Rollback();
- }
- catch (Exception e)
- {
- result = "在执行数据操作时发生错误。\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- try
- {
- trans.Rollback();
- }
- catch
- {
- }
- }
- finally
- {
- if (cmd != null && cmd.Parameters.Count > 0)
- cmd.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- return successed;
- }
-
-
-
-
-
-
-
-
-
- public static List<bool> ExecuteBatchCommands(List<string> connectionStringList, List<DataAccessCommand> dacList, bool needAllDone, out string result)
- {
- result = "";
- if (connectionStringList == null || connectionStringList.Count == 0)
- {
- result = "数据库连接字符串列表为空。";
- return null;
- }
- if (dacList == null || dacList.Count == 0)
- {
- result = "命令列表为空。";
- return null;
- }
-
- int serverCount = connectionStringList.Count;
- List<SqlConnection> connList = new List<SqlConnection>(serverCount);
- List<SqlTransaction> transList = new List<SqlTransaction>(serverCount);
- List<SqlCommand> cmdList = new List<SqlCommand>(serverCount);
- List<bool> successList = new List<bool>(serverCount);
- List<bool> transCommitList = new List<bool>(serverCount);
- bool allDone = true;
-
- for (int i = 0; i < serverCount; i++)
- {
- connList.Add(null);
- transList.Add(null);
- cmdList.Add(null);
- successList.Add(false);
- transCommitList.Add(false);
- int executedCommands = 0;
- successList[i] = false;
- try
- {
- if (string.IsNullOrEmpty(connectionStringList[i]))
- {
- result = string.Format("第{0}个数据库连接字符串为空。", i);
- }
- else
- {
- connList[i] = new SqlConnection(connectionStringList[i]);
- connList[i].Open();
- transList[i] = connList[i].BeginTransaction();
- cmdList[i] = new SqlCommand("", connList[i], transList[i]);
- foreach (DataAccessCommand dac in dacList)
- {
- cmdList[i].CommandText = dac.CommandText;
- cmdList[i].CommandType = dac.CommandType;
- if (dac.ParamList != null && dac.ParamList.Count > 0)
- {
- cmdList[i].Parameters.Clear();
- cmdList[i].Parameters.AddRange(dac.ParamList.ToArray());
- }
- int recordsAffected = cmdList[i].ExecuteNonQuery();
- if (dac.RecordsAffectedLargeThanZeroIsSuccessful)
- {
-
- if (recordsAffected > 0)
- executedCommands++;
- else
- break;
- }
- else
- executedCommands++;
- }
- if (executedCommands == dacList.Count)
- {
- transCommitList[i] = true;
- successList[i] = true;
- }
- else
- {
- transCommitList[i] = false;
- successList[i] = false;
- }
- }
- }
- catch (Exception e)
- {
- result = "在服务器(" + connectionStringList[i] + ")执行数据操作时发生错误。\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (cmdList[i] != null && cmdList[i].Parameters.Count > 0)
- cmdList[i].Parameters.Clear();
- }
- if (needAllDone)
- {
- if (successList[i] == false)
- {
- allDone = false;
- break;
- }
- }
- }
-
- for (int i = 0; i < connList.Count; i++)
- {
- if (needAllDone && allDone == false)
- transCommitList[i] = false;
- if (transList[i] != null)
- {
- if (transCommitList[i])
- transList[i].Commit();
- else
- transList[i].Rollback();
- }
- if (connList[i] != null && connList[i].State != ConnectionState.Closed)
- {
- connList[i].Close();
- connList[i] = null;
- }
- }
- return successList;
- }
-
-
-
-
-
-
-
-
-
-
-
- public static bool BulkCopy(string strConn, DataTable dtSrc, string destTableName, List<SqlBulkCopyColumnMapping> columnMappings, BulkCopyTransType transType, SqlBulkCopyOptions options, int timeout)
- {
- bool bSuccessed = false;
- if (dtSrc != null && dtSrc.Rows != null && dtSrc.Rows.Count > 0 && destTableName != null && destTableName != "" && timeout > 0)
- {
- SqlConnection conn = null;
- SqlTransaction trans = null;
- SqlBulkCopy sbc = null;
- try
- {
-
- if (transType == BulkCopyTransType.None)
- {
- sbc = new SqlBulkCopy(strConn, options);
- }
- else if (transType == BulkCopyTransType.Internal)
- {
- sbc = new SqlBulkCopy(strConn, options | SqlBulkCopyOptions.UseInternalTransaction);
- }
- else
- {
- conn = new SqlConnection(strConn);
- conn.Open();
- trans = conn.BeginTransaction();
- sbc = new SqlBulkCopy(conn, options, trans);
- }
-
- sbc.BulkCopyTimeout = timeout;
-
- sbc.DestinationTableName = destTableName;
-
- if (columnMappings != null && columnMappings.Count > 0)
- {
- foreach (SqlBulkCopyColumnMapping columnMapping in columnMappings)
- {
- sbc.ColumnMappings.Add(columnMapping);
- }
- }
- sbc.WriteToServer(dtSrc);
- if (trans != null)
- trans.Commit();
- bSuccessed = true;
- }
- catch
- {
- bSuccessed = false;
- if (trans != null)
- trans.Rollback();
- }
- finally
- {
- if (sbc != null)
- sbc.Close();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
-
-
- public static bool BulkCopy(DataTable dtSrc, string destTableName, List<SqlBulkCopyColumnMapping> columnMappings, BulkCopyTransType transType, SqlBulkCopyOptions options, int timeout)
- {
- bool bSuccessed = false;
- if (dtSrc != null && dtSrc.Rows != null && dtSrc.Rows.Count > 0 && destTableName != null && destTableName != "" && timeout > 0)
- {
- SqlConnection conn = null;
- SqlTransaction trans = null;
- SqlBulkCopy sbc = null;
- try
- {
-
- if (transType == BulkCopyTransType.None)
- {
- sbc = new SqlBulkCopy(DataAccess.connectionString, options);
- }
- else if (transType == BulkCopyTransType.Internal)
- {
- sbc = new SqlBulkCopy(DataAccess.connectionString, options | SqlBulkCopyOptions.UseInternalTransaction);
- }
- else
- {
- conn = new SqlConnection(DataAccess.connectionString);
- conn.Open();
- trans = conn.BeginTransaction();
- sbc = new SqlBulkCopy(conn, options, trans);
- }
-
- sbc.BulkCopyTimeout = timeout;
-
- sbc.DestinationTableName = destTableName;
-
- if (columnMappings != null && columnMappings.Count > 0)
- {
- foreach (SqlBulkCopyColumnMapping columnMapping in columnMappings)
- {
- sbc.ColumnMappings.Add(columnMapping);
- }
- }
- sbc.WriteToServer(dtSrc);
- if (trans != null)
- trans.Commit();
- bSuccessed = true;
- }
- catch
- {
- bSuccessed = false;
- if (trans != null)
- trans.Rollback();
- }
- finally
- {
- if (sbc != null)
- sbc.Close();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return bSuccessed;
- }
-
- public static bool BulkCopy(DataTable dtSrc, string destTableName)
- {
- return BulkCopy(dtSrc, destTableName, null, BulkCopyTransType.None, SqlBulkCopyOptions.Default, BulkCopyTimeout);
- }
- public static bool BulkCopy(DataTable dtSrc, string destTableName, List<SqlBulkCopyColumnMapping> columnMappings)
- {
- return BulkCopy(dtSrc, destTableName, columnMappings, BulkCopyTransType.None, SqlBulkCopyOptions.Default, BulkCopyTimeout);
- }
- public static bool BulkCopy(DataTable dtSrc, string destTableName, List<SqlBulkCopyColumnMapping> columnMappings, BulkCopyTransType transType)
- {
- return BulkCopy(dtSrc, destTableName, columnMappings, transType, SqlBulkCopyOptions.Default, BulkCopyTimeout);
- }
- public static bool BulkCopy(DataTable dtSrc, string destTableName, List<SqlBulkCopyColumnMapping> columnMappings, BulkCopyTransType transType, SqlBulkCopyOptions options)
- {
- return BulkCopy(dtSrc, destTableName, columnMappings, transType, options, BulkCopyTimeout);
- }
-
-
-
-
-
-
-
-
- public static int GetRowCount(string tableName, string filter, bool distinct, out string result)
- {
- int rowCount = -1;
- string selectCommandText = "SELECT " + (distinct ? "DISTINCT" : "") + " COUNT(*) FROM [" + tableName + "]";
- if (filter != "")
- selectCommandText += " WHERE " + filter;
- object objValue;
- if (DataAccess.GetOneValue(selectCommandText, out objValue, out result))
- {
- if (!Convert.IsDBNull(objValue))
- rowCount = (int)objValue;
- }
- return rowCount;
- }
- public static int GetRowCount(string tableName, string filter, out string result)
- {
- return GetRowCount(tableName, filter, false, out result);
- }
- public static int GetRowCount(string tableName, string filter)
- {
- string result;
- return GetRowCount(tableName, filter, false, out result);
- }
- public static int GetRowCount(string tableName)
- {
- string result;
- return GetRowCount(tableName, "", false, out result);
- }
-
-
-
-
-
-
-
-
-
-
-
-
- public static DataTable GetDataTable(string tableName, string primaryKey, string fields, string filter, string group, string sort, int pageNumber, int pageSize,out string result)
- {
-
- string commandText = "EXECUTE SP_Pagination @Tables,@PrimaryKey,@Sort,@CurrentPage,@PageSize,@Fields,@Filter,@Group";
-
- List<SqlParameter> paramList = new List<SqlParameter>(5);
- SqlParameter p;
- p = new SqlParameter("@Tables", SqlDbType.NVarChar, 1000);
- p.Value = tableName;
- paramList.Add(p);
- p = new SqlParameter("@PrimaryKey", SqlDbType.NVarChar, 100);
- p.Value = primaryKey;
- paramList.Add(p);
- p = new SqlParameter("@Sort", SqlDbType.NVarChar, 200);
- p.Value = sort;
- paramList.Add(p);
- p = new SqlParameter("@CurrentPage", SqlDbType.Int, 4);
- p.Value = pageNumber;
- paramList.Add(p);
- p = new SqlParameter("@PageSize", SqlDbType.Int, 4);
- p.Value = pageSize;
- paramList.Add(p);
- p = new SqlParameter("@Fields", SqlDbType.NVarChar, 1000);
- p.Value = fields;
- paramList.Add(p);
- p = new SqlParameter("@Filter", SqlDbType.NVarChar, 1000);
- p.Value = filter;
- paramList.Add(p);
- p = new SqlParameter("@Group", SqlDbType.NVarChar, 1000);
- p.Value = group;
- paramList.Add(p);
-
-
- DataTable dt = new DataTable();
-
- if (!DataAccess.GetDataTable(commandText, dt, paramList, out result))
- dt = null;
- return dt;
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
- public static DataTable GetDataTable(string strConn, string tableName, string primaryKey, string fields, string filter, string group, string sort, int pageNumber, int pageSize)
- {
-
- string commandText = "EXECUTE SP_Pagination @Tables,@PrimaryKey,@Sort,@CurrentPage,@PageSize,@Fields,@Filter,@Group";
-
- List<SqlParameter> paramList = new List<SqlParameter>(5);
- SqlParameter p;
- p = new SqlParameter("@Tables", SqlDbType.NVarChar, 1000);
- p.Value = tableName;
- paramList.Add(p);
- p = new SqlParameter("@PrimaryKey", SqlDbType.NVarChar, 100);
- p.Value = primaryKey;
- paramList.Add(p);
- p = new SqlParameter("@Sort", SqlDbType.NVarChar, 200);
- p.Value = sort;
- paramList.Add(p);
- p = new SqlParameter("@CurrentPage", SqlDbType.Int, 4);
- p.Value = pageNumber;
- paramList.Add(p);
- p = new SqlParameter("@PageSize", SqlDbType.Int, 4);
- p.Value = pageSize;
- paramList.Add(p);
- p = new SqlParameter("@Fields", SqlDbType.NVarChar, 1000);
- p.Value = fields;
- paramList.Add(p);
- p = new SqlParameter("@Filter", SqlDbType.NVarChar, 1000);
- p.Value = filter;
- paramList.Add(p);
- p = new SqlParameter("@Group", SqlDbType.NVarChar, 1000);
- p.Value = group;
- paramList.Add(p);
-
- string result;
- DataTable dt = new DataTable();
-
- if (!DataAccess.GetDataTable(strConn, commandText, dt, null, out result))
- dt = null;
- return dt;
- }
-
-
-
-
- public static List<SqlParameter> ToParameters(List<List<Object>> plist)
- {
- List<SqlParameter> parameters = new List<SqlParameter>(plist.Count);
- foreach (List<object> value in plist)
- {
- if (value[1] == null)
- {
- SqlParameter p = new SqlParameter("@" + value[0], DBNull.Value);
- parameters.Add(p);
- }
- else
- switch (value[1].GetType().ToString())
- {
- case "System.Guid":
- SqlParameter p = new SqlParameter("@" + value[0], SqlDbType.UniqueIdentifier, 16);
- p.Value = value[1];
- parameters.Add(p);
- break;
- case "System.Int64":
-
- p = new SqlParameter("@" + value[0], SqlDbType.BigInt);
- p.Value = (Int64)value[1];
- parameters.Add(p);
- break;
- case "System.Int32":
- p = new SqlParameter("@" + value[0], SqlDbType.Int, 4);
- p.Value = (Int32)value[1];
- parameters.Add(p);
- break;
- case "System.Int16":
- p = new SqlParameter("@" + value[0], SqlDbType.Int, 2);
- p.Value = (Int16)value[1];
- parameters.Add(p);
- break;
- case "System.Boolean":
- p = new SqlParameter("@" + value[0], SqlDbType.Bit);
- p.Value = (Boolean)value[1];
- parameters.Add(p);
- break;
- case "System.Char":
- p = new SqlParameter("@" + value[0], SqlDbType.Char);
- p.Value = value[1];
- parameters.Add(p);
- break;
- case "System.String":
- p = new SqlParameter("@" + value[0], SqlDbType.NVarChar);
- p.Value = value[1];
- parameters.Add(p);
- break;
- case "System.DateTime":
- p = new SqlParameter("@" + value[0], SqlDbType.DateTime, 8);
- p.Value = value[1];
- parameters.Add(p);
- break;
- case "System.Decimal":
- p = new SqlParameter("@" + value[0], SqlDbType.Decimal);
- p.Value = value[1];
- parameters.Add(p);
- break;
- case "System.Long":
- p = new SqlParameter("@" + value[0], SqlDbType.BigInt);
- p.Value = (long)value[1];
- parameters.Add(p);
- break;
- }
- }
- return parameters;
- }
- public static bool GetValues(string connectionString, string selectCommandText, ref DataTable dt, SqlParameter[] parameters, out string result)
- {
- bool bSuccessed = false;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- if (dt == null)
- {
- bSuccessed = false;
- result = "参数错误:dt不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlDataAdapter da = new SqlDataAdapter(selectCommandText, conn);
- try
- {
- conn.Open();
- da.SelectCommand.CommandType = CommandType.Text;
- da.SelectCommand.CommandTimeout = 300;
- if (parameters != null && parameters.Length > 0)
- da.SelectCommand.Parameters.AddRange(parameters);
- da.Fill(dt);
- DataTable ds = dt;
-
-
-
-
-
-
-
-
-
-
-
- bSuccessed = true;
- result = "已经成功的获取了数据。";
- }
- catch (Exception e)
- {
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (da != null && da.SelectCommand != null && da.SelectCommand.Parameters.Count > 0)
- da.SelectCommand.Parameters.Clear();
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- }
- return bSuccessed;
- }
- public static bool GetValues(string selectCommandText, ref DataTable dt, SqlParameter[] parameters, out string result)
- {
- return GetValues(connectionString, selectCommandText, ref dt, parameters, out result);
- }
- public static List<T> GetValues<T>(string selectCommandText, List<SqlParameter> parameters, out string result) where T : new()
- {
- DataTable dt = new DataTable();
- List<T> list = new List<T>();
- GetValues(selectCommandText, ref dt, parameters.ToArray(), out result);
- if (dt != null && dt.Rows.Count > 0)
- {
- list = (List<T>)ModelConvertHelper<T>.ConvertToModel(dt);
- }
- return list;
- }
-
-
-
-
-
-
-
- public static bool GetOneValue(string connectionString, string selectCommandText, out object objValue, out string result)
- {
- bool bSuccessed = false;
- objValue = null;
- result = "";
- if (selectCommandText == "")
- {
- bSuccessed = false;
- result = "参数错误:SELECT语句不能为空。";
- }
- else
- {
- SqlConnection conn = new SqlConnection(connectionString);
- SqlCommand cmd = new SqlCommand(selectCommandText, conn);
- try
- {
- conn.Open();
- cmd.CommandType = CommandType.Text;
- objValue = cmd.ExecuteScalar();
- bSuccessed = true;
- result = "已经成功的获取了数据。";
- }
- catch (Exception e)
- {
- bSuccessed = false;
- result = "在访问数据时发生错误。\r\nSELECT语句:" + selectCommandText + "\r\n错误描述:" + e.Message + "\r\n错误源:" + e.Source;
- }
- finally
- {
- if (conn != null)
- {
- if (conn.State != ConnectionState.Closed)
- conn.Close();
- }
- }
- }
- return bSuccessed;
- }
-
-
-
-
-
-
-
-
-
- public static int GetRowCount(string connectionString, string tableName, string filter, bool distinct, out string result)
- {
- int rowCount = -1;
- string selectCommandText = "SELECT " + (distinct ? "DISTINCT" : "") + " COUNT(*) FROM [" + tableName + "]";
- if (filter != "")
- selectCommandText += " WHERE " + filter;
- object objValue;
-
- if (DataAccess.GetOneValue(connectionString,selectCommandText, out objValue, out result))
- {
- if (!Convert.IsDBNull(objValue))
- rowCount = (int)objValue;
- }
- return rowCount;
- }
-
-
-
-
-
- public static Int64 GetRowCountDefine(string selectCommandText, out string result)
- {
- Int64 rowCount = -1;
- object objValue;
-
- if (DataAccess.GetOneValue(connectionString, selectCommandText, out objValue, out result))
- {
- if (!Convert.IsDBNull(objValue))
- rowCount = Convert.ToInt64(objValue);
- }
- return rowCount;
- }
-
-
-
-
-
- public static Int64 GetRowCountDefine(string selectCommandText,SqlParameter[] param, out string result)
- {
- Int64 rowCount = -1;
- object objValue;
-
- if (DataAccess.GetOneValue(connectionString, selectCommandText, param, out objValue, out result))
- {
- if (!Convert.IsDBNull(objValue))
- rowCount = Convert.ToInt64(objValue);
- }
- return rowCount;
- }
-
-
-
-
-
- public static int GetRowCountDefine(string connectionString, string selectCommandText, out string result)
- {
- int rowCount = -1;
- object objValue;
-
- if (DataAccess.GetOneValue(connectionString, selectCommandText, out objValue, out result))
- {
- if (!Convert.IsDBNull(objValue))
- rowCount = (int)objValue;
- }
- return rowCount;
- }
-
-
-
-
-
- public static int GetRowCountDefine(string connectionString, string selectCommandText, SqlParameter[] param, out string result)
- {
- int rowCount = -1;
- object objValue;
-
- if (DataAccess.GetOneValue(connectionString, selectCommandText, param, out objValue, out result))
- {
- if (!Convert.IsDBNull(objValue))
- rowCount = (int)objValue;
- }
- return rowCount;
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- }
-
-
-
- public enum BulkCopyTransType
- {
- None,
- Internal,
- External
- }
-
-
-
- public class DataAccessCommand
- {
-
- public string CommandText;
- public List<SqlParameter> ParamList;
- public CommandType CommandType;
- public bool RecordsAffectedLargeThanZeroIsSuccessful;
-
- public DataAccessCommand(string commandText, List<SqlParameter> paramList, CommandType commandType, bool recordsAffectedLargeThanZeroIsSuccessful)
- {
- CommandText = commandText;
- ParamList = paramList;
- this.CommandType = commandType;
- RecordsAffectedLargeThanZeroIsSuccessful = recordsAffectedLargeThanZeroIsSuccessful;
- }
- public DataAccessCommand(string commandText, List<SqlParameter> paramList)
- : this(commandText, paramList, CommandType.Text, true)
- {
- }
- public DataAccessCommand(string commandText)
- : this(commandText, null)
- {
- }
- }
- }
|