[DBMoto API]外部からレプリケーションやグループを開始・停止するサンプルC#プログラム

Tweet

DBMoto APIを使用することで、GUIツールであるDBMoto Management Centerからの操作ではなく、バッチを実行することで外部からDBMotoの操作を制御することが可能です。

ここではDBMotoのレプリケーションジョブやグループジョブを外部から制御するプログラムをご紹介します。
これらを使用することで、任意のタイミングでジョブを実行・停止したり、他アプリケーションとの連携が可能となります。

●レプリケーションを有効化・無効化するサンプルC#プログラム

using System;
using System.Collections.Generic;
using System.Text;
using HiTSoftware.DBMoto.Application;
using HiTSoftware.DBMoto.ObjectModel;

namespace APISamples
{
    public class SampleReplicationAsynch
    {
        public static void Main()
        {
            DBMotoApplication dbmApp = null;
            IServer dbmServer = null;
            IMetadata currentMetadata = null;

            try
            {
                // 初期設定、サーバ接続
                dbmApp = DBMotoApplication.Instance;
                dbmServer = dbmApp.Servers["local"];
                dbmServer.Connect();

                // カレントメタデータのロード
                currentMetadata = dbmServer.Metadatas.DefaultMetadata;
                currentMetadata.Load(true);

                // レプリケーション名
                IReplication repl = currentMetadata.Replications["Replication"];

                // レプリケーション有効化
                if (repl.ReplStatus == ReplStatus.Disabled)
                    repl.AsynchEnable();

                // 待機
                System.Threading.Thread.Sleep(3000);

                // レプリケーション無効化
                if (repl.ReplStatus != ReplStatus.Disabled)
                    repl.AsynchDisable();

                // 待機
                System.Threading.Thread.Sleep(3000);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
            finally
            {
                if (currentMetadata != null)
                    currentMetadata.Unload();
                if (dbmServer != null)
                    dbmServer.Disconnect();
                if (dbmApp != null)
                    dbmApp.Dispose();
            }
        }

    }
}

●グループを有効化・無効化するサンプルC#プログラム

using System;
using System.Collections.Generic;
using System.Text;
using HiTSoftware.DBMoto.Application;
using HiTSoftware.DBMoto.ObjectModel;

namespace APISamples
{
    public class SampleGroupAsynch
    {
        public static void Main()
        {
            DBMotoApplication dbmApp = null;
            IServer dbmServer = null;
            IMetadata currentMetadata = null;

            try
            {
                // 初期設定、サーバ接続
                dbmApp = DBMotoApplication.Instance;
                dbmServer = dbmApp.Servers["local"];
                dbmServer.Connect();

                // カレントメタデータのロード
                currentMetadata = dbmServer.Metadatas.DefaultMetadata;
                currentMetadata.Load(true);

                // グループ名
                IGroup group = currentMetadata.Groups["Group"];

                // グループ有効化
                if (group.ReplStatus == ReplStatus.Disabled)
                    group.AsynchEnable();

                // 待機
                System.Threading.Thread.Sleep(3000);

                // グループ無効化
                if (group.ReplStatus != ReplStatus.Disabled)
                    group.AsynchDisable();

                // 待機
                System.Threading.Thread.Sleep(3000);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
            finally
            {
                if (currentMetadata != null)
                    currentMetadata.Unload();
                if (dbmServer != null)
                    dbmServer.Disconnect();
                if (dbmApp != null)
                    dbmApp.Dispose();
            }
        }

    }
}

関連したトピックス

• APIからリフレッシュを実行するサンプルスクリプト[C#] [Syniti DR (DBMoto)]
• APIからレプリケーションの最新の実行件数を取得するサンプルスクリプト[C#] [Syniti DR (DBMoto)]
• APIからレプリケーション結果の検証やデータ整合を実行するサンプルスクリプト[C#] [Syniti DR (DBMoto)]
• DBMotoが使うスレッド数の算出方法【リアルタイムレプリケーションツールDBMoto】
• Syniti Data Replication (旧DBMoto)でのスクリプトの書き方④：レプリケーションスクリプト
• Syniti Data Replication (旧DBMoto)でのスクリプトの書き方③：グローバルスクリプト用の関数とイベント
• 2つのソーステーブルからターゲットの一つのレコードにレプリケーション
• レプリケーションの際にnullを特定の値に変換する方法　その1【リアルタイムレプリケーションツールDBMoto】
• MySQLへのレプリケーションで “Loading local data is disabled” エラーとなる場合の対処法
• ジュリアンデートのレプリケーション【リアルタイムレプリケーションツールDBMoto】