|
t .shipping_address_street, t.shipping_address_city ,t. shipping_address_state,t .shipping_address_postalcode, t.shipping_address_country ,t. parent_id,t .sic_code, t.campaign_id from #temp2 t
--inner join ( select id from account) a on a.id !=t.id
if not exists (SELECT * FROM account a,#temp1 b WHERE a .ID = b .ID) and not exists (SELECT * FROM account a, #temp1 b WHERE a.ID != b.ID )
insert into account ( id ,name, date_entered,date_modified ,modified_user_id, created_by,[description] ,deleted, assigned_user_id,account_type ,industry, annual_revenue,phone_fax ,billing_address_street, billing_address_city,billing_address_state ,billing_address_postalcode, billing_address_country,rating ,phone_office, phone_alternate,website ,[ownership], employees,ticker_symbol ,shipping_address_street, shipping_address_city,shipping_address_state ,shipping_address_postalcode, shipping_address_country,parent_id ,sic_code, campaign_id)
select t .id ,t. name,t .date_entered, t.date_modified ,t. modified_user_id,t .created_by, t.[description] ,t. deleted,t .assigned_user_id, t.account_type ,t. industry,t .annual_revenue, t.phone_fax ,t. billing_address_street,t .billing_address_city, t.billing_address_state ,t. billing_address_postalcode,t .billing_address_country, t.rating ,phone_office, t.phone_alternate ,t. website,t .[ownership], t.employees ,t. ticker_symbol,t .shipping_address_street, t.shipping_address_city ,t. shipping_address_state,t .shipping_address_postalcode, t.shipping_address_country ,t. parent_id,t .sic_code, t.campaign_id from #temp1 t
update openquery (MySql, 'select * from sugarcrm642cebackup.accountsbackup where ISNULL(ExecutingState) and BehaviorType=''U''') set ExecutingState='D' ,ModificationTime= getdate()
End
--delete from sql_tem
--delete openquery(MySql, 'SELECT * FROM sugarcrmtablebackup')
最后再开启sql server代理，因为本身这个需要计划任务每秒去monitor这个mysql变化，因为sql server这边只能设置10秒更新一次，那这边就只能如此，如果要看是否成功，可以右击该计划任务查看历史记录。
|