C# Common.DbTransaction类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了C#中System.Data.Common.DbTransaction类的典型用法代码示例。如果您正苦于以下问题：C# DbTransaction类的具体用法？C# DbTransaction怎么用？C# DbTransaction使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

DbTransaction类属于System.Data.Common命名空间，在下文中一共展示了DbTransaction类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C#代码示例。

示例1: DeleteRoleRightsByRoleId

 public bool DeleteRoleRightsByRoleId(Role roles, Database db, DbTransaction transaction)
 {
     DbCommand dbCommand = db.GetStoredProcCommand("usp_RoleRightDelete");
     db.AddInParameter(dbCommand, "RoleId", DbType.Guid, roles.RoleId);
     db.ExecuteNonQuery(dbCommand, transaction);
     return true;
 }

开发者ID:nirshandileep，项目名称:DairyManager，代码行数:7，代码来源:RoleDAO.cs

示例2: doCreate

        /// <summary>
        /// 新增基本檔資料(使用交易)
        /// </summary>
        /// <param name="htParams">放入輸入的參數</param>
        /// <param name="DBT">交易變數</param>
        /// <returns>回傳影響筆數</returns>
        public void doCreate(Hashtable htParams,
                            DbTransaction DBT
                            )
        {
            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_ALO_PATTERNSPEC_DETL.ADD_PATTERNSPEC_DETL");
                db.AddInParameter(cmd, "ID", DbType.VarNumeric, htParams["ID"]);
                db.AddInParameter(cmd, "PID", DbType.VarNumeric, htParams["PID"]);
                db.AddInParameter(cmd, "vCreateDate", DbType.Date, htParams["CREATEDATE"]);
                db.AddInParameter(cmd, "vCreateUID", DbType.String, htParams["CREATEUID"]);
                db.AddInParameter(cmd, "vUpdateDate", DbType.Date, htParams["UPDATEDATE"]);
                db.AddInParameter(cmd, "vUpdateUID", DbType.String, htParams["UPDATEUID"]);
                db.AddInParameter(cmd, "nSTART_RANKQTY", DbType.VarNumeric, htParams["START_RANKQTY"]);
                db.AddInParameter(cmd, "nEND_RANKQTY", DbType.VarNumeric, htParams["END_RANKQTY"]);
                db.AddInParameter(cmd, "nADJ_QTY", DbType.VarNumeric, htParams["ADJ_QTY"]);

                int ProcessRecord = (DBT == null) ? db.ExecuteNonQuery(cmd) : db.ExecuteNonQuery(cmd, DBT);

                if (ProcessRecord == 0)
                {
                    throw new Exception("輸入資料失敗!");
                }
            }
            catch (Exception ex)
            {
                throw new Exception("呼叫VDS_ALO_PATTERNSPEC_DETL_DBO.doCreate()發生錯誤,錯誤訊息:"
                                    + OracleExceptionProcess.OracleExceptionStringCut(ex.Message));
            }
        }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:36，代码来源:VDS_ALO_PATTERNSPEC_DETL_DBO.cs

示例3: Insert

        public bool Insert(Option Option, Database db, DbTransaction transaction)
        {
            DbCommand command = db.GetStoredProcCommand("usp_OptionInsert");

            db.AddInParameter(command, "Name", DbType.String, Option.Name);
            db.AddInParameter(command, "Description", DbType.String, Option.Description);
            db.AddInParameter(command, "OptionCategoryId", DbType.Int16, Option.OptionCategoryId);
            db.AddInParameter(command, "ParentOptionId", DbType.Int16, Option.ParentOptionId);
            db.AddInParameter(command, "IsDeleted", DbType.Boolean, Option.IsDeleted);
            db.AddInParameter(command, "IsMultiSelect", DbType.Boolean, Option.IsMultiSelect);
            db.AddInParameter(command, "Points", DbType.Int16, Option.Points);

            db.AddOutParameter(command, "OptionId", DbType.Int16, 3);

            if (transaction == null)
            {
                db.ExecuteNonQuery(command);
            }
            else
            {
                db.ExecuteNonQuery(command, transaction);
            }

            Option.OptionId = Convert.ToInt16(db.GetParameterValue(command, "OptionId").ToString());

            return true;
        }

开发者ID:nirshandileep，项目名称:RHP，代码行数:27，代码来源:PropertyOptionDAO.cs

