gbacache.server.designer.cs

microsoft synchronization sample for Oracle(Server side)

            //initLogFile();
            string connectionString = global::GBAServerSyncProvider.Properties.Settings.Default.ServerGBAppraiseDemoConnectionString;
            this.InitializeConnection(connectionString);
            this.InitializeSchema();
            this.InitializeSyncAdapters();
            this.InitializeNewAnchorCommand();
            this.OnInitialized();

            
        }
        
        public GBACacheServerSyncProvider(string connectionString) {
            this.InitializeConnection(connectionString);
            this.InitializeSyncAdapters();
            this.InitializeNewAnchorCommand();
            this.OnInitialized();
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        public T_PRODUCTSyncAdapter T_PRODUCTSyncAdapter
        {
            get
            {
                return this._t_PRODUCTSyncAdapter;
            }
            set
            {
                this._t_PRODUCTSyncAdapter = value;
            }
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        public T_CUSTOMERSyncAdapter T_CUSTOMERSyncAdapter
        {
            get
            {
                return this._t_CUSTOMERSyncAdapter;
            }
            set
            {
                this._t_CUSTOMERSyncAdapter = value;
            }
        }

        public T_PRODUCT_DYNASyncAdapter T_PRODUCT_DYNASyncAdapter
        {
            get { return _t_PRODUCT_DYNASyncAdapter; }
            set { _t_PRODUCT_DYNASyncAdapter = value; }
        }

        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeConnection(string connectionString) {
            //this.Connection = new System.Data.SqlClient.SqlConnection(connectionString);
            this.Connection = new System.Data.OracleClient.OracleConnection(connectionString);
        }
        
        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeSyncAdapters() {
            // Create SyncAdapters.
            this._t_PRODUCTSyncAdapter = new T_PRODUCTSyncAdapter();
            this.SyncAdapters.Add(this._t_PRODUCTSyncAdapter);
            this._t_CUSTOMERSyncAdapter = new T_CUSTOMERSyncAdapter();
            this.SyncAdapters.Add(this._t_CUSTOMERSyncAdapter);

            this._t_PRODUCT_DYNASyncAdapter = new T_PRODUCT_DYNASyncAdapter();
            this.SyncAdapters.Add(this._t_PRODUCT_DYNASyncAdapter);
        }
        
        [System.Diagnostics.DebuggerNonUserCodeAttribute()]
        private void InitializeNewAnchorCommand() {
            // selectNewAnchorCmd command.
            //this.SelectNewAnchorCommand = new System.Data.SqlClient.SqlCommand();
            //this.SelectNewAnchorCommand.CommandText = "Select @sync_new_received_anchor = GETUTCDATE()";
            //this.SelectNewAnchorCommand.CommandType = System.Data.CommandType.Text;
            //System.Data.SqlClient.SqlParameter selectnewanchorcommand_sync_new_received_anchorParameter = new System.Data.SqlClient.SqlParameter("@sync_new_received_anchor", System.Data.SqlDbType.DateTime);
            //selectnewanchorcommand_sync_new_received_anchorParameter.Direction = System.Data.ParameterDirection.Output;
            //this.SelectNewAnchorCommand.Parameters.Add(selectnewanchorcommand_sync_new_received_anchorParameter);

            this.SelectNewAnchorCommand = new System.Data.OracleClient.OracleCommand();
            this.SelectNewAnchorCommand.CommandText = " begin "
                +"select SYSDATE into :sync_new_received_anchor from dual; "
                +" end;";
            this.SelectNewAnchorCommand.CommandType = System.Data.CommandType.Text;
            OracleParameter selectnewanchorcommand_sync_new_received_anchorParameter = new OracleParameter(":sync_new_received_anchor", OracleType.DateTime);
            selectnewanchorcommand_sync_new_received_anchorParameter.Direction = System.Data.ParameterDirection.Output;
            this.SelectNewAnchorCommand.Parameters.Add(selectnewanchorcommand_sync_new_received_anchorParameter);

        }

        //override public SyncSchema GetSchema(System.Collections.ObjectModel.Collection<string> tableNames, SyncSession syncSession)
        //{
        //    string T_PRODUCT_SyncBlock = Convert.ToString(syncSession.SyncParameters[":T_PRODUCT_SyncBlock"].Value);

        //    //log("...T_PRODUCT_SyncBlock=" + T_PRODUCT_SyncBlock);

        //    if (this.T_PRODUCT_SyncBlock_BASE.Equals(T_PRODUCT_SyncBlock))
        //        return this.syncSchemaBaseInfo;
        //    else if (this.T_PRODUCT_SyncBlock_DYNAMIC.Equals(T_PRODUCT_SyncBlock))
        //        return this.syncSchemaDynamicInfo;
        //    else
        //        return this.syncSchemaDynamicInfo;
        //}

        private void InitializeSchema()
        {
            //this.syncSchemaBaseInfo = new SyncSchema();
            //InitSchema_T_CUSTOMER(this.syncSchemaBaseInfo);
            //this.InitSyncSchema_T_PRODUCT_BaseInfo(this.syncSchemaBaseInfo);

            //this.syncSchemaDynamicInfo = new SyncSchema();
            //InitSchema_T_CUSTOMER(this.syncSchemaDynamicInfo);
            //InitSyncSchema_T_PRODUCT_DynamicInfo(this.syncSchemaDynamicInfo);

            SyncSchema syncSchema = new SyncSchema();
            this.Schema = syncSchema;
            InitSchema_T_CUSTOMER(syncSchema);
            InitSyncSchema_T_PRODUCT(syncSchema);
            InitSyncSchema_T_PRODUCT_Dyna(syncSchema);

        }

        private void InitSchema_T_CUSTOMER(SyncSchema syncSchema)
        {
            //CUST_ID, NAME, INITLETTER, OCCUPATION, BIRTHDATE, SEX, HOMEPHONE, OFFICE_PHONE, MOBILEPHONE_1, MOBILEPHONE_2, OFFICE_ADDRESS, EMAIL, INTEREST, IM_TOOL, PHOTO, PHOTO_PATH, TYPE, CREATE_TIME, UPDATE_TIME, CREATE_BY, UPDATE_BY, LastEditDate, CreationDate
            syncSchema.Tables.Add("T_CUSTOMER");
            syncSchema.Tables["T_CUSTOMER"].Columns.Add("CUST_ID");
            syncSchema.Tables["T_CUSTOMER"].Columns["CUST_ID"].ProviderDataType = "VARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["CUST_ID"].MaxLength = 50;
            syncSchema.Tables["T_CUSTOMER"].Columns["CUST_ID"].AllowNull = false;
            
            syncSchema.Tables["T_CUSTOMER"].Columns.Add("SR_CODE");
            syncSchema.Tables["T_CUSTOMER"].Columns["SR_CODE"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["SR_CODE"].MaxLength = 20;
            syncSchema.Tables["T_CUSTOMER"].Columns["CUST_ID"].AllowNull = false;

            syncSchema.Tables["T_CUSTOMER"].PrimaryKey = new string[] { "CUST_ID","SR_CODE" };

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("NAME");
            syncSchema.Tables["T_CUSTOMER"].Columns["NAME"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["NAME"].MaxLength = 50;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("INITLETTER");
            syncSchema.Tables["T_CUSTOMER"].Columns["INITLETTER"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["INITLETTER"].MaxLength = 30;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("OCCUPATION");
            syncSchema.Tables["T_CUSTOMER"].Columns["OCCUPATION"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["OCCUPATION"].MaxLength = 50;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("BIRTHDATE");
            syncSchema.Tables["T_CUSTOMER"].Columns["BIRTHDATE"].ProviderDataType = "DATETIME";
            //syncSchema.Tables["T_CUSTOMER"].Columns["BIRTHDATE"].MaxLength = 30;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("SEX");
            syncSchema.Tables["T_CUSTOMER"].Columns["SEX"].ProviderDataType = "smallint";
            //syncSchema.Tables["T_CUSTOMER"].Columns["SEX"].MaxLength = 30;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("HOMEPHONE");
            syncSchema.Tables["T_CUSTOMER"].Columns["HOMEPHONE"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["HOMEPHONE"].MaxLength = 50;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("OFFICE_PHONE");
            syncSchema.Tables["T_CUSTOMER"].Columns["OFFICE_PHONE"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["OFFICE_PHONE"].MaxLength = 50;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("MOBILEPHONE_1");
            syncSchema.Tables["T_CUSTOMER"].Columns["MOBILEPHONE_1"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["MOBILEPHONE_1"].MaxLength = 50;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("MOBILEPHONE_2");
            syncSchema.Tables["T_CUSTOMER"].Columns["MOBILEPHONE_2"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["MOBILEPHONE_2"].MaxLength = 50;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("OFFICE_ADDRESS");
            syncSchema.Tables["T_CUSTOMER"].Columns["OFFICE_ADDRESS"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["OFFICE_ADDRESS"].MaxLength = 100;

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("EMAIL");
            syncSchema.Tables["T_CUSTOMER"].Columns["EMAIL"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["EMAIL"].MaxLength = 50;


            syncSchema.Tables["T_CUSTOMER"].Columns.Add("CREATE_TIME");
            syncSchema.Tables["T_CUSTOMER"].Columns["CREATE_TIME"].ProviderDataType = "DATETIME";

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("UPDATE_TIME");
            syncSchema.Tables["T_CUSTOMER"].Columns["UPDATE_TIME"].ProviderDataType = "DATETIME";

            syncSchema.Tables["T_CUSTOMER"].Columns.Add("CREATE_BY");
            syncSchema.Tables["T_CUSTOMER"].Columns["CREATE_BY"].ProviderDataType = "NVARCHAR";
            syncSchema.Tables["T_CUSTOMER"].Columns["CREATE_BY"].MaxLength = 100;