C#執行存儲過程的簡化
2024-07-21 02:18:06
供稿：網友
，歡迎訪問網頁設計愛好者web開發。下面的方法是我在實際開發中摸索出來的，可以在很大程度上簡化調用存儲過程的代碼。
首先來看一下c#調用存儲過程的一般過程：
1、打開數據庫連接sqlconnection；
2、生成一個sqlcommand；
3、向命令對象填充參數；
4、執行存儲過程；
5、關閉連接；
6、其他操作。
我這里講的主要是簡化第3步操作，最終在調用存儲過程的時候只需要傳遞存儲過程的名字和相應的參數值。調用示例如下：
dbaccess.run("p_am_deletefile", new object[]{loginid, request.userhostaddress, fileid});
由于在填充參數的時候必須要兩個值，一個是參數的名字，一個是參數的值。參數值是由外部傳入的，不用考慮；而參數名稱是和存儲過程相關的東西，應該可以由存儲過程名稱來確定而不用每次調用的時候寫上一遍。對于這個問題，如果能將存儲過程的參數保存到一個全局的地方，那么在調用存儲過程的時候只要能根據存儲過程的名字去索引就可以了。具體實現的時候我是將這些信息保存在數據庫訪問組件里面，采用名字/值對的方式。代碼如下：
public class infotable : nameobjectcollectionbase
{
public object this[string key]
{
get
{
return(this.baseget(key));
}
set
{
this.baseset(key, value);
}
}
}
。。。。。。
protected static infotable procinfotable = new infotable();
。。。。。。
public static infotable procinfotable
{
get
{
return procinfotable;
}
}
這樣的話，在實際調用存儲過程的時候就只需要去查這張表就可以知道存儲過程的參數名了。實現代碼如下：
public datatable run(string procname, object[] parms, ref int retvalue)
{
string[] paraminfo = (string[])(procinfotable[procname]);
if (paraminfo == null)
{
errorinfo.seterrorinfo("未取得" + procname + "的參數！");
return null;
}
bool bopened = (dbconn.state == connectionstate.open);
if (!bopened && !connect())
{
return null;
}
dataset ds = new dataset();
try
{
sqlcommand cmd = new sqlcommand(procname, dbconn);
cmd.commandtype = commandtype.storedprocedure;
for (int i = 0; i < parms.length && i < paraminfo.length; ++i)
{
cmd.parameters.add(new sqlparameter(paraminfo[i], parms[i]));
}
sqlparameter parmsr = new sqlparameter("return", sqldbtype.int);
parmsr.direction = parameterdirection.returnvalue;
cmd.parameters.add(parmsr);
sqldataadapter adp = new sqldataadapter(cmd);
adp.fill(ds);
retvalue = (int)(cmd.parameters["return"].value);
}
catch (exception ex)
{
errorinfo.seterrorinfo(ex.message);
retvalue = -1;
}
if (!bopened)
close();
if (ds.tables.count > 0)
return ds.tables[0];
else
return null;
}
可以看出，每個存儲過程的參數列表存儲為了一個string[]。接下來的工作就是將系統里頭許許多多的存儲過程的參數填充到表procinfotable中。我所用的數據庫是sql server 2000，下面給出一個存儲過程來解決這個煩人的問題：
create procedure dbo.p_am_procinfo
(
@procname t_str64 --存儲過程的名字
)
as
begin
set nocount on
if @procname = '' begin
select name as procname
from sysobjects
where substring(sysobjects.name, 1, 5) = 'p_am_'
end
else begin
select
syscolumns.name as paramname
from sysobjects, syscolumns
where sysobjects.id = syscolumns.id
and sysobjects.name = @procname
order by colid
end
end
這個存儲過程有兩個作用，在沒有傳遞存儲過程的名字的時候，該存儲過程返回所有以”p_am_”開頭的存儲過程的名字；在傳入了相應的存儲過程名字后，該存儲過程返回該存儲過程的參數列表。這樣一來，我們在程序開始的地方就可以將系統里的存儲過程參數列表取出來并保存到數據庫訪問組件的procinfotable屬性中了。具體代碼如下：
span.dbaccess dbaccess = new span.dbaccess();
//
//構造取存儲過程的參數表
//
span.dbaccess.procinfotable["p_am_procinfo"] = new string[]{"@procname"};
//
//取得其他存儲過程列表
//
datatable dt = dbaccess.run("p_am_procinfo", new object[]{""});
if (dt == null || dt.rows.count <= 0)
{
return;
}
//
//取得其他存儲過程的參數表
//
foreach (datarow dr in dt.rows)
{
datatable dtparams = dbaccess.run("p_am_procinfo", new object[]{dr["procname"]});
if (dtparams != null)
{
string[] paraminfo = new string[dtparams.rows.count];
for (int i = 0; i < dtparams.rows.count; ++i)
paraminfo[i] = dtparams.rows[i]["paramname"].tostring();
span.dbaccess.procinfotable[dr["procname"].tostring()] = paraminfo;
}
}
至此，全部技術細節介紹完畢。另外，數據庫訪問對象的幾個接口函數也一并給出：
//打開、關閉數據庫連接
public bool connect(string strconn)
public bool connect()
public bool close()
//執行sql命令(只有一個int返回)
public int exec(string procname, object[] parms)
public int exec(string sql)
//運行(返回一個datatable)
public datatable run(string procname, object[] parms, ref int retvalue)
public datatable run(string procname, object[] parms)
public datatable run(string sql)
//分頁查詢(頁號從1開始,返回一個datatable)
public datatable pagequery
(
string selectcmd,
int pagesize,
int pagenumber
)