示例4: CategoryDelete

        /// <summary>
        /// ���� ɾ��
        /// </summary>
        /// <param name="id">Id ���</param>
        /// <returns>ִ�н��</returns>
        public int CategoryDelete(out string resultMsg, Int32 id, DbTransaction tran = null)
        {
            resultMsg = string.Empty;
            int res = 0;
            try
            {
                //�洢��������
                string sql = "usp_category_delete_by_id";

                //�������
                IList<DBParameter> parm = new List<DBParameter>();
                parm.Add(new DBParameter() { ParameterName = "ID", ParameterValue = id, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.Int32 });
                //parm.Add(new DBParameter() { ParameterName = "resultMsg", ParameterInOut = BaseDict.ParmOut, ParameterType = DbType.String });

                //����ִ��
                res = DBHelper.ExecuteNonQuery(sql, true, parm, tran);
                //foreach (var item in parm)
                //{
                //    //��ȡ�������ֵ
                //    if (item.ParameterName == "resultMsg")
                //    {
                //        resultMsg = item.ParameterValue.ToString();
                //        break;
                //    }
                //}
            }
            catch (Exception ex)
            {
                if (tran != null)
                    tran.Rollback();
                resultMsg = string.Format("{0} {1}", BaseDict.ErrorPrefix, ex.ToString());
            }
            return res;
        }

开发者ID:JasonDevStudio，项目名称:Cnita，代码行数:39，代码来源:LogicCategory.cs

示例5: DiscoverSpParameterSet

        /// <summary>
        /// Resolve at run time the appropriate set of DbParameters for a stored procedure
        /// </summary>
        /// <param name="transaction">A valid SqlTransaction object</param>
        /// <param name="connection">A valid SqlConnection object</param>
        /// <param name="storedProcedureName">The name of the stored procedure</param>
        /// <param name="includeReturnValueParameter">Whether or not to include their return value parameter</param>
        /// <returns>The parameter array discovered.</returns>
        private static IList<SqlParameter> DiscoverSpParameterSet(DbTransaction transaction, DbConnection connection, string storedProcedureName, bool includeReturnValueParameter)
        {
            using (SqlCommand cmd = new SqlCommand(storedProcedureName, connection as SqlConnection))
            {
                if (connection.State != ConnectionState.Open)
                {
                    connection.Open();
                }

                cmd.CommandType = CommandType.StoredProcedure;
                if (transaction != null)
                {
                    cmd.Transaction = transaction as SqlTransaction;
                }

                SqlCommandBuilder.DeriveParameters(cmd);

                if (!includeReturnValueParameter)
                {
                    cmd.Parameters.RemoveAt(0);
                }

                SqlParameter[] discoveredParameters = new SqlParameter[cmd.Parameters.Count];

                cmd.Parameters.CopyTo(discoveredParameters, 0);

                return discoveredParameters;
            }
        }

开发者ID:jawn，项目名称:SqlHelper，代码行数:37，代码来源:ParameterCache.cs

