DBMoto ver8.2.1.10より、PostgreSQLのXML型UUID型のリフレッシュ、およびミラーリングの対応を開始しました。

PostgreSQLにターゲットテーブルを作成する際にも、XML型、UUID型の指定が可能です。

マッピング情報でも各データ型の表示が確認できます。

DBMotoは「リモート接続モード」に対応しています。
例えばDBMotoを2ライセンス（2構成）ご購入いただいている場合、ライセンスは以下の方法にて生成することが可能です。それぞれのメリットとデメリットもまとめました。

1. 2ライセンスを1つのライセンスファイルにまとめる

【メリット】1台のDBMotoマシンのみで運用可能
【デメリット】2構成分を1つのマシンでレプリケーションするため負荷がかかる可能性がある

2. 2ライセンスそれぞれ別々のライセンスファイルとする

【メリット】DBMotoマシンは2台なのでレプリケーション処理を分散可能
【デメリット】DBMotoマシンを2台用意する必要がある

さて、2の別々のライセンスファイルとした場合のデメリットを補う方法が「リモート接続モード」です。リモート監視用のDBMotoマシンをもう1台用意していただく必要がありますが、2台のレプリケーション用DBMotoマシンへ接続可能であるため、事実上1の1つのライセンスファイルにまとめたときと同様に一元管理が可能となります。
※しかも2のメリットである負荷分散も可能！！

接続イメージは下記の通りです。

●リモート接続モード設定手順

リモート接続モード用のDBMotoマシンをインストール時に「Remote Management Center Installation」を選択します。このモードでインストール時はライセンスファイルの適用は不要です。

インストール完了後、レプリケーション用のDBMotoマシンへリモート接続設定を行います。まず「新しいサーバを追加」を選択します。

任意の接続名と接続先IPアドレスを入力します。ポートは既定の58361のままで問題ございません。

実際に2台のレプリケーション用DBMotoマシンへ接続した際の画面です。このようにmetadataがそのまま読み込まれます。

【リモート接続モード使用時の注意点】
・リモート接続の際は、レプリケーション用DBMotoマシンにてDBMoto Server Agentが稼働している必要があり、ポート58361の解放が必要です。
・リモート接続後のmetadataにて直接設定が可能ですが、DB接続時にはリモート接続モードのDBMotoマシンから接続する仕様です。DB接続の際はリモート接続モードのDBMotoマシンにDBの各ドライバが必要です。
・DBMoto Data Replicatorの実行はレプリケーション用DBMotoマシンにて行います。

2つのテーブルを1つのテーブルにレプリケーションす場合には以下のような手順で実施します。
1．一つのターゲットテーブルに対して、各ソーステーブルからレプリケーションを作成します。
2．ターゲットテーブルでのトランケートや結合を制御するため、各レプリケーションでスクリプトを設定します。
3．レプリケーションを一つのグループに設定します。
4．全てのレコードを削除し、ターゲットテーブルをクリーンアップします。
5．レプリケーションを実行します。

例として、以下のようなレプリケーションを行う場合をご紹介します。

MULTITEST1 > MULTITEST3のレプリケーションを作成します。
1．マッピング設定でID, NAME, COMPANYをマッピングします。
2．UNITにはvbNullをマップします。

3．レプリケーションを無効にし、ウィザードを完了します。
4．レプリケーションのプロパティを開きます。
5．スクリプトの使用にチェックを入れ、以下のスクリプトを追加します。

[vb]
Imports Microsoft.VisualBasic
Imports DBMotoPublic
Imports DBMotoScript
Imports DBRS.GlobalScript

Namespace DBRS
    Public Class ReplicationScript : Inherits IreplicationScript
      Dim PrimaryKey As String
      Dim Field As String
      Dim Table2 As String 

      Public Overrides Sub Refresh_onBeforeTruncate(ByRef CancelTruncate As Boolean, ByRef Filter As String)
