-5

ストアド プロシージャを呼び出すためのジェネリック メソッドを作成しようとしています。

配列を介してパラメータを渡したい

現時点では、パラメーターを SqlCommand に追加するのに問題があります

これは私がこれまでに持っているものです

誰でもアドバイスできますか

ありがとう

サイモン

メソッドの呼び出し

string[] paramNames = new string[1];
paramNames[0] = "@date = 2012-1-1";
string err="";


WriteToDatabase("exec LoadData", CommandType.StoredProcedure, paramNames, out err);

方法

public static bool WriteToDatabase(
        string sql,
        CommandType commandType,
        string[] paramNames,
        out string errorText)
    {
        bool success = false;
        errorText = "";
        try
        {
            using (SqlConnection connection = new SqlConnection(ConnectionString))
            {
               connection.Open(); 
                List<SqlParameter> parameters = new List<SqlParameter>();

                foreach (string paramName in paramNames)
                {
                    parameters.Add(new SqlParameter() { ParameterName = paramName });
                }

                using (SqlCommand command = new SqlCommand()
                {
                    Connection = connection,
                    CommandText = sql,
                    CommandType = commandType,
                    Parameters = parameters

                })
                 command.ExecuteNonQuery();  

                 connection.Close();
            }


        }
        catch (SqlException sex)
        {
            log.Error("QueryDatabase SQLexception:" + sex.Message);
        }
        catch (Exception ex)
        {
            log.Error("QueryDatabase exception:" + ex.Message);
        }
        return success;
    }
4

3 に答える 3

2

これは私がしばらく前に作ったクラスです。使い方はとても簡単です:

using System;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
using System.Web;
using System.Xml;
using System.Collections;
using System.Collections.Specialized;
using System.Collections.Generic;
using System.Text;

namespace NESCTC.Data
{   
    public class DataAccess : IDisposable
    {
        #region declarations

        private SqlCommand _cmd;
        private string _SqlConnString;

        #endregion

        #region constructors

        public DataAccess(string ConnectionString)
        {
            _cmd = new SqlCommand();
            _cmd.CommandTimeout = 240;
            _SqlConnString = ConnectionString;
        }

        #endregion

        #region IDisposable implementation

        ~DataAccess()
        {
            Dispose(false);
        }

        public void Dispose()
        {
            Dispose(true);            
        }

        protected virtual void Dispose(bool disposing)
        {
            if (disposing)
            {
                _cmd.Connection.Dispose();
                _cmd.Dispose();
            }
        }

        #endregion

        #region data retrieval methods

        public DataTable ExecReturnDataTable()
        {
            using (var conn = new SqlConnection(this.ConnectionString))
            {
                try
                {
                    PrepareCommandForExecution(conn);
                    using (SqlDataAdapter adap = new SqlDataAdapter(_cmd))
                    {
                        DataTable dt = new DataTable();
                        adap.Fill(dt);
                        return dt;
                    }
                }
                finally
                {
                    _cmd.Connection.Close();
                }
            }
        }                

        public object ExecScalar()
        {
            using (var conn = new SqlConnection(this.ConnectionString))
            {
                try
                {
                    PrepareCommandForExecution(conn);
                    return _cmd.ExecuteScalar();
                }
                finally
                {
                    _cmd.Connection.Close();
                }
            }
        }    

        #endregion

        #region data insert and update methods

        public void ExecNonQuery()
        {
            using (var conn = new SqlConnection(this.ConnectionString))
            {
                try
                {
                    PrepareCommandForExecution(conn);
                    _cmd.ExecuteNonQuery();
                }
                finally
                {
                    _cmd.Connection.Close();
                }
            }
        }

        #endregion

        #region helper methods

        public void AddParm(string ParameterName, SqlDbType ParameterType, object Value)
        { _cmd.Parameters.Add(ParameterName, ParameterType).Value = Value; }

        private SqlCommand PrepareCommandForExecution(SqlConnection conn)
        {
            try
            {
                _cmd.Connection = conn;
                _cmd.CommandType = CommandType.StoredProcedure;
                _cmd.CommandTimeout = this.CommandTimeout;
                _cmd.Connection.Open();

                return _cmd;
            }
            finally
            {
                _cmd.Connection.Close();
            }
        }

        #endregion

        #region properties

        public int CommandTimeout
        {
            get { return _cmd.CommandTimeout; }
            set { _cmd.CommandTimeout = value; }
        }

        public string ProcedureName
        {
            get { return _cmd.CommandText; }
            set { _cmd.CommandText = value; }
        }

        public string ConnectionString
        {
            get { return _SqlConnString; }
            set { _SqlConnString = value; }
        }

        #endregion
    }
}

使用方法の例を次に示します。

public void UpdateWorkOrder(int workOrderID, int paymentTermTypeID, string acceptedBy, string lastIssuedBy)
{
    using (var data = new DataAccess(this.ConnectionString))
    {
        data.ProcedureName = "UpdateWorkOrderDetails";
        data.AddParm("@WorkOrderID", SqlDbType.Int, workOrderID);
        data.AddParm("@PaymentTermTypeID", SqlDbType.Int, paymentTermTypeID);
        data.AddParm("@AcceptedBy", SqlDbType.VarChar, acceptedBy);
        data.AddParm("@LastIssuedBy", SqlDbType.VarChar, lastIssuedBy);
        data.ExecNonQuery();
    }
}

public DataTable GetWorkOrder(int workOrderID)
{
    using (var data = new DataAccess(this.ConnectionString))
    {
        data.ProcedureName = "GetWorkOrder";
        data.AddParm("@WorkOrderID", SqlDbType.Int, workOrderID);
        return data.ExecReturnDataTable();
    }
}
于 2012-04-10T15:46:42.797 に答える
0

このページは非常に役立ちますhttp://csharp-station.com/Tutorial/AdoDotNet/Lesson01 たくさんの例をチェックしてください！

于 2013-03-13T23:19:02.790 に答える
0

パラメータの名前と値は個別に指定する必要があります。それを行うには、さまざまなオプションがあります。パラメータ コレクションにはメソッドがあります

public SqlParameter AddWithValue(string parameterName, object value)

それを使用したい場合は、両方をメソッドに提供する必要があります

public static bool WriteToDatabase(
    string sql,
    CommandType commandType, 
    string[] paramNames,    
    object[] paramValues,    
    out string errorText)    
{
    ...
    for (int i = 0; i < paramNames.Length; i++) {
        command.Parameters.AddWithValue(paramNames[i], paramValues[i]);
    }
    ...
}
于 2012-04-10T15:47:57.103 に答える