示例6: AddReviewBillContent

        /// <summary>
        /// 添加审稿单
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool AddReviewBillContent(ReviewBillContentEntity model, DbTransaction trans = null)
        {
            StringBuilder sqlCommandText = new StringBuilder();
            sqlCommandText.Append(" @CID");
            sqlCommandText.Append(", @JournalID");
            sqlCommandText.Append(", @ItemID");
            sqlCommandText.Append(", @ContentValue");
            sqlCommandText.Append(", @IsChecked");
            sqlCommandText.Append(", @AddUser");

            DbCommand cmd = db.GetSqlStringCommand(String.Format("INSERT INTO dbo.ReviewBillContent ({0},AddDate) VALUES ({1},getdate())", sqlCommandText.ToString().Replace("@", ""), sqlCommandText.ToString()));

            db.AddInParameter(cmd, "@ItemContentID", DbType.Int64, model.ItemContentID);
            db.AddInParameter(cmd, "@CID", DbType.Int64, model.CID);
            db.AddInParameter(cmd, "@JournalID", DbType.Int64, model.JournalID);
            db.AddInParameter(cmd, "@ItemID", DbType.AnsiString, model.ItemID);
            db.AddInParameter(cmd, "@ContentValue", DbType.AnsiString, model.ContentValue);
            db.AddInParameter(cmd, "@IsChecked", DbType.Boolean, model.IsChecked);
            db.AddInParameter(cmd, "@AddUser", DbType.Int64, model.AddUser);
            try
            {
                bool result = false;
                if (trans == null)
                    result = db.ExecuteNonQuery(cmd) > 0;
                else
                    result = db.ExecuteNonQuery(cmd, trans) > 0;
                if (!result)
                    throw new Exception("新增审稿单失败！");
                return result;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

开发者ID:zhanglc8801，项目名称:WKT2015，代码行数:40，代码来源:ReviewBillContentDataAccess.cs

示例7: doCreate

        /// <summary>
        /// 新增基本檔資料(使用交易)
        /// </summary>
        /// <param name="ParameterList">放入輸入的參數</param>
        /// <param name="DBT">交易變數</param>
        /// <returns>回傳影響筆數</returns>
        public int doCreate(Int32 PID, DbTransaction DBT, DataRow dRow, ArrayList ParameterList)
        {
            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_IFM_REQUEST_DETL.InsertOne");
                db.AddInParameter(cmd, "vPID", DbType.VarNumeric, PID);
                db.AddInParameter(cmd, "vCREATEDATE", DbType.Date, ParameterList[17]);
                db.AddInParameter(cmd, "vCREATEUID", DbType.String, ParameterList[18]);
                db.AddInParameter(cmd, "vUPDATEDATE", DbType.Date, ParameterList[19]);
                db.AddInParameter(cmd, "vUPDATEUID", DbType.String, ParameterList[20]);
                db.AddInParameter(cmd, "vREQ_NO", DbType.String, ParameterList[0]);
                db.AddInParameter(cmd, "vPHASE_CODE", DbType.String, dRow["PHASE_CODE"]);
                db.AddInParameter(cmd, "vSTART_DATE", DbType.Date, dRow["START_DATE"]);
                db.AddInParameter(cmd, "vEND_DATE", DbType.Date, dRow["END_DATE"]);
                db.AddInParameter(cmd, "vEMP_ID", DbType.String, dRow["EMP_ID"]);
                db.AddInParameter(cmd, "vPHASE_HOUR", DbType.String, dRow["PHASE_HOUR"]);

                int ProcessRecord = (DBT == null) ? db.ExecuteNonQuery(cmd) : db.ExecuteNonQuery(cmd, DBT);

                if (ProcessRecord == 0)
                {
                    throw new Exception("輸入資料失敗!");
                }

                return int.Parse((db.GetParameterValue(cmd, "vPID")).ToString());
            }
            catch (Exception ex)
            {
                throw new Exception("呼叫PKG_VDS_IFM_REQUEST_DETL.InsertOne發生錯誤,錯誤訊息:"
                                    + ex.Message);
            }
        }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:38，代码来源:IFM_SysRequestLineDBO.cs

示例8: PicturesInsertUpdate

        /// <summary>
        /// ���� ���/����
        /// </summary>
        /// <param name="pictures">ʵ��</param>
        /// <returns>ִ�н��</returns>
        public int PicturesInsertUpdate(out string resultMsg,ModelPictures pictures,DbTransaction tran =null)
        {
            resultMsg = string.Empty;
            int res = 0;
            try
            {
                //�洢��������
                string sql = "USP_PICTURES_INSERT_UPDATE";
                //�������
                IList<DBParameter> parm = new List<DBParameter>();
                parm.Add(new DBParameter() { ParameterName = "ID", ParameterValue = pictures.Id, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.Int32 });
                parm.Add(new DBParameter() { ParameterName = "NAME", ParameterValue = pictures.Name, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.String });
                parm.Add(new DBParameter() { ParameterName = "CATEGORYID", ParameterValue = pictures.Categoryid, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.Int32 });
                parm.Add(new DBParameter() { ParameterName = "OWNER", ParameterValue = pictures.Owner, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.Int32 });
                parm.Add(new DBParameter() { ParameterName = "PICURI", ParameterValue = pictures.Picuri, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.String });
                parm.Add(new DBParameter() { ParameterName = "PICLINK", ParameterValue = pictures.Piclink, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.String });
                parm.Add(new DBParameter() { ParameterName = "STATUS", ParameterValue = pictures.Status, ParameterInOut = BaseDict.ParmIn, ParameterType = DbType.Int32 });

                //����/����ִ��
                res = DBHelper.ExecuteNonQuery(sql, true, parm, tran);

            }
            catch (Exception ex)
            {
                if(tran != null)
                    tran.Rollback();
                resultMsg = string.Format("{0} {1}", BaseDict.ErrorPrefix, ex.ToString());
            }
            return res;
        }

开发者ID:JasonDevStudio，项目名称:Cnita，代码行数:35，代码来源:LogicPictures.cs

示例9: doCreate

        /// <summary>
        /// �s�W���ɸ��(�ϥΥ��)
        /// </summary>
        /// <param name="ParameterList">��J��J���Ѽ�</param>
        /// <param name="DBT">����ܼ�</param>
        /// <returns>�^�Ǽv�T����</returns>
        public int doCreate(ArrayList ParameterList,
            DbTransaction DBT
            )
        {
            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_OUT05.InsertOne");
                for (int i = 0; i < ParameterList.Count; i++)
                {
                    SQLHelper.ParameterItem pi = ((SQLHelper.ParameterItem)ParameterList[i]);
                    db.AddInParameter(cmd,
                        string.Format("{0}", pi.ParaName),
                        pi.FieldType,
                        pi.FieldValue);
                }
                db.AddOutParameter(cmd, "PID", DbType.VarNumeric, Int32.MaxValue);

                int ProcessRecord = (DBT == null) ? db.ExecuteNonQuery(cmd) : db.ExecuteNonQuery(cmd, DBT);

                if (ProcessRecord == 0)
                {
                    throw new Exception("��J��ƥ���!");
                }

                return Convert.ToInt32(db.GetParameterValue(cmd, "PID"));
            }
            catch (Exception ex)
            {
                throw new Exception("�I�sPKG_VDS_OUT05.InsertOne�o�Ϳ��~,���~�T��:"
                                    + OracleExceptionProcess.OracleExceptionStringCut(ex.Message)
                                    );
            }
        }

