ExecuteNonQuery не обновляет выходной параметр - PullRequest
3 голосов
/ 26 апреля 2019

Я использую ExecuteNonQuery для вставки записи в базу данных и возврата идентификатора новой записи. Он вставляет нормально, но выходной параметр не обновляется.

Попытка выполнить хранимую процедуру в SSMS, и она работала нормально. Имеет проблему только при выполнении с ExecuteNonQuery.

Включен весь код, который используется для попытки вставки.

        public int InsertPurchaseOrder(IPurchaseOrder po)
        {
            int returnId = 0;
            int returnCount = 0;

            List<IParam> parms = ParameterFactory.CreateListInstance();

            parms.Add(ParameterFactory.CreateParameter("@Timestamp", po.Timestamp, SqlDbType.Timestamp, ParameterDirection.Output));
            parms.Add(ParameterFactory.CreateParameter("@Status", po.Status, SqlDbType.Int, ParameterDirection.Input));
            parms.Add(ParameterFactory.CreateParameter("@Subtotal", po.Subtotal, SqlDbType.Money, ParameterDirection.Input));
            parms.Add(ParameterFactory.CreateParameter("@Taxes", po.Taxes, SqlDbType.Money, ParameterDirection.Input));
            parms.Add(ParameterFactory.CreateParameter("@Total", po.Total, SqlDbType.Money, ParameterDirection.Input));
            parms.Add(ParameterFactory.CreateParameter("@EmployeeId", po.EmployeeId, 8, SqlDbType.VarChar, ParameterDirection.Input));

            parms.Add(ParameterFactory.CreateParameter("@PONumOut", 12345, SqlDbType.Int, ParameterDirection.Output));

            try
            {
                returnCount = dataAccess.ExecuteNonQuery(SPROC_INSERT_PO, CommandType.StoredProcedure, parms);
                if (returnCount >= 0)
                {
                    po.Timestamp = (byte[])parms[0].Value;
                    returnId = Convert.ToInt32(parms[6].Value);
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return returnId;
        }
 public static IParam CreateParameter(string name, object value, SqlDbType type, ParameterDirection direction)
        {
            return new Param(name, value, type, direction);
        }
        public Param(string name, object value, SqlDbType type, ParameterDirection direction)
        {
            Name = name;
            Value = value;
            Size = 0;
            DataType = type;
            Direction = direction;
        }
        public int ExecuteNonQuery(string cmdText, CommandType cmdType, List<IParam> parms)
        {
            SqlCommand cmd = CreateCommand(cmdText, cmdType, parms);

            using (cmd.Connection)
            {
                cmd.Connection.Open();
                return cmd.ExecuteNonQuery();
            }
        }
        public SqlCommand CreateCommand(string cmdText, CommandType cmdType, List<IParam> parms)
        {
            SqlConnection conn = new SqlConnection(
                Properties.Settings.Default.cnnString);

            SqlCommand cmd = new SqlCommand(cmdText, conn);
            cmd.CommandType = cmdType;

            if (parms != null)
            {
                foreach (IParam p in parms)
                {
                    cmd.Parameters.Add(new SqlParameter(p.Name,
                        p.DataType, p.Size));
                    cmd.Parameters[p.Name].Value = p.Value;
                    cmd.Parameters[p.Name].Direction = p.Direction;
                }
            }

            return cmd;
        }
ALTER PROCEDURE [dbo].[spInsertPO]
    @Timestamp timestamp OUTPUT,
    @Status Int,
    @Subtotal money,
    @Taxes money,
    @Total money,
    @EmployeeId varchar(8),
    @PONumOut Int OUTPUT
AS
BEGIN
    BEGIN TRY
        SET NOCOUNT OFF
        INSERT INTO
            PurchaseOrder(Status,Subtotal,Taxes,Total,EmployeeId)
        VALUES
            (@Status, @Subtotal, @Taxes, @Total, @EmployeeId)

        SET @PONumOut = @@IDENTITY;
    END TRY
    BEGIN CATCH
        THROW
    END CATCH
END

Ответы [ 2 ]

0 голосов
/ 26 апреля 2019

Пожалуйста, используйте как это

`ALTER PROCEDURE [dbo]. [SpInsertPO] @Timestamp timestamp OUTPUT, @Status Int, @ Итого деньги, @ Обманывают деньги, @ Всего денег, @EmployeeId varchar (8), @PONumOut Int OUTPUT КАК НАЧАТЬ НАЧАТЬ ВЫКЛЮЧИТЬ ВСТАВИТЬ В PurchaseOrder (статус, Итого, налоги, Total, EmployeeID) ЦЕННОСТИ (@Status, @Subtotal, @Taxes, @Total, @EmployeeId)

    SET @PONumOut = @@IDENTITY;
END TRY
BEGIN CATCH
    THROW
END CATCH

return @PONumOut; `

END

0 голосов
/ 26 апреля 2019

Решена проблема.

Необходимо изменить мой метод ExecuteNonQuery () следующим образом.

        public int ExecuteNonQuery(string cmdText, CommandType cmdType, List<IParam> parms)
        {
            SqlCommand cmd = CreateCommand(cmdText, cmdType, parms);

            using (cmd.Connection)
            {
                cmd.Connection.Open();
                int ret = cmd.ExecuteNonQuery();
                UnloadParms(parms, cmd);
                return ret;
            }
        }

И добавьте следующий метод.

private static void UnloadParms(List<IParam> parms, SqlCommand cmd)
        {
            if (parms != null)
            {
                for (int i = 0; i <= parms.Count - 1; i++)
                {
                    IParam p = parms[i];
                    p.Value = cmd.Parameters[i].Value;
                    parms[i] = p;
                }
            }
        }
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...