using
System;
using
System.Collections;
using
System.Collections.Specialized;
using
System.Runtime.Remoting.Messaging;
using
System.Data;
using
System.Data.SqlClient;
using
System.Configuration;
namespace
LTP.SQLServerDAL
{
///
<summary>
///
ADO.NET數據庫操作基礎類。
///
</summary>
public
abstract
class
DbManagerSQL
{
//
數據庫連接字符串
protected
static
string
connectionString
=
ConfigurationSettings.AppSettings[
"
ConnectionString
"
];
public
DbManagerSQL()
{
//
//
TODO:在此處添加構造函數邏輯
//
}
///
<summary>
///
執行SQL語句，返回影響的記錄數
///
</summary>
///
<paramname="SQLString"></param>
///
<returns></returns>
public
static
int
ExecuteSql(
string
SQLString)
{
using
(SqlConnectionconnection
=
new
SqlConnection(connectionString))
{
using
(SqlCommandcmd
=
new
SqlCommand(SQLString,connection))
{
try
{
connection.Open();
int
rows
=
cmd.ExecuteNonQuery();
return
rows;
}
catch
(System.Data.SqlClient.SqlExceptionE)
{
throw
new
Exception(E.Message);
}
}
}
}
///
<summary>
///
執行兩條SQL語句，實現數據庫事務。
///
</summary>
///
<paramname="SQLString1"></param>
///
<paramname="SQLString2"></param>
public
static
void
ExecuteSqlTran(
string
SQLString1,
string
SQLString2)
{
using
(SqlConnectionconnection
=
new
SqlConnection(connectionString))
{
connection.Open();
SqlCommandcmd
=
new
SqlCommand();
cmd.Connection
=
connection;
SqlTransactiontx
=
connection.BeginTransaction();
cmd.Transaction
=
tx;
try
{
cmd.CommandText
=
SQLString1;
cmd.ExecuteNonQuery();
cmd.CommandText
=
SQLString2;
cmd.ExecuteNonQuery();
tx.Commit();
}
catch
(System.Data.SqlClient.SqlExceptionE)
{
tx.Rollback();
throw
new
Exception(E.Message);
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
///
<summary>
///
執行多條SQL語句，實現數據庫事務，每條語句以“;”分割。
///
</summary>
///
<paramname="SQLStringList"></param>
public
static
void
ExecuteSqlTran(
string
SQLStringList)
{
using
(OdbcConnectionconn
=
new
OdbcConnection(connectionString))
{
conn.Open();
OdbcCommandcmd
=
new
OdbcCommand();
cmd.Connection
=
conn;
OdbcTransactiontx
=
conn.BeginTransaction();
cmd.Transaction
=
tx;
try
{
string
[]split
=
SQLStringList.Split(
new
Char[]
{
'
;
'
}
);
foreach
(
string
strsql
in
split)
{
if
(strsql.Trim()
!=
""
)
{
cmd.CommandText
=
strsql;
cmd.ExecuteNonQuery();
}
}
tx.Commit();
}
catch
(System.Data.Odbc.OdbcExceptionE)
{
tx.Rollback();
throw
new
Exception(E.Message);
}
}
}
///
<summary>
///
執行帶一個存儲過程參數的的SQL語句。
///
</summary>
///
<paramname="SQLString"></param>
///
<paramname="content"></param>
///
<returns></returns>
public
static
int
ExecuteSql(
string
SQLString,
string
content)
{
using
(SqlConnectionconnection
=
new
SqlConnection(connectionString))
{
SqlCommandcmd
=
new
SqlCommand(SQLString,connection);
System.Data.SqlClient.SqlParametermyParameter
=
new
System.Data.SqlClient.SqlParameter(
"
@content
"
,SqlDbType.NText);
myParameter.Value
=
content;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int
rows
=
cmd.ExecuteNonQuery();
return
rows;
}
catch
(System.Data.SqlClient.SqlExceptionE)
{
throw
new
Exception(E.Message);
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
///
<summary>
///
向數據庫里插入圖像格式的字段
///
</summary>
///
<paramname="strSQL"></param>
///
<paramname="fs"></param>
///
<returns></returns>
public
static
int
ExecuteSqlInsertImg(
string
strSQL,
byte
[]fs)
{
using
(SqlConnectionconnection
=
new
SqlConnection(connectionString))
{
SqlCommandcmd
=
new
SqlCommand(strSQL,connection);
System.Data.SqlClient.SqlParametermyParameter
=
new
System.Data.SqlClient.SqlParameter(
"
@fs
"
,SqlDbType.Image);
myParameter.Value
=
fs;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int
rows
=
cmd.ExecuteNonQuery();
return
rows;
}
catch
(System.Data.SqlClient.SqlExceptionE)
{
throw
new
Exception(E.Message);
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
///
<summary>
///
執行一條計算查詢結果語句，返回查詢結果（整數）。
///
</summary>
///
<paramname="strSQL"></param>
///
<returns></returns>
public
static
int
GetCount(
string
strSQL)
{
using
(SqlConnectionconnection
=
new
SqlConnection(connectionString))
{
SqlCommandcmd
=
new
SqlCommand(strSQL,connection);
try
{
connection.Open();
SqlDataReaderresult
=
cmd.ExecuteReader();
int
i
=
0
;
while
(result.Read())
{
i
=
result.GetInt32(
0
);
}
result.Close();
return
i;
}
catch
(System.Data.SqlClient.SqlExceptione)
{
throw
new
Exception(e.Message);
}
finally
_5044_5095_Closed_Tex
分享到：
發表評論
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
評論