gbacache.server.designer.cs

microsoft synchronization sample for Oracle(Server side)

//------------------------------------------------------------------------------
// <auto-generated>
//     此代码由工具生成。
//     运行库版本:2.0.50727.1433
//
//     对此文件的更改可能会导致不正确的行为，并且如果
//     重新生成代码，这些更改将会丢失。
// </auto-generated>
//------------------------------------------------------------------------------

using System.Data.OracleClient;
using System.Data;
using Microsoft.Synchronization.Data;
using System;
using System.IO;
namespace GBAServerSyncProvider {


    public partial class T_PRODUCTSyncAdapter : Microsoft.Synchronization.Data.Server.SyncAdapter
    {

        partial void OnInitialized();

        public T_PRODUCTSyncAdapter()
        {
            this.InitializeCommands();
            this.InitializeAdapterProperties();
            this.OnInitialized();
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeCommands()
        {
            // T_PRODUCTSyncTableSelectIncrementalInsertsCommand command.
            OracleCommand IncrementalInsertsCommand = new OracleCommand();
            this.SelectIncrementalInsertsCommand = IncrementalInsertsCommand;
            IncrementalInsertsCommand.CommandText = "SELECT *  FROM T_PRODUCT WHERE (CREATE_TIME > :sync_last_received_anchor AND CREATE_TIME <= :sync_new_received_anchor)";
            IncrementalInsertsCommand.CommandType = System.Data.CommandType.Text;
            IncrementalInsertsCommand.Parameters.Add(":sync_last_received_anchor", OracleType.DateTime);
            IncrementalInsertsCommand.Parameters.Add(":sync_new_received_anchor", OracleType.DateTime);

            // T_PRODUCTSyncTableSelectIncrementalDeletesCommand command.
            this.SelectIncrementalDeletesCommand = new System.Data.OracleClient.OracleCommand();
            this.SelectIncrementalDeletesCommand.CommandText = "SELECT ID, \"DeletionDate\" FROM \"T_PRODUCT_Tombstone\" WHERE (:sync_initi" +
                "alized = 1 AND \"DeletionDate\" > :sync_last_received_anchor AND \"DeletionDate\" <=" +
                " :sync_new_received_anchor)";
            this.SelectIncrementalDeletesCommand.CommandType = System.Data.CommandType.Text;
            this.SelectIncrementalDeletesCommand.Parameters.Add(new OracleParameter(":sync_initialized", OracleType.Int16));
            this.SelectIncrementalDeletesCommand.Parameters.Add(new OracleParameter(":sync_last_received_anchor", OracleType.DateTime));
            this.SelectIncrementalDeletesCommand.Parameters.Add(new OracleParameter(":sync_new_received_anchor", OracleType.DateTime));

            // T_PRODUCTSyncTableSelectIncrementalUpdatesCommand command.
            OracleCommand IncrementalUpdatesCommand = new OracleCommand();
            this.SelectIncrementalUpdatesCommand = IncrementalUpdatesCommand;
            IncrementalUpdatesCommand.CommandText = "SELECT * FROM T_PRODUCT WHERE (UPDATE_TIME > :sync_last_received_anchor AND UPDATE_TIME <= :sync_new_received_anchor AND CREATE_TIME <= :sync_last_received_anchor)";
            IncrementalUpdatesCommand.CommandType = System.Data.CommandType.Text;
            IncrementalUpdatesCommand.Parameters.Add(":sync_last_received_anchor", OracleType.DateTime);
            IncrementalUpdatesCommand.Parameters.Add(":sync_new_received_anchor", OracleType.DateTime);


        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeAdapterProperties()
        {
            this.TableName = "T_PRODUCT";
        }
    }

    public partial class T_PRODUCT_DYNASyncAdapter : Microsoft.Synchronization.Data.Server.SyncAdapter
    {

        partial void OnInitialized();

        public T_PRODUCT_DYNASyncAdapter()
        {
            this.InitializeCommands();
            this.InitializeAdapterProperties();
            this.OnInitialized();
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeCommands()
        {
            // T_PRODUCTSyncTableSelectIncrementalInsertsCommand command.
            OracleCommand IncrementalInsertsCommand = new OracleCommand();
            this.SelectIncrementalInsertsCommand = IncrementalInsertsCommand;
            IncrementalInsertsCommand.CommandText = "SELECT *  FROM T_PRODUCT_DYNA WHERE (CREATE_TIME > :sync_last_received_anchor AND CREATE_TIME <= :sync_new_received_anchor)";
            IncrementalInsertsCommand.CommandType = System.Data.CommandType.Text;
            IncrementalInsertsCommand.Parameters.Add(":sync_last_received_anchor", OracleType.DateTime);
            IncrementalInsertsCommand.Parameters.Add(":sync_new_received_anchor", OracleType.DateTime);

            // T_PRODUCTSyncTableSelectIncrementalDeletesCommand command.
            this.SelectIncrementalDeletesCommand = new System.Data.OracleClient.OracleCommand();
            this.SelectIncrementalDeletesCommand.CommandText = "SELECT ID, \"DeletionDate\" FROM \"T_PRODUCT_DYNA_Tombstone\" WHERE (:sync_initi" +
                "alized = 1 AND \"DeletionDate\" > :sync_last_received_anchor AND \"DeletionDate\" <=" +
                " :sync_new_received_anchor)";
            this.SelectIncrementalDeletesCommand.CommandType = System.Data.CommandType.Text;
            this.SelectIncrementalDeletesCommand.Parameters.Add(new OracleParameter(":sync_initialized", OracleType.Int16));
            this.SelectIncrementalDeletesCommand.Parameters.Add(new OracleParameter(":sync_last_received_anchor", OracleType.DateTime));
            this.SelectIncrementalDeletesCommand.Parameters.Add(new OracleParameter(":sync_new_received_anchor", OracleType.DateTime));

            // T_PRODUCTSyncTableSelectIncrementalUpdatesCommand command.
            OracleCommand IncrementalUpdatesCommand = new OracleCommand();
            this.SelectIncrementalUpdatesCommand = IncrementalUpdatesCommand;
            IncrementalUpdatesCommand.CommandText = "SELECT * FROM T_PRODUCT_DYNA WHERE (UPDATE_TIME > :sync_last_received_anchor AND UPDATE_TIME <= :sync_new_received_anchor AND CREATE_TIME <= :sync_last_received_anchor)";
            IncrementalUpdatesCommand.CommandType = System.Data.CommandType.Text;
            IncrementalUpdatesCommand.Parameters.Add(":sync_last_received_anchor", OracleType.DateTime);
            IncrementalUpdatesCommand.Parameters.Add(":sync_new_received_anchor", OracleType.DateTime);


        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeAdapterProperties()
        {
            this.TableName = "T_PRODUCT_DYNA";
        }
    }

    public partial class T_CUSTOMERSyncAdapter : Microsoft.Synchronization.Data.Server.SyncAdapter
    {

        partial void OnInitialized();

        public T_CUSTOMERSyncAdapter()
        {
                this.InitializeCommands();
            this.InitializeAdapterProperties();
            this.OnInitialized();
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeCommands()
        {
            // T_CUSTOMERSyncTableSelectIncrementalInsertsCommand command.
            this.SelectIncrementalInsertsCommand = new System.Data.OracleClient.OracleCommand();
            this.SelectIncrementalInsertsCommand.CommandText = "SELECT * FROM T_CUSTOMER WHERE SR_CODE=:SRCode AND (CREATE_TIME > :sync_last_received_anchor AND CREATE_TIME <= :sync_new_received_anchor)";
            this.SelectIncrementalInsertsCommand.CommandType = System.Data.CommandType.Text;
            this.SelectIncrementalInsertsCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_last_received_anchor", System.Data.OracleClient.OracleType.DateTime));
            this.SelectIncrementalInsertsCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_new_received_anchor", System.Data.OracleClient.OracleType.DateTime));
            this.SelectIncrementalInsertsCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":SRCode", OracleType.NVarChar));

            // T_CUSTOMERSyncTableSelectIncrementalDeletesCommand command.
            this.SelectIncrementalDeletesCommand = new System.Data.OracleClient.OracleCommand();
            this.SelectIncrementalDeletesCommand.CommandText = "SELECT CUST_ID, \"DeletionDate\" FROM \"T_CUSTOMER_Tombstone\" WHERE (:sync_initial" +
                "ized = 1 AND \"DeletionDate\" > :sync_last_received_anchor AND \"DeletionDate\" <= :" +
                "sync_new_received_anchor)";
            this.SelectIncrementalDeletesCommand.CommandType = System.Data.CommandType.Text;
            this.SelectIncrementalDeletesCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_initialized",System.Data.DbType.Boolean));
            this.SelectIncrementalDeletesCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_last_received_anchor", System.Data.OracleClient.OracleType.DateTime));
            this.SelectIncrementalDeletesCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_new_received_anchor", System.Data.OracleClient.OracleType.DateTime));
            
            // T_CUSTOMERSyncTableSelectIncrementalUpdatesCommand command.
            this.SelectIncrementalUpdatesCommand = new System.Data.OracleClient.OracleCommand();
            this.SelectIncrementalUpdatesCommand.CommandText = "SELECT * FROM T_CUSTOMER WHERE SR_CODE=:SRCode AND (UPDATE_TIME > :sync_last_received_anchor AND UPDATE_TIME <= :sync_new_received_anchor AND CREATE_TIME <= :sync_last_received_anchor)";
            this.SelectIncrementalUpdatesCommand.CommandType = System.Data.CommandType.Text;
            this.SelectIncrementalUpdatesCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_last_received_anchor", System.Data.OracleClient.OracleType.DateTime));
            this.SelectIncrementalUpdatesCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":sync_new_received_anchor", System.Data.OracleClient.OracleType.DateTime));
            this.SelectIncrementalUpdatesCommand.Parameters.Add(new System.Data.OracleClient.OracleParameter(":SRCode", OracleType.NVarChar));
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeAdapterProperties()
        {
            this.TableName = "T_CUSTOMER";
        }
    }
    
    public partial class GBACacheServerSyncProvider : Microsoft.Synchronization.Data.Server.DbServerSyncProvider {

        //private string T_PRODUCT_SyncBlock_BASE = "T_PRODUCT_SyncBlock_BASE";       //For synchronizing base information of T_PRODUCT table, such as ID,NAME,PHOHO.
       // private string T_PRODUCT_SyncBlock_DYNAMIC = "T_PRODUCT_SyncBlock_DYNAMIC"; //For synchronizing dynamic information, such as price.

        private T_PRODUCTSyncAdapter _t_PRODUCTSyncAdapter;

        private T_CUSTOMERSyncAdapter _t_CUSTOMERSyncAdapter;

        private T_PRODUCT_DYNASyncAdapter _t_PRODUCT_DYNASyncAdapter;



        //private  SyncSchema syncSchemaBaseInfo;

        //private SyncSchema syncSchemaDynamicInfo;

        //private StreamWriter logFile;
        
        partial void OnInitialized();
        
        public GBACacheServerSyncProvider() {