Salesforce の取引先データを Dynamics CRM に同期するサンプルアプリケーションの開発手順を見ていきます。
ソースコード
このサンプルアプリケーションのソースコードはこちらからどうぞ。
CData製品のインストール
まずは CData Software をインストールします。今回必要になるのは、次の2つです。
プロジェクト作成
Visual Studio を起動し、新しいWindowsフォームアプリケーションのプロジェクトを作成します。
参照設定
インストールした CData Software の2製品には、いくつかのADO.NETアセンブリが含まれています。
今回必要になるのは次の2つのDLLですので、これらをプロジェクトの参照設定で追加します。
- System.Data.CData.Salesforce.dll
- System.Data.CData.DynamicsCRM.dll
クラス構造
このサンプルアプリケーションに登場するクラスの構造は下図の通りです。
コーディング
まずは、CData が提供するクラス群を生成するファクトリクラスを設けます。
abstract class CDataFactory
{
public abstract IDbConnection CreateConnection(string connectionString);
public abstract IDbCommand CreateCommand(string commandText, IDbConnection conn);
public abstract DbDataAdapter CreateDataAdapter(IDbCommand command);
public abstract DbCommandBuilder CreateCommandBuilder(DbDataAdapter adapter);
上記をベースとして、Salesforce 用と DynamicsCRM 用の2つを設けます。
private class CDataFactorySalesforce : CDataFactory
{
public override IDbConnection CreateConnection(string connectionString)
{
return new SalesforceConnection(connectionString);
}
public override IDbCommand CreateCommand(string commandText, IDbConnection conn)
{
return new SalesforceCommand(commandText, (SalesforceConnection)conn);
}
public override DbDataAdapter CreateDataAdapter(IDbCommand command)
{
return new SalesforceDataAdapter((SalesforceCommand)command);
}
public override DbCommandBuilder CreateCommandBuilder(DbDataAdapter adapter)
{
return new SalesforceCommandBuilder((SalesforceDataAdapter)adapter);
}
}
private class CDataFactoryDynamicsCRM : CDataFactory
{
public override IDbConnection CreateConnection(string connectionString)
{
return new DynamicsCRMConnection(connectionString);
}
public override IDbCommand CreateCommand(string commandText, IDbConnection conn)
{
return new DynamicsCRMCommand(commandText, (DynamicsCRMConnection)conn);
}
public override DbDataAdapter CreateDataAdapter(IDbCommand command)
{
return new DynamicsCRMDataAdapter((DynamicsCRMCommand)command);
}
public override DbCommandBuilder CreateCommandBuilder(DbDataAdapter adapter)
{
return new DynamicsCRMCommandBuilder((DynamicsCRMDataAdapter)adapter);
}
}
次に、ADO.NET へのアクセス部分をラップするクラスを設けます。
このクラスは、上で作成したファクトリクラスおよび ADO.NET のクラス/インターフェイスを使用することにより、
接続先が Salesforce であるか Dynamics CRM であるかを意識することなく、それぞれのシステムへの接続、および DataTable の生成処理と更新処理を行います。
class DbWrapper : IDisposable
{
private CDataFactory factory;
private IDbConnection conn = null;
public DbWrapper(CDataFactory factory, string connectionString)
{
this.factory = factory;
this.conn = factory.CreateConnection(connectionString);
}
public void Dispose()
{
this.conn.Dispose();
}
public DataTable CreateDataTable(string tableName)
{
using (var command = this.factory.CreateCommand("SELECT * FROM " + tableName, conn))
using (var adaptor = this.factory.CreateDataAdapter(command))
{
var table = new DataTable(tableName);
adaptor.Fill(table);
return table;
}
}
public void Update(DataTable table)
{
using (var command = this.factory.CreateCommand("SELECT * FROM " + table.TableName, conn))
using (var adaptor = this.factory.CreateDataAdapter(command))
using (var commandBuilder = this.factory.CreateCommandBuilder(adaptor))
{
adaptor.InsertCommand = commandBuilder.GetInsertCommand();
adaptor.UpdateCommand = commandBuilder.GetUpdateCommand();
adaptor.Update(table);
}
}
}
当然のことながら、Salesforce の取引先オブジェクトと Dynamics CRM の取引先企業エンティティでは、データ項目が異なります。
そこで、そのマッピングを行うクラスを設けます。
Salesforce のデータも Dynamics CRM のデータもデータベースのテーブルデータとして扱えるので、
このクラスが行うことは、Salesforce 側の項目名を Dynamics CRM 側の項目名に翻訳して、項目の値をセットするだけです。
class AccountMapper : ColumnMapper
{
private static Dictionary<string, string> NameMapping = new Dictionary<string, string>()
{
{ "AccountNumber", "AccountNumber" },
{ "AnnualRevenue", "Revenue" },
// ...省略...
};
public override void Map(DataRow source, DataRow destination)
{
foreach (var entry in NameMapping)
{
destination[entry.Value] = source[entry.Key];
}
}
}
上記のクラスのオブジェクトを "Account" などの文字列から取得できるようにするためのクラスも設けておきます。
static class ColumnMapperRegistry
{
private static Dictionary<string, ColumnMapper> columnMapperMap = new Dictionary<string, ColumnMapper>();
static ColumnMapperRegistry()
{
columnMapperMap["Account"] = new AccountMapper();
}
public static ColumnMapper GetMapper(string name)
{
return columnMapperMap[name];
}
}
ここまでで、Salesforce および Dynamics CRM にアクセスする部分が出来ました。次に、フォームにとりかかります。
取引先データの読み込みやインポートには時間がかかるかもしれないので、処理状況をメッセージ表示するフォームを追加します。
このフォームは、時間のかかる処理の実行中に自分自身を表示して、状況をメッセージ表示したり、処理が完了したら閉じられるようにします。
次にメインのフォームを追加します。
このフォームには、次のコンポーネントを追加します。
- インポート対象を選択するためのコンボボックス
- データ読み込みを行うボタン
- データを表示するためのデータグリッドビュー×2 (左がSalesforce、右がDynamicsCRM と対応する)
- インポートを実行するボタン
インポート対象の種類を選ぶコンボボックスは、今回は単に "Account" という文字列を選択できるものにします。
private void MainForm_Load(object sender, EventArgs e)
{
this.cbObject.DataSource = new string[] { "", "Account" };
}
データ読み込みの処理では、先に作成した DbWrapper を使用して DataTable を生成し、
それをデータグリッドビューにバインドします。
アプリケーションの設定に記載された Salesforce および Dynamics CRM の接続情報を使用して、それぞれのシステムへ接続します。
using (var salesforce = new DbWrapper(CDataFactory.Salesforce, Properties.Settings.Default.SalesforceConnectionString))
using (var dynamicsCRM = new DbWrapper(CDataFactory.DynamicsCRM, Properties.Settings.Default.DynamicsCRMConnectionString))
{
DataTable を生成します。
var salesforceDataTable = salesforce.CreateDataTable(tableName);
var dynamicsCRMDataTable = dynamicsCRM.CreateDataTable(tableName);
生成した DataTable をデータグリッドビューへバインドします。
this.dgvSource.DataSource = salesforceDataTable;
this.dgvDestination.DataSource = dynamicsCRMDataTable;
これで、2つのデータグリッドビューに Salesforce および Dynamics CRM それぞれの取引先データが表示されるはずです。
最後に、インポート処理を記述します。
選択されている行を取得して、それを DataRow のリストに変換します。
var importTargetRows = this.dgvSource.Rows.Cast<DataGridViewRow>()
.Where(o => o.Selected)
.Select(o => ((DataRowView)o.DataBoundItem).Row)
.Where(o => !string.IsNullOrWhiteSpace(o["AccountNumber"].ToString()))
.ToList();
ここではLINQを使用して、
- 行選択されているもののみ抽出
.Where(o => o.Selected) - DataRowView に変換
.Select(o => (DataRowView)o.DataBoundItem) - 取引先番号(AccountNumber)が設定されているもののみ抽出
.Where(o => !string.IsNullOrWhiteSpace(o["AccountNumber"].ToString()))
ということを行っています。
同じように、インポート先のデータも DataRowView として取得しますが、取引先番号で引けるように、Dictionaryに変換します。
var destinationRowMap = this.dgvDestination.Rows.Cast<DataGridViewRow>()
.Select(o => ((DataRowView)o.DataBoundItem).Row)
.Where(o => !string.IsNullOrWhiteSpace(o["AccountNumber"].ToString()))
.ToDictionary(o => o["AccountNumber"].ToString(), o => o); // AccountNumberをキー、DataRowViewを値とするDictionaryに変換
選択されている行の DataRow をループして、Salesforce 側の取引先番号と対応する DataRow が Dynamics CRM 側にあればそれを取得し、なければ新しい DataRow を生成します。
そして上で作成した AccountMapper を使用して、Salesforce 側のデータを Dynamics CRM 側にセットします。
foreach (var importTargetRow in importTargetRows)
{
DataRow dataRow = null;
if (destinationRowMap.ContainsKey(importTargetRow["AccountNumber"].ToString()))
{
dataRow = destinationRowMap[importTargetRow["AccountNumber"].ToString()];
importUpdate++;
}
else
{
dataRow = ((DataTable)this.dgvDestination.DataSource).NewRow();
((DataTable)this.dgvDestination.DataSource).Rows.Add(dataRow);
importNew++;
}
ColumnMapperRegistry.GetMapper(tableName).Map(importTargetRow, dataRow);
}
仕上げに、Dynamics CRM 側の DataTable を Update します。
これにより、DataRow に加えられた変更から、それに対応する UPDATE/INSERT 文が生成され、Dynamics CRM へのデータ更新が実行されます。
using (var dynamicsCRM = new CDataWrapper(CDataFactory.DynamicsCRM, Properties.Settings.Default.DynamicsCRMConnectionString))
{
dynamicsCRM.Update((DataTable)this.dgvDestination.DataSource);
実行
接続情報の設定
接続情報をアプリケーションの設定に記述します。
プロジェクトを右クリック → プロパティ からプロジェクトのプロパティを開き、「設定」で
"SalesforceConnectionString" と "DynamicsCRMConnectionString" の2つを追加します。
Salesforce の接続文字列は、以下の形式になります。
User=<ユーザ名>;Password=<パスワード>;Security Token=<セキュリティトークン>;
Dynamics CRM の接続文字列は、以下の形式になります。
User=<アカウント名>;Password=<パスワード>;URL=<サーバー組織ルート>;CRM Version=CRM Online;
データ読み込み＆同期
左上のコンボボックスで「Account」を選び、選択ボタンをクリックすると、Salesforce および Dynamics CRM のデータが
それぞれに対応するデータグリッドビューに読み込まれます。
データが読み込まれた状態で、左側のデータグリッドビューでインポートしたいデータを選択し、インポートボタンをクリックすると、選択したデータが Dynamics CRM に反映されます。