3

SQLまたはfoxproのいずれかで動作するC＃プログラムでOleDbを使用しています。foxproデータを使用してトランザクションでステートメントを実行してから、RollBackを呼び出そうとしても、データが元に戻らないことに気付きました。SQLデータを使用して実行する場合、ロールバックは正常に機能するため、FoxProでも機能しない理由が少しわかりません。

私のテストアプリケーションでは、テーブル（TESTTABLE）からグリッドのデータソースにバインドされているデータテーブルにレコードを読み込んでいます。グリッドに行を追加し、保存ボタンを押してデータベーステーブルをクリアしてから、バインドされたDataTable内の現在のすべての行をループして、データベーステーブルに挿入し直します。理論的には、挿入中に問題が発生した場合、RollBackは削除を元に戻す必要があります。私が気付いているのは、挿入が失敗してトランザクションをロールバックした場合、テーブルが削除前の状態に戻るのではなく、削除されたレコードが削除されたままになることです。

2013年1月23日編集

VisualFoxPro9.0.0.5815を使用しています。テーブルが緩んでいるので、作成後にテーブルで「MAKETRANSACTABLE」を実行する必要があります。これを行うには、OleDbCommandを使用して次のコマンドを実行します

string commandText = "ExecScript('Use TESTTABLE In 0'+chr(13)+chr(10)+'MakeTransactable([TESTTABLE])')"

これが私が使っている保存機能です...

    private void Save()
    {

        //Table: TESTTABLE
        //Columns: REFERENCE NUMERIC(10), DESCRIPT VARCHAR(20)

        bool CauseException = cbBreak.Checked;
        //string SQLDbConnString = @"Provider=SQLNCLI;Server=TESTSERVER\\SQLExpress;Database=TESTDATA;Uid=test;Pwd=test;Connect Timeout=600";
        string FoxProDbConnString = @"Provider=vfpoledb;Data Source=C:\Test\Data;Exclusive=false;Nulls=false;ConnectTimeOut=600;QueryTimeOut=600;";

        using (OleDbConnection dbConn = new OleDbConnection(FoxProDbConnString))
        {
            dbConn.Open();
            using (OleDbTransaction dbTran = dbConn.BeginTransaction())
            {
                try
                {
                    //Run a delete command to remove all records from the table
                    string deletequery = "DELETE FROM TESTTABLE";
                    using (OleDbCommand cmd = new OleDbCommand(deletequery, dbConn, dbTran))
                    {
                        cmd.ExecuteNonQuery();
                    }

                    //Loop through the DataTable rows and insert them into the database table
                    foreach (DataRow row in dt.Rows)
                    {
                        string insertquery = "INSERT INTO TESTTABLE (REFERENCE, DESCRIPT) VALUES (?,?)";
                        using (OleDbCommand cmd = new OleDbCommand(insertquery, dbConn, dbTran))
                        {
                            if (CauseException)
                            {
                                cmd.Parameters.Add("ref", OleDbType.Numeric).Value = "THIS IS NOT A NUMERIC VALUE";
                            }
                            else
                            {
                                cmd.Parameters.Add("ref", OleDbType.Numeric).Value = Convert.ToDouble(row["reference"]);
                            }
                            cmd.Parameters.Add("descript", OleDbType.VarChar).Value = Convert.ToString(row["descript"]).Trim();
                            cmd.ExecuteNonQuery();
                        }
                    }

                    //If no exceptions were thrown during the inserts, commit the transaction    
                    dbTran.Commit();
                    MessageBox.Show("Saved");
                }
                catch (Exception ex)
                {
                    //If an exception occurs, RollBack the transaction.  This SHOULD undo the delete.
                    dbTran.Rollback();
                    MessageBox.Show("Failed to save. Rolling back changes.");
                }
            }
        }
    }

2013年1月24日編集

System.Data.OleDbの代わりにSystem.Data.Odbcを使用して上記と同じコードをテストしたところ、トランザクションは完全に機能しました。次の接続文字列を使用しました。

string odbcConnStr = @ "Driver = {INTERSOLV dBASEFile（* .DBF）}; SourceDB = C：\ Test \ Data;";

ここでの問題は、特にvfpoledbプロバイダーがトランザクションを正しく処理していないことにあるように思われます。私が調べた別の方法は、ルーズテーブルの代わりにデータベースコンテナを使用することでしたが、「CREATEDATABASE」関数はvfpoledbでサポートされていないようです。

4

1 に答える 1

3

私はあなたのMakeTransactable編集を取り、それを肉付けしました。それは次のように呼ばれます：

cnn.MakeTransactable("directory/table");

コード：

public static class OleDbConnectionMakeTransactableExtensions
{
    private static readonly Dictionary<int, List<string>> AlreadyTransactable = new Dictionary<int, List<string>>();