开发者ID:ChiangHanLung，项目名称:VDS，代码行数:39，代码来源:OUT05_SKUDBO.cs

示例10: doCloseOrder

        public void doCloseOrder(ArrayList ParameterList,
            DbTransaction DBT)
        {
            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_OUT05.Update_Close_Order");
                for (int i = 0; i < ParameterList.Count; i++)
                {
                    string[] pl = (string[])ParameterList[i];

                    db.AddInParameter(cmd, "pid", DbType.VarNumeric, pl[0]); // ID
                    db.AddInParameter(cmd, "p_status_reason", DbType.String, pl[1]); // STATUS_REASON
                    db.AddInParameter(cmd, "p_updatedate", DbType.DateTime, System.DateTime.Now);
                    db.AddInParameter(cmd, "p_updateuid", DbType.String, pl[2]);

                    int ProcessRecord = (DBT == null) ? db.ExecuteNonQuery(cmd) : db.ExecuteNonQuery(cmd, DBT);

                    if (ProcessRecord == 0)
                    {
                        throw new Exception("��s��ƥ���!");
                    }
                }
            }
            catch (Exception ex)
            {
                throw new Exception("�I�sPKG_VDS_OUT05.Update_Close_Order()�o�Ϳ��~,���~�T��:"
                                    + OracleExceptionProcess.OracleExceptionStringCut(ex.Message)
                                    );
            }
        }

开发者ID:ChiangHanLung，项目名称:VDS，代码行数:30，代码来源:OUT05_SKUDBO.cs

示例11: CGR04_SetReAcceptDate

        public int CGR04_SetReAcceptDate(ArrayList ParameterList, DbTransaction DBT)
        {
            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_CGR04.CGR04_SetReAcceptDate");

                db.AddInParameter(cmd, "V_BDATE", DbType.String, ParameterList[0]);
                db.AddInParameter(cmd, "V_EDATE", DbType.String, ParameterList[1]);
                db.AddInParameter(cmd, "V_ACCEPTDATE", DbType.String, ParameterList[2]);
                db.AddOutParameter(cmd, "RES", DbType.Int16, 10);


                if (DBT == null)
                {
                    db.ExecuteNonQuery(cmd);
                }
                else
                {
                    db.ExecuteNonQuery(cmd, DBT);
                }

                return int.Parse(cmd.Parameters["RES"].Value.ToString());
            }
            catch (Exception ex)
            {
                throw new Exception("呼叫PKG_VDS_CGR04.InsertRow()發生錯誤,錯誤訊息:" + OracleExceptionProcess.OracleExceptionStringCut(ex.Message));
            }
        }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:28，代码来源:VDS_CGR04_DBO.cs

示例12: AddProductTags

 public bool AddProductTags(int productId, IList<int> tagIds, DbTransaction tran)
 {
     bool flag = false;
     DbCommand sqlStringCommand = this.database.GetSqlStringCommand("INSERT INTO Hishop_ProductTag VALUES(@TagId,@ProductId)");
     this.database.AddInParameter(sqlStringCommand, "TagId", DbType.Int32);
     this.database.AddInParameter(sqlStringCommand, "ProductId", DbType.Int32);
     foreach (int num in tagIds)
     {
         this.database.SetParameterValue(sqlStringCommand, "ProductId", productId);
         this.database.SetParameterValue(sqlStringCommand, "TagId", num);
         if (tran != null)
         {
             flag = this.database.ExecuteNonQuery(sqlStringCommand, tran) > 0;
         }
         else
         {
             flag = this.database.ExecuteNonQuery(sqlStringCommand) > 0;
         }
         if (!flag)
         {
             return flag;
         }
     }
     return flag;
 }

