Skip to content

Commit

Permalink
0004840: Sybase ASE primary key update should create update event when
Browse files Browse the repository at this point in the history 
only one record is updated
  • Loading branch information
Philip Marzullo committed Feb 18, 2021
1 parent b460841 commit dab2c2f
Showing 1 changed file with 29 additions and 6 deletions.
35 changes: 29 additions & 6 deletions symmetric-client/src/main/java/org/jumpmind/symmetric/db/ase/AseTriggerTemplate.java
View file
Expand Up @@ -102,6 +102,8 @@ public AseTriggerTemplate(ISymmetricDialect symmetricDialect) {
sqlTemplates.put("updateTriggerTemplate" ,
"create trigger $(triggerName) on $(schemaName)$(tableName) for update " + getOrderClause() + " as\n" +
" begin \n" +
" declare @LOCALROWCOUNT int \n" +
" set @LOCALROWCOUNT=@@ROWCOUNT \n" +
" set nocount on \n" +
" declare @DataRow varchar(16384) \n" +
" declare @OldPk varchar(2000) \n" +
Expand All @@ -121,7 +123,27 @@ public AseTriggerTemplate(ISymmetricDialect symmetricDialect) {
" if ($(syncOnIncomingBatchCondition)) begin \n" +
" if ($(hasPrimaryKeysDefined) $(primaryKeysUpdated) ) \n" +
" begin \n" +
" declare DeleteDataCursor cursor for \n" +
" if (@LOCALROWCOUNT = 1) \n" +
" begin \n" +
" declare DataCursor cursor for \n" +
" $(if:containsBlobClobColumns) \n" +
" select $(columns), $(oldKeys), $(oldColumns) $(oldKeyNames) $(newKeyNames), $(channelExpression) from inserted inner join $(schemaName)$(tableName) $(origTableAlias) on $(tableNewPrimaryKeyJoin) inner join deleted on 1=1 where $(syncOnUpdateCondition)\n" +
" $(else:containsBlobClobColumns) \n" +
" select $(columns), $(oldKeys), $(oldColumns) $(oldKeyNames) $(newKeyNames), $(channelExpression) from inserted inner join deleted on 1=1 where $(syncOnUpdateCondition) \n" +
" $(end:containsBlobClobColumns) \n" +
" open DataCursor \n" +
" fetch DataCursor into @DataRow, @OldPk, @OldDataRow $(oldKeyVariables) $(newKeyVariables), @ChannelId \n" +
" while @@sqlstatus = 0 begin \n" +
" 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) \n" +
" values('$(targetTableName)','U', $(triggerHistoryId), @DataRow, @OldPk, @OldDataRow, @ChannelId, @txid, @clientname, $(externalSelect), getdate())\n" +
" fetch DataCursor into @DataRow, @OldPk, @OldDataRow $(oldKeyVariables) $(newKeyVariables), @ChannelId \n" +
" end \n" +
" close DataCursor \n" +
" deallocate cursor DataCursor \n" +
" end \n" +
" else \n" +
" begin \n" +
" declare DeleteDataCursor cursor for \n" +
" select $(oldKeys), $(oldColumns) $(oldKeyNames), $(specialSqlServerSybaseChannelExpression) from deleted where $(syncOnDeleteCondition) \n" +
" open DeleteDataCursor \n" +
" fetch DeleteDataCursor into @OldPk, @OldDataRow $(oldKeyVariables), @ChannelId \n" +
Expand All @@ -132,12 +154,12 @@ public AseTriggerTemplate(ISymmetricDialect symmetricDialect) {
" end \n" +
" close DeleteDataCursor \n" +
" deallocate cursor DeleteDataCursor \n" +
" declare InsertDataCursor cursor for \n" +
" $(if:containsBlobClobColumns) \n" +
" declare InsertDataCursor cursor for \n" +
" $(if:containsBlobClobColumns) \n" +
" select $(columns) $(newKeyNames), $(channelExpression) from inserted inner join $(schemaName)$(tableName) $(origTableAlias) on $(tableNewPrimaryKeyJoin) where $(syncOnInsertCondition)\n" +
" $(else:containsBlobClobColumns) \n" +
" $(else:containsBlobClobColumns) \n" +
" select $(columns) $(newKeyNames), $(channelExpression) from inserted where $(syncOnInsertCondition) \n" +
" $(end:containsBlobClobColumns) \n" +
" $(end:containsBlobClobColumns) \n" +
" open InsertDataCursor \n" +
" fetch InsertDataCursor into @DataRow $(newKeyVariables), @ChannelId \n" +
" while @@sqlstatus = 0 begin \n" +
Expand All @@ -147,7 +169,8 @@ public AseTriggerTemplate(ISymmetricDialect symmetricDialect) {
" end \n" +
" close InsertDataCursor \n" +
" deallocate cursor InsertDataCursor \n" +
" end \n" +
" end \n" +
" end \n" +
" else \n" +
" begin \n" +
" declare DataCursor cursor for \n" +
Expand Down

0 comments on commit dab2c2f

Please sign in to comment.