提交

username@email.com

2025-05-21 a980cd04341d71216e0f59bd4b7327fe9fc50032

 CY_ECommercePlatform/CY.SQLDAL/Database.cs

@@ -307,6 +307,34 @@
            return command.ExecuteReader(CommandBehavior.CloseConnection);//释放Reader时关闭连接
        }


        /// <summary>
        /// 返回intid
        /// </summary>
        /// <param name="SQLString">Transaction-SQL语句</param>
        /// <param name="param">SQL参数</param>
        /// <returns>返回intid</returns>
        public int InsertDataAndGetId(string SQLString, params SqlParameter[] param)
        {
            int newRecordId = 0;
            
                SqlCommand cmd = new SqlCommand(SQLString + "; SELECT SCOPE_IDENTITY();", this.Connection);
            if (this._Tran != null)
            {
                cmd.Transaction = this._Tran;
            }
            cmd.CommandTimeout = Database.QueryTimeOut;
            cmd.Parameters.Clear();
            if (param != null)
            {
                cmd.Parameters.AddRange(param);

            }
            newRecordId = Convert.ToInt32(cmd.ExecuteScalar());
            
            return newRecordId;
        }

        /// <summary>
        /// 执行SQL语句，返回影响的记录数
        /// </summary>
@@ -454,21 +482,9 @@

            using (IDataReader reader = QueryDataReader("sp_CurrencyPage", CommandType.StoredProcedure, parameters))
            {
                try
                {
                    result = ReadDataToModel<T>(reader);
                }
                catch (System.Data.SqlClient.SqlException e)
                {
                    throw e;
                }
                finally
                {
                    reader.Close();
                    Close();
                }

              
                result = ReadDataToModel<T>(reader);
                reader.Close();
                Close();
            }
            int? resultValue = CY.Infrastructure.Common.MyConvert.ConvertToInt32(parameters[8].Value);
            pagination.RecordCount = resultValue.HasValue ? resultValue.Value : 0;
@@ -561,19 +577,9 @@
                return null;
            using (IDataReader reader = QueryDataReader("sp_SelectModel", CommandType.StoredProcedure, parameters))
            {
                try
                {
                    result = ReadDataToModel<T>(reader);
                }
                catch (System.Data.SqlClient.SqlException e)
                {
                    throw e;
                }
                finally
                {
                    reader.Close();
                    Close();
                }  
                result = ReadDataToModel<T>(reader);
                reader.Close();
                Close();
            }
            return result;