1.建一個通用的處理數據的類
using
System;
using
System.Data;
using
System.Data.SqlClient;
using
System.Text;
namespace
Document
{
/**/
///
<summary>
///
SummarydescriptionforDataHelper.
///
</summary>
public
class
DataHelper
{
public
DataHelper()
{
//
//
TODO:Addconstructorlogichere
//
}
public
static
string
ConnectionString
=
System.Configuration.ConfigurationSettings.AppSettings[
"
ConnectionString
"
];
GetDataSet
#region
GetDataSet
public
static
DataSetGetDataSet(
string
sql)
{
SqlDataAdaptersda
=
new
SqlDataAdapter(sql,ConnectionString);
DataSetds
=
new
DataSet();
sda.Fill(ds);
return
ds;
}
#endregion
ExecCommand
#region
ExecCommand
public
static
int
ExecCommand(SqlCommandsqlcom)
{
SqlConnectionconn
=
new
SqlConnection(ConnectionString);
sqlcom.Connection
=
conn;
conn.Open();
try
{
int
rtn
=
sqlcom.ExecuteNonQuery();
return
rtn;
}
catch
(Exceptionex)
{
throw
ex;
}
finally
{
conn.Close();
}
return
0
;
}
public
static
int
ExecCommand(
string
sql)
{
if
(sql.EndsWith(
"
,
"
))sql
=
sql.Substring(
0
,sql.Length
-
1
);
SqlCommandsqlcom
=
new
SqlCommand(sql);
return
ExecCommand(sqlcom);
}
#endregion
ExecuteScalar
#region
ExecuteScalar
public
static
object
ExecuteScalar(
string
sql)
{
SqlConnectionconn
=
new
SqlConnection(ConnectionString);
SqlCommandsqlcom
=
new
SqlCommand(sql,conn);
conn.Open();
try
{
object
rtn
=
sqlcom.ExecuteScalar();
return
rtn;
}
catch
(Exceptionex)
{
throw
ex;
}
finally
{
conn.Close();
}
return
null
;
}
#endregion
ExecSPCommand
#region
ExecSPCommand
public
static
void
ExecSPCommand(
string
sql,System.Data.IDataParameter[]paramers)
{
SqlConnectionconn
=
new
SqlConnection(ConnectionString);
SqlCommandsqlcom
=
new
SqlCommand(sql,conn);
sqlcom.CommandType
=
CommandType.StoredProcedure;
foreach
(System.Data.IDataParameterparamer
in
paramers)
{
sqlcom.Parameters.Add(paramer);
}
conn.Open();
try
{
sqlcom.ExecuteNonQuery();
}
catch
(Exceptionex)
{
string
s
=
ex.Message;
}
finally
{
conn.Close();
}
}
#endregion
ExecSPDataSet
#region
ExecSPDataSet
public
static
DataSetExecSPDataSet(
string
sql,System.Data.IDataParameter[]paramers)
{
SqlConnectionconn
=
new
SqlConnection(ConnectionString);
SqlCommandsqlcom
=
new
SqlCommand(sql,conn);
sqlcom.CommandType
=
CommandType.StoredProcedure;
foreach
(System.Data.IDataParameterparamer
in
paramers)
{
sqlcom.Parameters.Add(paramer);
}
conn.Open();
SqlDataAdapterda
=
new
SqlDataAdapter();
da.SelectCommand
=
sqlcom;
DataSetds
=
new
DataSet();
da.Fill(ds);
conn.Close();
return
ds;
}
#endregion
DbType
#region
DbType
private
static
System.Data.DbTypeGetDbType(Typetype)
{
DbTyperesult
=
DbType.String;
if
(type.Equals(
typeof
(
int
))
||
type.IsEnum)
result
=
DbType.Int32;
else
if
(type.Equals(
typeof
(
long
)))
result
=
DbType.Int32;
else
if
(type.Equals(
typeof
(
double
))
||
type.Equals(
typeof
(Double)))
result
=
DbType.Decimal;
else
if
(type.Equals(
typeof
(DateTime)))
result
=
DbType.DateTime;
else
if
(type.Equals(
typeof
(
bool
)))
result
=
DbType.Boolean;
else
if
(type.Equals(
typeof
(
string
)))
result
=
DbType.String;
else
if
(type.Equals(
typeof
(
decimal
)))
result
=
DbType.Decimal;
else
if
(type.Equals(
typeof
(
byte
[])))
result
=
DbType.Binary;
else
if
(type.Equals(
typeof
(Guid)))
result
=
DbType.Guid;
return
result;
}
#endregion
UpdateTable
#region
UpdateTable
public
static
void
UpdateTable(DataTabledt,
string
TableName,
string
KeyName)
{
foreach
(DataRowdr
in
dt.Rows)
{
updateRow(dr,TableName,KeyName);
}
}
#endregion
InsertTable
#region
InsertTable
//
用于主鍵是數據庫表名+ID類型的
public
static
void
InsertTable(DataTabledt)
{
string
TableName
=
"
[
"
+
dt.TableName
+
"
]
"
;
string
KeyName
=
dt.TableName
+
"
ID
"
;
foreach
(DataRowdr
in
dt.Rows)
{
insertRow(dr,TableName,KeyName);
}
}
//
用于主鍵是任意類型的
public
static
void
InsertTable(DataTabledt,
string
KeyName)
{
string
TableName
=
"
[
"
+
dt.TableName
+
"
]
"
;
foreach
(DataRowdr
in
dt.Rows)
{
insertRow(dr,TableName,KeyName);
}
}
#endregion
DeleteTable
#region
DeleteTable
public
static
void
DeleteTable(DataTabledt,
string
KeyName)
{
string
TableName
=
"
[
"
+
dt.TableName
+
"
]
"
;
foreach
(DataRowdr
in
dt.Rows)
{
deleteRow(dr,TableName,KeyName);
}
}
#endregion
update
分享到：
發表評論
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
評論