    public static void MakeTransactable(this OleDbConnection connection, string freeTableName)
    {
        OleDbTransaction tran = connection.GetActiveTransaction();
        if (tran == null)
        {
            throw new InvalidOperationException("No transaction set");
        }

        int key = tran.GetHashCode();
        List<string> transactable;
        if (!AlreadyTransactable.TryGetValue(key, out transactable))
        {
            transactable = new List<string>();
            AlreadyTransactable.Add(key, transactable);
        }

        freeTableName = OtherExtensionMethods.GetCleanTablePath(freeTableName);

        if (transactable.Contains(freeTableName, StringComparer.InvariantCultureIgnoreCase))
        {
            return;
        }

        string alias = connection.GetCurrentAlias(freeTableName);
        if (alias == null)
        {
            connection.ExecScript(string.Format("use [{0}] shared again in 0", freeTableName));
            alias = connection.GetCurrentAlias(freeTableName);

            if (alias == null)
            {
                throw new InvalidOperationException(string.Format("Could not get an alias for table '{0}'", freeTableName));
            }
        }

        connection.ExecScript(string.Format(@"
IF NOT ISTRANSACTABLE('{0}') THEN
    MAKETRANSACTABLE('{0}')
ENDIF
", alias));

        transactable.Add(freeTableName);
    }

    public static string GetCurrentAlias(this OleDbConnection connection, string freeTableName)
    {
        freeTableName = OtherExtensionMethods.GetCleanTablePath(freeTableName);
        string alias = connection.ExecScript<string>(string.Format(@"
LOCAL cTable, cAlias, nIndex, nAliasCount, cDbf, cCheck
LOCAL ARRAY aUsedAliases[1]
LOCAL cList

cTable = LOWER(ADDBS(JUSTPATH(""{0}"")) + JUSTSTEM(""{0}""))
nAliasCount = AUSED(""aUsedAliases"")
IF nAliasCount = 0 THEN
    RETURN """"
ENDIF

cList = cTable + ': '

FOR nIndex = 1 TO nAliasCount
    cAlias = aUsedAliases[1, 1]
    cDbf = LOWER(DBF(cAlias))

    cCheck = RIGHT(ADDBS(JUSTPATH(cDbf)) + JUSTSTEM(cDbf), LEN(cTable))
    cList = cList + ', ' + cAlias + ' -> ' + cDbf + ' -> ' + cCheck

    IF cCheck = cTable THEN
        RETURN cAlias
    ENDIF
ENDFOR

RETURN """"
", freeTableName));
        return alias.EmptyToNull();
    }
}

public static class OleDbConnectionTransactionExtensions
{
    public static OleDbCommand WithTransactionSet(this OleDbCommand command)
    {
        if (command.Connection == null)
        {
            throw new InvalidOperationException("Command does not have a Connection set");
        }
        var transaction = command.Connection.GetActiveTransaction();
        if (!Equals(command.Transaction, transaction))
        {
            command.Transaction = transaction;
        }
        return command;
    }

    public static OleDbTransaction GetActiveTransaction(this OleDbConnection connection)
    {
        if (connection.State != ConnectionState.Open)
        {
            throw new ArgumentOutOfRangeException("connection", "Connection is not open");
        }
        return GetTransaction(connection);
    }

    private static readonly Func<OleDbConnection, OleDbTransaction> GetTransaction;

    static OleDbConnectionTransactionExtensions()
    {
        var getOpenConnectionMethod = typeof(OleDbConnection).GetMethod("GetOpenConnection", BindingFlags.Instance | BindingFlags.NonPublic);
        if (getOpenConnectionMethod == null)
        {
            throw new InvalidOperationException("Could not find the GetOpenConnection() internal method on OleDbConnection");
        }

        var internalType = getOpenConnectionMethod.ReturnType;
        var localTransactionProperty = internalType.GetProperty("LocalTransaction", BindingFlags.Instance | BindingFlags.NonPublic);
        if (localTransactionProperty == null)
        {
            throw new InvalidOperationException("Could not find the LocalTransaction property on OleDbConnectionInternal");
        }

        var param = Expression.Parameter(typeof(OleDbConnection));
        var connection = Expression.Call(param, getOpenConnectionMethod);
        var transaction = Expression.Property(connection, localTransactionProperty);

        var lambda = Expression.Lambda<Func<OleDbConnection, OleDbTransaction>>(transaction, param);
        var compiled = lambda.Compile();

        GetTransaction = compiled;
    }
}

public static class OtherExtensionMethods
{
    public static void ExecScript(this OleDbConnection connection, string script)
    {
        using (var command = connection.CreateCommand().WithTransactionSet())
        {
            command.CommandType = CommandType.StoredProcedure;
            command.CommandText = "EXECSCRIPT";
            command.Parameters.Add(new OleDbParameter("script", script));
            command.ExecuteNonQuery();
        }
    }

    public static T ExecScript<T>(this OleDbConnection connection, string script)
    {
        using (var command = connection.CreateCommand().WithTransactionSet())
        {
            command.CommandType = CommandType.StoredProcedure;
            command.CommandText = "EXECSCRIPT";
            command.Parameters.Add(new OleDbParameter("script", script));

            object raw = command.Logged().ExecuteScalar();
            return ConvertDbResult<T>(raw);
        }
    }

    public static string GetCleanTablePath(string tablePath)
    {
        return tablePath.ToLower().Replace("/", "\\").Trim("\\"[0]);
    }
}

GetActiveTransaction()andメソッド呼び出しはWithTransactionSet()、内部状態を使用して、接続からアクティブなトランザクションをプルします。

于 2013-05-19T13:19:39.347 に答える