Skip to content

Commit

Permalink
fix sybase issue
Browse files Browse the repository at this point in the history
  • Loading branch information
@chenson42
chenson42 committed Nov 9, 2011
1 parent e595f90 commit 109523f
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions symmetric/symmetric-core/src/main/resources/org/jumpmind/symmetric/db/sybase.xml
View file
Expand Up @@ -132,11 +132,11 @@
select $(columns), $(newKeyNames) from inserted where $(syncOnInsertCondition)
$(end:containsBlobClobColumns)
open DataCursor
fetch next from DataCursor into @DataRow, $(newKeyVariables)
fetch next from DataCursor into @DataRow $(newKeyVariables)
while @@FETCH_STATUS = 0 begin
insert into $(defaultCatalog)$(defaultSchema)$(prefixName)_data (table_name, event_type, trigger_hist_id, row_data, channel_id, transaction_id, source_node_id, external_data, create_time)
values('$(targetTableName)','I', $(triggerHistoryId), @DataRow, '$(channelName)', $(txIdExpression), $(defaultCatalog)dbo.$[sym.sync.table.prefix]_node_disabled(0), $(externalSelect), getdate())
fetch next from DataCursor into @DataRow, $(newKeyVariables)
fetch next from DataCursor into @DataRow $(newKeyVariables)
end
close DataCursor
deallocate DataCursor
Expand All @@ -158,16 +158,16 @@
if ($(syncOnIncomingBatchCondition)) begin
declare DataCursor cursor for
$(if:containsBlobClobColumns)
select $(columns), $(oldKeys), $(oldColumns), $(oldKeyNames), $(newKeyNames) from inserted inner join $(schemaName)$(tableName) $(origTableAlias) on $(tableNewPrimaryKeyJoin) inner join deleted on $(oldNewPrimaryKeyJoin) where $(syncOnUpdateCondition)
select $(columns), $(oldKeys), $(oldColumns) $(oldKeyNames) $(newKeyNames) from inserted inner join $(schemaName)$(tableName) $(origTableAlias) on $(tableNewPrimaryKeyJoin) inner join deleted on $(oldNewPrimaryKeyJoin) where $(syncOnUpdateCondition)
$(else:containsBlobClobColumns)
select $(columns), $(oldKeys), $(oldColumns), $(oldKeyNames), $(newKeyNames) from inserted inner join deleted on $(oldNewPrimaryKeyJoin) where $(syncOnUpdateCondition)
select $(columns), $(oldKeys), $(oldColumns) $(oldKeyNames) $(newKeyNames) from inserted inner join deleted on $(oldNewPrimaryKeyJoin) where $(syncOnUpdateCondition)
$(end:containsBlobClobColumns)
open DataCursor
fetch next from DataCursor into @DataRow, @OldPk, @OldDataRow, $(oldKeyVariables), $(newKeyVariables)
fetch next from DataCursor into @DataRow, @OldPk, @OldDataRow $(oldKeyVariables) $(newKeyVariables)
while @@FETCH_STATUS = 0 begin
insert into $(defaultCatalog)$(defaultSchema)$(prefixName)_data (table_name, event_type, trigger_hist_id, row_data, pk_data, old_data, channel_id, transaction_id, source_node_id, external_data, create_time)
values('$(targetTableName)','U', $(triggerHistoryId), @DataRow, @OldPk, @OldDataRow, '$(channelName)', $(txIdExpression), $(defaultCatalog)dbo.$[sym.sync.table.prefix]_node_disabled(0), $(externalSelect), getdate())
fetch next from DataCursor into @DataRow, @OldPk, @OldDataRow, $(oldKeyVariables), $(newKeyVariables)
fetch next from DataCursor into @DataRow, @OldPk, @OldDataRow $(oldKeyVariables) $(newKeyVariables)
end
close DataCursor
deallocate DataCursor
Expand All @@ -186,13 +186,13 @@
$(declareOldKeyVariables)
if ($(syncOnIncomingBatchCondition)) begin
declare DataCursor cursor for
select $(oldKeys), $(oldColumns), $(oldKeyNames) from deleted where $(syncOnDeleteCondition)
select $(oldKeys), $(oldColumns) $(oldKeyNames) from deleted where $(syncOnDeleteCondition)
open DataCursor
fetch next from DataCursor into @OldPk, @OldDataRow, $(oldKeyVariables)
fetch next from DataCursor into @OldPk, @OldDataRow $(oldKeyVariables)
while @@FETCH_STATUS = 0 begin
insert into $(defaultCatalog)$(defaultSchema)$(prefixName)_data (table_name, event_type, trigger_hist_id, pk_data, old_data, channel_id, transaction_id, source_node_id, external_data, create_time)
values('$(targetTableName)','D', $(triggerHistoryId), @OldPk, @OldDataRow, '$(channelName)', $(txIdExpression), $(defaultCatalog)dbo.$[sym.sync.table.prefix]_node_disabled(0), $(externalSelect), getdate())
fetch next from DataCursor into @OldPk,@OldDataRow, $(oldKeyVariables)
fetch next from DataCursor into @OldPk,@OldDataRow $(oldKeyVariables)
end
close DataCursor
deallocate DataCursor
Expand Down

0 comments on commit 109523f

Please sign in to comment.