　　　　'リフレッシュ時のレコード削除を無効化
        CancelTruncate = True
      End Sub

      Public Overrides Sub Record_onAfterMapping( recSource As DBMotoPublic.IRecord,  recTarget As DBMotoPublic.IRecord, ByRef AbortRecord As Boolean, ByRef DisableReplication As Boolean)
        Table2 = """asami"".MULTITEST2" 'もう一方のテーブル
        PrimaryKey = "ID" '主キー
        Field = "UNIT" 'vbNullをマップしたフィールド
        '主キーが変更されていない場合
        If recTarget.GetValueAfter(PrimaryKey) = Nothing Then
          recTarget.SetValueAfter(Field, Nothing)
        '主キーが変更されている場合(またはinsert)
        Else
          InterpolationFields (recTarget)
        End If
      End Sub
      '補間するためにFieldの値を検索
      Private Sub InterpolationFields (recTarget As IRecord)
        Dim cmd As System.Data.IdbCommand
        Dim rs As System.Data.IdataReader
        Dim SQL As String
        'Table2からPrimaryKeyのレコードを検索
        SQL = "Select * From " + Table2 + " Where " + PrimaryKey + " = " & recTarget.GetValueAfter(PrimaryKey)
        'レプリケーションのソース接続情報を取得
        cmd = SourceConnection.CreateCommand
        'コマンドにSQLクエリを代入
        cmd.CommandText = SQL
        'SQLを実行
        rs = cmd.ExecuteReader
        'FieldのvbNullを取得した値に置き換え
        While rs.Read
          recTarget.SetValueAfter(Field, rs(Field))
        End While
        rs.Close
      End Sub
    End Class
End Namespace
[/vb]

MULTITEST2 > MULTITEST3のレプリケーションを作成します。
1．マッピング設定でID, NAME, UNITをマッピングします。
2．COMPANYにはvbNullをマップします。
3．レプリケーションを無効にし、ウィザードを完了します。
4．レプリケーションのプロパティを開きます。
5．スクリプトの使用にチェックを入れ、以下のスクリプトを追加します。

[vb]
Imports Microsoft.VisualBasic
Imports DBMotoPublic
Imports DBMotoScript
Imports DBRS.GlobalScript

Namespace DBRS
    Public Class ReplicationScript : Inherits IreplicationScript
      Dim PrimaryKey As String
      Dim Field As String
      Dim Table1 As String
      Dim Table2 As String
      Dim Table3 As String 

      Public Overrides Sub Refresh_onBeforeTruncate(ByRef CancelTruncate As Boolean, ByRef Filter As String)
            CancelTruncate = True
      End Sub

      Public Overrides Sub Record_onAfterMapping( recSource As DBMotoPublic.IRecord,  recTarget As DBMotoPublic.IRecord, ByRef AbortRecord As Boolean, ByRef DisableReplication As Boolean)
        Table1 = """asami"".MULTITEST1" 'もう一方のソーステーブル
        Table2 = """asami"".MULTITEST2" 'ソーステーブル
        Table3 = "ASAMI.MULTITEST3" 'ターゲットテーブル
        PrimaryKey = "ID" '主キー
        Field = "UNIT" 'もう一方のレプリケーションでvbNullをマップしたフィールド
        'insert,update,deleteでの場合分け
        Select Case recTarget.OperationType
          'insertの場合、ターゲットのFieldに対してupdateを実施
          Case enmOperationType.Insert
            UpdateFields(recTarget)
            AbortRecord = True
          'updateの場合
          Case enmOperationType.Update
            '主キーが変更されている場合、ターゲットの変更前のFieldをNullにupdate
            If recTarget.GetValueAfter(PrimaryKey) <> recTarget.GetValueBefore(PrimaryKey) Then
              SetNull(recTarget)
            End If
            'ターゲットのFieldに対してupdateを実施
            UpdateFields(recTarget)
            AbortRecord = True
            'Deleteの場合
            Case enmOperationType.Delete
　　　　　　　　'Fieldをnullにupdate
              SetNull(recTarget)
              AbortRecord = True
        End Select
      End Sub

      'Fieldに対するupdate
      Private Sub UpdateFields (recTarget As IRecord)
        Dim SQL As String
        SQL = "Update " + Table3 + " Set "
        'FieldがNullの場合はNullにupdate
        If recTarget.GetValueAfter(Field) = Nothing Then
          SQL = SQL + " " + Field + " = Null "
        'Fieldの値でupdateを実施
        Else
          SQL = SQL + " " + Field + " = '" + recTarget.GetValueAfter(Field) + "'"
        End If
        '主キーに変更がない場合は変更前の主キーのレコードをupdate
        if recTarget.GetValueAfter("ID") = Nothing then
          SQL = SQL + " Where " + PrimaryKey + " = '" + recTarget.GetValueBefore(PrimaryKey) +  "'"
        '主キーが変更されている場合は変更後の主キーのレコードをupdate
        else
          SQL = SQL + " Where " + PrimaryKey + " = '" + recTarget.GetValueAfter(PrimaryKey) +  "'"
        End if 

        AddLog ("UpdateFields SQL: " + SQL, 0)
        Try
          Dim cmd As System.Data.IdbCommand
          cmd = TargetConnection.CreateCommand
          cmd.CommandText = SQL
          cmd.ExecuteNonQuery()
        Catch Ex As System.Exception
          AddLog (Table2 + ".*_onAfterFieldMapping (UpdateFields): Cannot update field UNIT on Table " + Table3 + " (" + Ex.Message + ")", 1)
        End Try
      End Sub
      'FieldをNullにupdate
      Private Sub SetNull (recTarget As IRecord)
        Dim SQL As String

        SQL = "Update " + Table3 + " Set " + Field + " = Null Where ID = '" + recTarget.GetValueBefore(PrimaryKey) +  "'"
        AddLog ("SetNull: " + SQL, 0)
        Try
            Dim cmd As System.Data.IdbCommand
            cmd = TargetConnection.CreateCommand
            cmd.CommandText = SQL
            cmd.ExecuteNonQuery()
        Catch Ex As System.Exception
            AddLog (Table2 + ".*_onAfterFieldMapping (SetNull): Cannot update field UNIT on Table " + Table3 + " (" + Ex.Message + ")", 1)
        End Try
      End Sub
    End Class
End Namespace
[/vb]

このようにスクリプトを使用することでターゲットテーブルの一つのレコードを2つのソーステーブルから作成可能です。
しかし、このスクリプトには以下のような制限もあります。
・リフレッシュ時には手動でのターゲットテーブルのレコード削除が必須
・MULTITEST1に存在しない主キーをMULTITEST2にinsertした場合、MULTITEST3にその情報は連携されない
等々

そのため、連携を行うテーブルに合わせてスクリプトをカスタマイズする必要があります。

【2014/1/14・3/31記事改訂】

●全件リフレッシュの再設定

リフレッシュは通常初回の1回のみ行われますが、何らかの理由でミラーリングが行えなくなって整合性が失われた場合（ログが流れてしまった等）などは、リフレッシュの再設定を行うことが可能です。

■バージョン8.1までの場合
1. レプリケーション名を右クリック「プロパティ」を開きます。
※グループ化されている場合はグループ名を右クリック「レプリケーションを編集」です。

2. 左ペインから「スケジュール」を選択し、「初期リフレッシュ実行」にチェックが入っていることを確認します。その後「現在」のボタンをクリックします。

3. 現在の時刻が取得されたことを確認し、設定は完了です。次回レプリケーション再開時にリフレッシュが実行されます。

■バージョン8.2以降の場合
1. レプリケーション名（あるいはグループ名）を右クリックすると「初期リフレッシュを実行」という項目があります。クリックします。

2.クリックすると、次のような確認のためのアラートが出力されます。「はい」をクリックしますと、直ちにリフレッシュが開始されます。

※リフレッシュを行った際には、リフレッシュ開始前にミラーリング用のトランザクションIDを自動で再取得しますので、「初期リフレッシュ＋ミラーリング」のレプリケーションの場合は、ミラーリングのトランザクションID再設定作業は不要です。

●差分ミラーリングの再設定

ミラーリングはDBのトランザクションログに保存されているトランザクションIDで管理されています。
何らかの理由で古いIDからのミラーリングを再度行われる場合には、IDを戻すことで実現可能となります。

1.  レプリケーション名を右クリック「プロパティ」を開きます。
※グループ化されている場合はグループ名を右クリック「レプリケーションを編集」です。

2.  左ペインから「優先」を選択し、「トランザクションID」の項目を確認します。これが今現在レプリケーションが完了済みのトランザクションIDとなります。このIDを直接任意の古いIDに変更することももちろん可能です。
任意のタイムスタンプの位置のIDを取得するためには、トランザクションIDの右側のボタンをクリックします。

3. 「日付または時刻」にチェックを入れ、戻したいIDの位置のタイムスタンプを設定します。

4. 元の画面に戻り、トランザクションIDが指定のタイムスタンプの位置のものに戻っていることを確認します。設定はこれで完了です。次回レプリケーション再開時にこのトランザクションIDからミラーリングが再開されます。