我有一些 C# 代码在事务中使用“ON COMMIT DELETE ROWS”选项创建多个 Oracle 临时表。
在事务内部,我将在各种临时表中插入一堆行。在某些情况下,我需要截断特定的临时表,以便我可以从该表重新开始,但不理会其他临时表。
我发现当您执行截断时,Oracle 必须执行隐式 COMMIT,因为不仅特定的临时表被截断,而且我的所有临时表都被截断。
好的,我在其他地方读到 Truncate 命令被认为是 DDL 命令,这就是为什么正在处理提交,这导致我的“ON COMMIT DELETE ROWS”临时表被清除。
如果这是真的,那么创建一个新的临时表的行为难道不是一个 DDL 命令,而且它还会触发清除所有其他临时表的相同提交?如果是这样,我还没有看到这种行为。我在我的代码中创建了新的临时表,发现在创建新的临时表后,之前创建的临时表的行仍然完好无损。
下面是一些演示该问题的 C# 代码(此处未包含帮助程序):
private void RunTest()
{
if (_oc == null)
_oc = new OracleConnection("data source=myserver;user id=myid;password=mypassword");
_oc.Open();
_tran = _oc.BeginTransaction();
string tt1 = "DMTEST1";
AddTempTable(tt1, false);
int TempTableRowCount0 = GetTempTableRowCount(tt1);
AddRows(tt1, 5);
int TempTableRowCount10 = GetTempTableRowCount(tt1);
string tt2 = "DMTEST2";
AddTempTable(tt2, false);
int TempTableRowCount12 = GetTempTableRowCount(tt1); // This will have the same value as TempTableRowCount10
AddRows(tt2, 6);
int TempTableRowCount13 = GetTempTableRowCount(tt2); // This will have the same value as TempTableRowCount10
string tt3 = "DMTEST3";
AddTempTable(tt3, true); // The TRUE argument which does a TRUNCATE against the DMTEST3 table is the problem
int TempTableRowCount14 = GetTempTableRowCount(tt1); // This will return 0, it should be = TempTableRowCount10
int TempTableRowCount15 = GetTempTableRowCount(tt2); // This will return 0, it should be = TempTableRowCount13
_tran.Commit();
_tran = null;
int TempTableRowCount20 = GetTempTableRowCount(tt1); // This should be 0 because the transaction was committed
int TempTableRowCount21 = GetTempTableRowCount(tt2); // and the temp tables are defined as "ON COMMIT DELETE ROWS"
}
private void AddTempTable(string TableName, bool Truncate)
{
IDbCommand ocmd = new OracleCommand();
ocmd.Connection = _oc;
if (!TableExists(TableName))
{
ocmd.CommandText = string.Format("CREATE GLOBAL TEMPORARY TABLE {0} ({1}) ON COMMIT DELETE ROWS", TableName, "FIELD1 Float");
int rc = ocmd.ExecuteNonQuery();
}
if (Truncate)
{
ocmd.CommandText = "TRUNCATE TABLE " + TableName;
int rc = ocmd.ExecuteNonQuery();
}
}