开发者ID:ZhangVic，项目名称:asp1110git，代码行数:25，代码来源:TagDao.cs

示例13: UpdateBoxDataMain

 public int UpdateBoxDataMain(ArrayList ParameterList, DbTransaction DBT)
 {
     try
     {
         DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_VGR06.UpdateBoxDataMain");
         //0.V_BOX_NO 
         //1.V_RETURN_NO 
         //2.V_STATUS      
         //3.D_LAST_DATE      
         //4.V_LAST_ID        
         //5.D_OLD_LAST_DATE 
         //6.V_OLD_LAST_ID
         db.AddInParameter(cmd, "V_BOX_NO", DbType.String, ParameterList[0]);
         db.AddInParameter(cmd, "V_RETURN_NO", DbType.String, ParameterList[1]);
         db.AddInParameter(cmd, "V_STATUS", DbType.String, ParameterList[2]);
         db.AddInParameter(cmd, "D_LAST_DATE", DbType.Date, ParameterList[3]);
         db.AddInParameter(cmd, "V_LAST_ID", DbType.String, ParameterList[4]);
         db.AddInParameter(cmd, "D_OLD_LAST_DATE", DbType.Date, ParameterList[5]);
         db.AddInParameter(cmd, "V_OLD_LAST_ID", DbType.String, ParameterList[6]);
         int rtn = (DBT == null) ? db.ExecuteNonQuery(cmd) : db.ExecuteNonQuery(cmd, DBT);
         return rtn;
     }
     catch (Exception ex)
     {
         throw new Exception("呼叫PKG_VDS_VGR06.UpdateBoxDataMain() 發生錯誤,錯誤訊息:" + ex.Message);
     }
 }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:27，代码来源:VDS_VGR06_DBO.cs

