.net调用存储过程

存储过程：（用向导建立）

CREATE PROCEDURE [insert_pinglun]

(@qyid [int],

@content [ntext],

@plname [nvarchar](50),

@qq [char](20),

@email [nvarchar](50),

@ip [char](20),

@time1 [datetime])

AS INSERT INTO [cne71].[dbo].[pinglun]

( [qyid],

[content],

[plname],

[qq],

[email],

[ip],

[time1])

VALUES

( @qyid,

@content,

@plname,

@qq,

@email,

@ip,

@time1)

return 1

GO

数据层代码：（调用存储过程）

public int insertpinglun(qiyeVAO qiyeVO)

{

int rowsAffected;

int returnValue;

SqlParameter[] Parameters={

new SqlParameter("@qyid",SqlDbType.Int,6),

new SqlParameter("@content",SqlDbType.NText),

new SqlParameter("@plname",SqlDbType.NVarChar,50),

new SqlParameter("@qq",SqlDbType.Char,20),

new SqlParameter("@email",SqlDbType.NVarChar,50),

new SqlParameter("@ip",SqlDbType.Char,20),

new SqlParameter("@time1",SqlDbType.DateTime)

};

Parameters[0].Value=qiyeVO.Id;

Parameters[1].Value=qiyeVO.Content;

Parameters[2].Value=qiyeVO.Plname;

Parameters[3].Value=qiyeVO.Qq;

Parameters[4].Value=qiyeVO.Email;

Parameters[5].Value=qiyeVO.Ip;

Parameters[6].Value=qiyeVO.Time1;

core.DbObject db1= new DbObject();

returnValue = (int)db1.RunProcedure("insert_pinglun",Parameters,out rowsAffected);

return returnValue;

}

类代码：（core/DbObject .cs)

public class DbObject

{

protected SqlConnection Connection;

private string connectionString;

public DbObject()

{

connectionString = System.Configuration.ConfigurationSettings.AppSettings["sqlConnection"];

Connection = new SqlConnection( connectionString );

}

public SqlCommand BuildIntCommand(string storedProcName,IDataParameter[] parameters)

{

SqlCommand command = BuildQueryCommand ( storedProcName,parameters );

command.Parameters.Add(new SqlParameter("ReturnValue",SqlDbType.Int,4,ParameterDirection.ReturnValue,false,0,0,string.Empty,DataRowVersion.Default,null));

return command;

}

public SqlCommand BuildQueryCommand ( string storedProcName,IDataParameter[] parameters)

{

SqlCommand command = new SqlCommand( storedProcName,Connection);

command.CommandType = CommandType.StoredProcedure;

foreach ( SqlParameter parameter in parameters )

{

command.Parameters.Add( parameter );

//System.Web.HttpContext.Current.Response.Write( parameter.ParameterName);

//System.Web.HttpContext.Current.Response.Write( parameter.SqlDbType);

//System.Web.HttpContext.Current.Response.Write( parameter.Value);

}

//System.Web.HttpContext.Current.Response.Write (command.Parameters.Count);

return command;

}

protected string ConnectionString

{

get

{

return connectionString;

}

}

public int RunProcedure ( string storedProcName ,IDataParameter[] parameters, out int rowsAffected )

{

int result;

Connection.Open();

SqlCommand command = BuildIntCommand ( storedProcName ,parameters );

rowsAffected = command.ExecuteNonQuery();//没有影响就是-1

result = (int)command.Parameters["ReturnValue"].Value;

Connection.Close();

Connection.Dispose();

return result;

}

}