示例14: UpdateToVersion_1

 // update to version 3
 private static void UpdateToVersion_1(DbConnection conn, DbTransaction tran)
 {
     ExecuteNonQuery(conn, tran, "create table tmp_song_data (songid int, textdata text, dataid int);\ninsert into tmp_song_data (songid, textdata, dataid) select ID, songtext, 1 from song;\ninsert into tmp_song_data (songid, textdata, dataid) select ID, songtext, 3 from song where link_1 is not null;\ninsert into tmp_song_data (songid, textdata, dataid) select ID, songtext, 3 from song where link_2 is not null;\n");
     ExecuteNonQuery(conn, tran, "ALTER TABLE \"song\" RENAME TO \"temp_table_7_129075918630300000\"");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"song\" ( \n    \"ID\" integer primary key NOT NULL, \n    \"title\" text NULL, \n    \"groupname\" text NULL, \n    \"author\" text NULL, \n    \"lang\" text NULL, \n    \"server_id\" integer NULL, \n    \"netID\" integer NULL, \n    \"transp\" integer NULL, \n    \"published\" datetime NULL, \n    \"localmodified\" logical NULL, \n    \"remark\" text NULL, \n    CONSTRAINT \"FK_song_server_id\" FOREIGN KEY (\"server_id\") REFERENCES \"server\"(\"ID\")\n)");
     ExecuteNonQuery(conn, tran, "CREATE INDEX \"IX_song_groupname_ID\" ON \"song\" (\"groupname\",\"ID\")");
     ExecuteNonQuery(conn, tran, "INSERT INTO \"song\" (\"ID\", \"title\", \"groupname\", \"author\", \"lang\", \"server_id\", \"netID\", \"transp\", \"published\", \"localmodified\", \"remark\") select \"ID\" AS \"ID\", \"title\" AS \"title\", \"groupname\" AS \"groupname\", \"author\" AS \"author\", \"lang\" AS \"lang\", \"server_id\" AS \"server_id\", \"netID\" AS \"netID\", \"transp\" AS \"transp\", \"published\" AS \"published\", \"localmodified\" AS \"localmodified\", \"remark\" AS \"remark\" FROM \"temp_table_7_129075918630300000\"");
     ExecuteNonQuery(conn, tran, "DROP TABLE \"temp_table_7_129075918630300000\"");
     ExecuteNonQuery(conn, tran, "ALTER TABLE \"server\" RENAME TO \"temp_table_8_129075918630380000\"");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"server\" ( \n    \"ID\" integer primary key NOT NULL, \n    \"url\" text NULL, \n    \"servertype\" text NULL, \n    \"config\" text NULL, \n    \"isreadonly\" logical NULL\n)");
     ExecuteNonQuery(conn, tran, "INSERT INTO \"server\" (\"ID\", \"url\", \"servertype\", \"config\", \"isreadonly\") select \"ID\" AS \"ID\", \"url\" AS \"url\", \"servertype\" AS \"servertype\", \"config\" AS \"config\", \"isreadonly\" AS \"isreadonly\" FROM \"temp_table_8_129075918630380000\"");
     ExecuteNonQuery(conn, tran, "DROP TABLE \"temp_table_8_129075918630380000\"");
     ExecuteNonQuery(conn, tran, "ALTER TABLE \"deletedsong\" RENAME TO \"temp_table_9_129075918630410000\"");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"deletedsong\" ( \n    \"ID\" integer primary key NOT NULL, \n    \"song_netID\" integer NULL, \n    \"server_id\" integer NULL, \n    CONSTRAINT \"FK_deletedsong_server_id\" FOREIGN KEY (\"server_id\") REFERENCES \"server\"(\"ID\")\n)");
     ExecuteNonQuery(conn, tran, "INSERT INTO \"deletedsong\" (\"ID\", \"song_netID\", \"server_id\") select \"ID\" AS \"ID\", \"song_netID\" AS \"song_netID\", \"server_id\" AS \"server_id\" FROM \"temp_table_9_129075918630410000\"");
     ExecuteNonQuery(conn, tran, "DROP TABLE \"temp_table_9_129075918630410000\"");
     ExecuteNonQuery(conn, tran, "UPDATE \"info\" SET \"value\"=\'3\' WHERE \"name\"=\'dbversion\'");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"songdata\" ( \n    \"ID\" integer primary key NOT NULL, \n    \"song_id\" integer NOT NULL, \n    \"datatype_id\" integer NOT NULL, \n    \"label\" text NULL, \n    \"textdata\" text NULL, \n    CONSTRAINT \"FK_songdata_song_id\" FOREIGN KEY (\"song_id\") REFERENCES \"song\"(\"ID\"), \n    CONSTRAINT \"FK_songdata_datatype_id\" FOREIGN KEY (\"datatype_id\") REFERENCES \"datatype_list\"(\"ID\")\n)");
     ExecuteNonQuery(conn, tran, "CREATE INDEX \"IX_songdata_song_id\" ON \"songdata\" (\"song_id\")");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"datatype_list\" ( \n    \"ID\" integer NOT NULL, \n    \"name\" text NOT NULL, \n    CONSTRAINT \"PK_datatype_list\" PRIMARY KEY (\"ID\")\n)");
     ExecuteNonQuery(conn, tran, "INSERT INTO \"datatype_list\" (\"ID\", \"name\") VALUES (\'3\', \'link\')");
     ExecuteNonQuery(conn, tran, "INSERT INTO \"datatype_list\" (\"ID\", \"name\") VALUES (\'1\', \'songtext\')");
     ExecuteNonQuery(conn, tran, "INSERT INTO \"datatype_list\" (\"ID\", \"name\") VALUES (\'2\', \'notation\')");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"songlist\" ( \n    \"ID\" integer primary key NOT NULL, \n    \"name\" text NOT NULL, \n    \"options\" text NULL\n)");
     ExecuteNonQuery(conn, tran, "CREATE TABLE \"songlistitem\" ( \n    \"ID\" integer primary key NOT NULL, \n    \"song_id\" integer NOT NULL, \n    \"songlist_id\" integer NOT NULL, \n    \"transp\" integer NULL, \n    \"position\" integer NULL, \n    CONSTRAINT \"FK_songlistitem_song_id\" FOREIGN KEY (\"song_id\") REFERENCES \"song\"(\"ID\"), \n    CONSTRAINT \"FK_songlistitem_songlist_id\" FOREIGN KEY (\"songlist_id\") REFERENCES \"songlist\"(\"ID\")\n)");
     ExecuteNonQuery(conn, tran, "CREATE INDEX \"IX_songlistitem_song_id\" ON \"songlistitem\" (\"song_id\")");
     ExecuteNonQuery(conn, tran, "CREATE INDEX \"IX_songlistitem_songlist_id\" ON \"songlistitem\" (\"songlist_id\")");
     ExecuteNonQuery(conn, tran, "insert into songdata (song_id, textdata, datatype_id) \nselect songid, textdata, dataid from tmp_song_data;\ndrop table tmp_song_data;\n\n");
     ExecuteNonQuery(conn, tran, "update info set value=\'3\' where name=\'dbversion\'");
 }

开发者ID:BackupTheBerlios，项目名称:zp7-svn，代码行数:31，代码来源:DbCreator.cs

示例15: doCreateMutiStoreData

        /// <summary>
        /// 執行轉門市唯一檔 
        /// </summary>
        public int[] doCreateMutiStoreData(DbTransaction DBT)
        {
            try
            {
                int[] intCNT =new int[2];
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_STM03.InsertMuti");
                db.AddOutParameter(cmd, "VCOUNT", DbType.VarNumeric, Int32.MaxValue);
                db.AddOutParameter(cmd, "V_DIS_SW_COUNT", DbType.VarNumeric, Int32.MaxValue);
               
                int ProcessRecord = (DBT == null) ? db.ExecuteNonQuery(cmd) : db.ExecuteNonQuery(cmd, DBT);

                if (ProcessRecord == 0)
                {
                    throw new Exception("輸入資料失敗!");
                }

                intCNT[0] = int.Parse((db.GetParameterValue(cmd, "VCOUNT")).ToString());
                intCNT[1] = int.Parse((db.GetParameterValue(cmd, "V_DIS_SW_COUNT")).ToString());

                return intCNT;


            }
            catch (Exception ex)
            {
                throw new Exception("呼叫STM_CreateStoreUniqueFileDBO.doCreateMutiStoreData()發生錯誤,錯誤訊息:"
                                    + OracleExceptionProcess.OracleExceptionStringCut(ex.Message)
                                    );
            }
        }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:33，代码来源:STM_CreateStoreUniqueFileDBO.cs

示例16: Insert

        public static bool Insert(SurveyEntity survey, Database db, DbTransaction transaction)
        {
            DbCommand command = db.GetStoredProcCommand("usp_SurveyInsert");

            db.AddInParameter(command, "MyUniversity", DbType.String, survey.MyUniversity);
            db.AddInParameter(command, "UniversityName", DbType.String, survey.UniversityName);
            db.AddInParameter(command, "UniversityAddress", DbType.String, survey.UniversityAddress);
            db.AddInParameter(command, "TypeOfResidence", DbType.String, survey.TypeOfResidence);
            db.AddInParameter(command, "TypeOfResidenceOption", DbType.String, survey.TypeOfResidenceOption);
            db.AddInParameter(command, "NameOfResidence", DbType.String, survey.NameOfResidence);
            db.AddInParameter(command, "AddressOfResidence", DbType.String, survey.AddressOfResidence);
            db.AddInParameter(command, "PropertyOwnerComment", DbType.String, survey.PropertyOwnerComment);
            db.AddInParameter(command, "Email", DbType.String, survey.Email);

            if (transaction == null)
            {
                db.ExecuteNonQuery(command);
            }
            else
            {
                db.ExecuteNonQuery(command, transaction);
            }

            return true;
        }

开发者ID:nirshandileep，项目名称:RHP，代码行数:25，代码来源:SurveyDAO.cs

示例17: Find

        /// <summary>
        /// 
        /// </summary>
        /// <param name="criteria"></param>
        /// <param name="connection"></param>
        /// <param name="transaction"></param>
        /// <returns></returns>
        public MembershipEntity Find(MembershipsCriteria criteria, DbConnection connection, DbTransaction transaction)
        {
            var password = criteria.Password;
            if (password == null) { this.DoNothing(); }
            else
            {
                if (criteria.Password is SecureString) { password = ((SecureString)criteria.Password).GetString(); }

                var hash = KandaHashAlgorithm.ComputeHash( typeof(SHA512Managed).FullName, (string)password, Encoding.Unicode);
                password = hash;
            }
            criteria.Password = password;

            var reader = default(KandaDbDataReader);

            try
            {
                reader = MembershipsGateway.Select(criteria, connection, transaction);

                var found = (reader.Read() ? KandaDbDataMapper.MapToObject<MembershipEntity>(reader) : MembershipEntity.Empty);

                return found;
            }
            finally
            {
                if (reader != null) { reader.Close(); }
            }
        }

开发者ID:kkkkkkaaaaaa，项目名称:kkkkkkaaaaaa，代码行数:35，代码来源:MembershipsRepository.cs

示例18: DeleteShipSubsidy

        //刪除離島配送費補貼
        public string[] DeleteShipSubsidy(ArrayList ParameterList, DbTransaction DBT)
        {
            string[] strReturn = new string[2];

            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_VAM32.DeleteShipSubsidy");
                db.AddInParameter(cmd, "V_VENDOR", DbType.String, ParameterList[0]);
                db.AddInParameter(cmd, "V_ITEM", DbType.String, ParameterList[1]);
                db.AddInParameter(cmd, "V_UID", DbType.String, ParameterList[2]);
                db.AddOutParameter(cmd, "V_RESULT", DbType.String, 38);
                db.AddOutParameter(cmd, "V_MSG", DbType.String, 100);

                db.ExecuteNonQuery(cmd, DBT);

                strReturn[0] = cmd.Parameters[cmd.Parameters.Count - 2].Value.ToString();
                strReturn[1] = cmd.Parameters[cmd.Parameters.Count - 1].Value.ToString();

                return strReturn;
            }
            catch (Exception ex)
            {
                throw new Exception("呼叫PKG_VDS_VAM32.DeleteShipSubsidy()發生錯誤，錯誤訊息："
                                    + OracleExceptionProcess.OracleExceptionStringCut(ex.Message));
            }
        }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:27，代码来源:VAM32_DBO.cs

示例19: InsertData

        internal void InsertData(ArrayList ParameterList, DbTransaction DBT, out int ID)
        {
            try
            {
                DbCommand cmd = db.GetStoredProcCommand("PKG_VDS_VAM15.InsertData");
                db.AddInParameter(cmd, "V_PROMOTE_ID", DbType.String, ParameterList[0]);
                db.AddInParameter(cmd, "V_VENDOR", DbType.String, ParameterList[1]);
                db.AddInParameter(cmd, "V_TAX_TYPE", DbType.String, ParameterList[2]);
                db.AddInParameter(cmd, "V_TAX_REMAIN_AMT", DbType.String, ParameterList[3]);
                db.AddInParameter(cmd, "V_UTAX_REMAIN_AMT", DbType.String, ParameterList[4]);
                db.AddInParameter(cmd, "V_TAX_AMT", DbType.String, ParameterList[5]);
                db.AddInParameter(cmd, "V_UTAX_AMT", DbType.String, ParameterList[6]);
                db.AddInParameter(cmd, "V_TAX", DbType.String, ParameterList[7]);
                db.AddInParameter(cmd, "V_UPDATEUID", DbType.String, ParameterList[8]);
                db.AddInParameter(cmd, "V_UPDATEDATE", DbType.String, ParameterList[9]);
                db.AddInParameter(cmd, "V_CREATEUID", DbType.String, ParameterList[10]);
                db.AddInParameter(cmd, "V_CREATEDATE", DbType.String, ParameterList[11]);

                db.AddOutParameter(cmd, "N_ID", DbType.Int32, 10);

                db.ExecuteNonQuery(cmd, DBT);

                ID = int.Parse(db.GetParameterValue(cmd, "N_ID").ToString());

            }
            catch (Exception ex)
            {
                throw new Exception("呼叫PKG_VDS_VAM15.InsertData()發生錯誤,錯誤訊息:" + OracleExceptionProcess.OracleExceptionStringCut(ex.Message));
            }
        }

开发者ID:ChiangHanLung，项目名称:PIC_VDS，代码行数:30，代码来源:VAM15_DBO.cs

示例20: PrepareCommand

        private static void PrepareCommand(
            DbCommand command,
            DbConnection connection,
            DbTransaction transaction,
            CommandType commandType,
            string commandText,
            DbParameter[] commandParameters)
        {
            if (command == null) throw new ArgumentNullException("command");
            if (commandText == null || commandText.Length == 0) throw new ArgumentNullException("commandText");

            command.Connection = connection;
            command.CommandText = commandText;
            command.CommandType = commandType;

            if (transaction != null)
            {
                if (transaction.Connection == null) throw new ArgumentException("The transaction was rollbacked or commited, please provide an open transaction.", "transaction");
                command.Transaction = transaction;
            }

            if (commandParameters != null)
            {
                AttachParameters(comma

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

C# Common.RowUpdatedEventArgs类代码示例发布时间：2022-05-26

C# Common.DbProviderManifest类代码示例发布时间：2022-05-26

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18146|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9633|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8161|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8538|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8439|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9360|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8410|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7848|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8395|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7387|2022-11-06

客服电话

电子邮件

C# Common.DbTransaction类代码示例

示例1: DeleteRoleRightsByRoleId

示例2: doCreate

示例3: Insert

示例4: CategoryDelete

示例5: DiscoverSpParameterSet

示例6: AddReviewBillContent

示例7: doCreate

示例8: PicturesInsertUpdate

示例9: doCreate

示例10: doCloseOrder

示例11: CGR04_SetReAcceptDate

示例12: AddProductTags

示例13: UpdateBoxDataMain

示例14: UpdateToVersion_1

示例15: doCreateMutiStoreData

示例16: Insert

示例17: Find

示例18: DeleteShipSubsidy

示例19: InsertData

示例20: PrepareCommand

请发表评论

全部评论

上一篇：

下一篇：

MikeMcQuaid/strap:

headcr4sh/node-maven: Maven for Node.js

CVE-2022-26527

traex/RippleEffect: Implementation of Ri

pravega/zookeeper-operator: Kubernetes O

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053