c, N "0/.~~.2<<BRRRRRRRbbblv(}NA)@@bmn@r9log@x}Lmssqlsystemresource &d)1~a֦jG鴛LP֦jG鴛L߳"L@2 GJs9$@x}Lmssqlsystemresource &d)P"~a֦jG鴛LP֦jG鴛Lެ!L@2 GJs9$x}Lmssqlsystemresource &d)P"~a֦jG鴛LP֦jG鴛L߳"L@2 GJs9$x}Lmssqlsystemresource &d)1~a֦jG鴛LP֦jG鴛L߳"L@2 GJs9$2 GJs9$`@) P#KP0)A[ 0@@@@@@@@@@@@@@@@@@@@@@@@`({!L~(#5-=($@Q("R)@S) T) U) @V)  W) ^@X)  Y)  Z)  @[) \) @]) ^) _)@`)a)@b)c) d)@e) f)@g)h)i)@j)k)@l)m) n)@!o)"JII8HhGFED(DXCBA@@H?x>=<<8;h:987(7X65433H2x10H0(@HPP)8iV)|!L)(@@@@@@HPF)@h@~3|!L\FileSize>)@~(  aj@@)@~")@}!L(@@@@@@HPb)HKM0)@~}!L)@(@@@@@@HP" )P1Hg)5-=)Q)#@R)PS)P @T)P U)P V)@ W)P_X)P  @Y)P  Z)P  @[)P  \)P  ])P @^)P _)P@`)Pa)Pb)P@c)P d)P@e)P f)Pg)P@h)Pi)P@j)Pk)Pl)P@m)Pn)P@o)P `)ܵ!L~(XHx8h ( X  Hx8h(@HPP )`QV)P"ܵ!L)P"(@@@@@@HPf)h̷@~3߳"L@ALTER DATABASE OPTION STATE CHAN>)h~ c'J$@>)h~ c)hެ!L߳"L(@@@@@@HPr)p @)h~$ )h"L(LTER DATABASE OPTION STATE CHAN>)h~ c'J$@>)h~ c)hެ!L߳"L(@@@@@@HH@@@@@@Pb)xM0)h~"L)h("L(LTER DATABASE OPTION STATE CHAN>)h~ c'J$@>)h~ c)hެ!L߳"L(@@@@@@HH@@@@@@P#V)r@~3"L DROPOBJAABA)~  >)~6'" "${" " _Kn)~ ,)~ ;>)~< 4<B0 B8CREATE VIEW sys.sac_state AS@ SELECT component_name, convert(sysname, N'mssqlsystemresource') collate database_default AS database_name, schema_name collate database_default AS schema_name, object_name collate database_default AS object_name, state, type FROM sys.obd_state  < I6 <(h>)~  )" ).6.component_name ) >}6 @))k >)~D) 4)Q0-4Qcomponent_name ) 96 )) C >) ~y)$),6,database_name ) }-,+"6 ))  >) ~D)) )@O0-Odatabase_name ) z->)~h)$#)(6(schema_name ) x=6 )) >)~D )))K0-Kschema_name ) a>)~c@ p&)(6(object_name ) EϠB~6 ))>)~D )))K0-Kobject_name ) D>)~^v)$)6state ) )@~D )))?0-00?state ) Bd>)~)!()6type ) {36 ))>)~D )))=0-=type ) <戠L>)~@I"& " & sac_state " ۷6 ")K>)~aS"!N" & sac_state " /pH6 ")+>)~zy"&XF"  " Y@6 ")>)H~6'")"F0, V {L"L Fsac_state " _Kn6 ")  0)~ "L) X h H  H h8x X P () P,'0)_@~3>"L3*CreatProc transaction)~  >)~6'")!"F"0,V >"L>"L Fsac_state " _Kn6 ")" >)~I")" W & s@c_state " ۷ys6 ")K>)~aS")" e,& sac_state " /pHe,6 ")+>)~zy")"  " Y@ 6 ")@~3>"L4@SplitPage>) ~ <) cB-@@) ~<P) ~><V>)~><)Bc:< B8CREATE VIEW sys.sac_state AS SELECT component_name, convert(sysname, N'mssqlsystemresource') collate database_default AS database_n@me, schema_name collate database_default AS schema_name, object_name collate database_default AS object_name, state, type FROM sys.obd_state 0 8CREATE VIEW sys.server_event_session_actions AS SELECT event_session_id = v.objid, event_id = v.subobjid, name = convert(sysname, v.value) collate database_default, package = convert(sysname, p.name) collate database_default, module = convert(sysname, m.name) collate database_default FROM mas@er.sys.sysobjvalues v LEFT JOIN master.sys.sysqnames p ON p.nid = ((((substring( v.imageval, 4, 1 ) * 256 ) + substring( v.imageval, 3, 1 ) * 256 ) + substring( v.imageval, 2, 1 ) * 256 ) + substring( v.imageval, 1, 1 )) LEFT JOIN master.sys.sysqnames m ON m.nid = p.qid WHERE v.valclass = 58 -- SVC_XE_SESSION_ACTION AND has_access ('ES', 0) = 1 0 8CREATE VIEW sys.server_event_session_events AS SELECT event_session_id = v.objid, event_id = @.subobjid, name = convert(sysname, v.value) collate database_default, package = convert(sysname, p.name) collate database_default, module = convert(sysname, m.name) collate database_default, predicate = convert(nvarchar(3000), v.imageval) collate database_default FROM master.sys.sysobjvalues v LEFT JOIN master.sys.sysqnames p ON p.nid = v.valnum LEFT JOIN master.sys.sysqnames m ON m.nid = p.qid WHERE v.valclass = 56 -- SVC_XE_SESSION_EVENT AND has_access ('ES', 0) = 1 @ c8CREATE VIEW sys.server_event_session_fields AS SELECT event_session_id = v.objid, object_id = v.subobjid, name = convert(sysname, v.imageval) collate database_default, value = v.value FROM master.sys.sysobjvalues v WHERE v.valclass = 59 -- SVC_XE_SESSION_FIELD AND has_access ('ES', 0) = 1 0 :8CREATE VIEW sys.server_event_session_targets AS SELECT event_session_id = v.objid, target_id = v.subobjid, nam@ = convert(sysname, v.value) collate database_default, package = convert(sysname, p.name) collate database_default, module = convert(sysname, m.name) collate database_default FROM master.sys.sysobjvalues v LEFT JOIN master.sys.sysqnames p ON p.nid = v.valnum LEFT JOIN master.sys.sysqnames m ON m.nid = p.qid WHERE v.valclass = 57 -- SVC_XE_SESSION_TARGET AND has_access ('ES', 0) = 1 0 8CREATE VIEW sys.server_event_sessions AS SELECT event_sess@on_id = c.id, name = convert(sysname, c.name) collate database_default, event_retention_mode = char(v2.subobjid), -- EMDXEEventRetention event_retention_mode_desc = xeer.name collate database_default, max_dispatch_latency = convert(INT, v1.value), max_memory = v1.subobjid, max_event_size = v1.valnum, memory_partition_mode = char(v2.valnum), -- EMDXEMemoryPartition memory_partition_mode_desc = xemp.name collate database_default, track_causality = convert(bit, c@status & 1), -- XE_SESSION_STATUS_BIT_CAUSALITY startup_state = convert(bit, c.status & 2) -- XE_SESSION_STATUS_BIT_AUTOSTART FROM master.sys.sysclsobjs c LEFT JOIN master.sys.sysobjvalues v1 ON v1.valclass = 90 AND -- SVC_XE_SESSION_PROP_1 v1.objid = c.id LEFT JOIN master.sys.sysobjvalues v2 ON v2.valclass = 91 AND -- SVC_XE_SESSION_PROP_2 v2.objid = c.id LEFT JOIN sys.syspalnames xeer ON xeer.class = 'XEER' AND xeer.value = char(v2.subobjid) LEFT JOIN sys.syspalnames xemp ON @emp.class = 'XEMP' AND xemp.value = char(v2.valnum) WHERE c.class = 62 -- SOC_XESESSION AND has_access ('ES', 0) = 1 6 <) <)~ <)>(>)~<)V>>)~V<3 >>)~<&XF<>@0) ~>"L) >) ~><)<d0 d8CREATE VIEW sys.sac_state AS SELECT component_name, convert(sysname, N'mssqlsystemresource') collate database_default AS database_name, schema_name collate database_default AS schema_name, object_name collate database_default AS object_name, state, type FROM sys.obd_state UNION ALL SELECT convert(sysname, c.name) AS compon@nt_name, convert(sysname, N'master') collate database_default AS database_name, s.name collate database_default AS schema_name, o.name collate database_default AS object_name, convert(tinyint, convert(int, c.value) & 1) AS state, o.type FROM master.sys.sysobjkeycrypts k JOIN master.sys.sysschobjs o ON o.id = k.id JOIN master.sys.sysxlgns l ON l.type = 'M' AND substring(l.sid, 13, 28) = k.thumbprint JOIN master.sys.configurations c ON c.name = substring(l.name, 3, len(l.name) - 4) L@FT JOIN master.sys.schemas s ON s.schema_id = o.nsid WHERE k.class = 1 AND k.type = 'INCP' UNION ALL SELECT convert(sysname, c.name) AS component_name, convert(sysname, N'msdb') collate database_default AS database_name, s.name collate database_default AS schema_name, o.name collate database_default AS object_name, convert(tinyint, convert(int, c.value) & 1) AS state, o.type FROM msdb.sys.sysobjkeycrypts k JOIN msdb.sys.sysschobjs o ON o.id = k.id JOIN master.sys.sysxlgns l ON l.@ype = 'M' AND substring(l.sid, 13, 28) = k.thumbprint JOIN master.sys.configurations c ON c.name = substring(l.name, 3, len(l.name) - 4) LEFT JOIN msdb.sys.schemas s ON s.schema_id = o.nsid WHERE k.class = 1 AND k.type = 'INCP'  < I6 <)>)~D)))Q0-4Qcomponent_name ) 9>)@~  ))).6.component_name ) >}6 ))k >)~D)))O0-Odatabase_name ) z->)~y)) ),6,database_name ) }-,+"@6 )) >)~D )))K0-Kschema_name ) a>)~h)))(6(schema_name ) x=6 ))>)~D )))K0-@Kobject_name ) D>)!~c)))(6(object_name ) EϠB~6 )) >)"~D ))!)?0-00?state ) Bd>)$~^v)))@state ) )%~D ))$)=0-=type ) <戠L6 ))&C >)'~)))6type ) {36 ))(@>))~6'")" " _Kn0)~>"L)p&&%H%%p$8$##"X"!p! 8 p@@Pp `(p(@@@H6tEex.ie0vtaaP1'00)Nj(%"%5'-)=H)P"  )P@"85:-A= )" 0("E @0)"E 0)"E 0)@"E 0)"0 ) "E @0!) "E 0") "E @#) " x 0$) " E 0%)" @ ))R5T-Y= ))[F@0&))H0'))H0())H@0)))H0*))H@0+))H0,))H0-))@H0.)) H0/)) .H@00)) J01)) H02))@ H03))H04))H@05) )H)<5-=)@<)<-=1 (+<@1 )%<1)&<1)@'<1)(<1))<@)$"5-=O)#" @0)""(5*-1=0)," 1)-)5-@1).)[F`)P""L~('X&%$##H"x! 8h(XHx8h ( X  Hx8h(@@@HH@@@=0P0))1"L)1(H)P"  )P@"85:-A= )" 0("E @0)"E 0)"E 0)@"E 0)"0 ) "E @0!) "E 0") "E @#) " x 0$) " E 0%)" @ ))R5T-Y= ))[FH0&))H0'))H0())H@@@@@@@$ &0$e># g <# 0X4  8create procedure sys.sp_MSenum_subscriptions ( @publisher sysname, @publisher_db sysname, @publication sysname, @exclude_anonymous bit = 0 ) as begin declare @subscriber sysname declare @subscriber_id smallint declare @subscriber_db sysname declare @subscriber_name sysname declare @type int declare @status int declare @distribution_agent nvarchar(100) declare @publisher_id smallint declare @independent_agent bit declare @offload_enabled bit declare @offload_server sysname declare @start_time nvarchar(24) declare @time nvarchar(24) declare @duration int declare @comments nvarchar(4000) declare @delivery_time int declare @delivered_transactions int declare @delivered_commands int declare @average_commands int declare @delivery_rate int declre @delivery_latency int declare @error_id int declare @publication_id int declare @job_id binary(16) declare @agent_id int declare @local_job bit declare @profile_id int declare @last_timestamp binary(8) ,@subscriber_type tinyint set nocount on -- -- security check -- only replmonitor can execute this -- if not (is_member(N'db_owner') = 1 or isnull(is_member(N'replmonitor'),0) = 1) begin raiserror(14260, 16, -1) eturn (1) end select @publisher_id = srvid from master.dbo.sysservers where UPPER(srvname) = UPPER(@publisher) select @publication_id = publication_id from dbo.MSpublications where publisher_id = @publisher_id and publisher_db = @publisher_db and publication = @publication and (publication_type = 0 or publication_type = 1) create table #subscriptions (subscriber sysname NOT NULL, status int NOT NULL, subscribe_db sysname NOT NULL, type tinyint NOT NULL, distribution_agent nvarchar(100) NOT NULL, last_action nvarchar(4000) NULL, action_time nvarchar(24) NULL, start_time nvarchar(24) NULL, duration int NULL, delivery_rate float NULL, delivery_latency int NULL, delivered_transactions int NULL, delivered_commands int NULL, delivery_time int NULL, average_commands int NULL, error_id int NULL, job_id binary(16) NULL, local_job bit NULL, profle_id int NOT NULL, agent_id int NOT NULL, last_timestamp binary(8) NOT NULL, offload_enabled bit NOT NULL, offload_server sysname NULL, subscriber_type tinyint NULL) -- This is to force all queries to return rows ordered by job_id -- Note: There might be dist agents left for cleaning up sub, in this case -- they are not in sub table and we don't want to show them create unique clustered index ucsubscriptions ON #subscriptions (agent_id) declare hC CURSOR LOCAL FST_FORWARD FOR select id, name, subscriber_id, subscriber_db, job_id, local_job, subscription_type, profile_id, subscriber_name, offload_enabled, offload_server from MSdistribution_agents a where exists (select * from dbo.MSsubscriptions s where (a.id = s.agent_id or a.anonymous_agent_id = s.agent_id) and s.publisher_id = @publisher_id and s.publisher_db = @publisher_db and -- For 6.x publisher, we don't know the association between the publication - and subscriptions. Show every dist agent under each publication. (s.publication_id = @publication_id or s.publication_id = 0 ) and (a.subscriber_id >= 0 or a.subscriber_id is NULL)) and (@exclude_anonymous = 0 or a.anonymous_agent_id is null) for read only -- declare hC CURSOR LOCAL FAST_FORWARD FOR select a.id, a.name, a.subscriber_id, ms.subscriber_db, -- a.job_id, a.local_job, ms.subscription_type, a.profile_id, a.subscriber_name -- from MSdistribution_agentsa, master.dbo.sysservers s, dbo.MSsubscriptions ms -- where -- a.publisher_id = @publisher_id and -- a.publisher_db = @publisher_db and -- (a.publication = @publication or a.publication = 'ALL') and -- a.subscriber_id >= 0 and -- ms.publisher_db = @publisher_db and -- ms.publication_id = @publication_id and -- ms.subscriber_id = a.subscriber_id and -- ms.subscriber_db = a.subscriber_db and -- s.srvid = ms.subscriber_id -- for read only open hC fetch hC into @agent_id, @distribution_agent, @subscriber_id, @subscriber_db, @job_id, @local_job, @type, @profile_id, @subscriber_name, @offload_enabled, @offload_server while (@@fetch_status <> -1) begin /* Stuff in the values for no history case */ select @status = 0, @start_time = NULL, @time = NULL, @duration = NULL, @comments = NULL, @delivery_time = NULL, @delivered_transactions = NULL, @delivered_commands = NULL, @average_commands = NULL, @delivery_rate = NULL, @delivery_latency = NULL, @error_id = NULL, @last_timestamp = 0x00000000 -- Get the status of the agent select @status = runstatus, @start_time = sys.fn_replformatdatetime(start_time), @time = sys.fn_replformatdatetime(time), @duration = duration, @comments = comments, @delivery_time = 0, @delivered_tansactions = delivered_transactions, @delivered_commands = delivered_commands, @average_commands = average_commands, -- Note: return average rate here !!! delivery_rate column is current rate @delivery_rate = delivery_rate, @delivery_latency = delivery_latency, @error_id = error_id, @last_timestamp = timestamp from MSdistribution_history with (READPAST) where agent_id = @agent_id and timestamp = (select max(timestamp) from MSdistribution_history with (READPAST) where agent_id = @agent_id) -- For anonymous subscriptions, @subscriber_name is not NULL if @subscriber_name is NULL begin select @subscriber = srvname from master.dbo.sysservers where srvid=@subscriber_id select @subscriber_type = type from MSsubscriber_info where UPPER(publisher) = UPPER(@publisher) and UPPER(subscriber) = UPPER(@suscriber) end else begin select @subscriber = @subscriber_name select @subscriber_db = @subscriber_db + '-' + convert(nvarchar(30), @agent_id) -- Don't know the subscriber type for anonymous end insert into #subscriptions values ( @subscriber, @status, @subscriber_db, @type, @distribution_agent, @comments, @time, @start_time, @duration, @delivery_rate, @delivery_latency, @delivered_transactions, @delivered_commands, @deliery_time, @average_commands, @error_id, @job_id, @local_job, @profile_id, @agent_id, @last_timestamp, @offload_enabled, @offload_server, @subscriber_type) fetch hC into @agent_id, @distribution_agent, @subscriber_id, @subscriber_db, @job_id, @local_job, @type, @profile_id, @subscriber_name, @offload_enabled, @offload_server end select * from #subscriptions order by job_id asc drop table #subscriptions close hC dallocate hC end 0|7  8create view sys.trace_subclass_values as select * from OpenRowset(TABLE SYSTRACESUBCLASSVALUES) is<$g  <"p! (nuou>$g <$ et  >$g <"p!   raise>$g <#<nsX4  maxs0#g L#, -1) >#g <$<va0ƃ%  8create procedure [sys].[sp_cdc_get_ddl_history] ( @capture_instance sysname ) as begin -- Verify database is currently enabled for change data capture if ([sys].[fn_cdc_is_db_enabled]() != 1) begin declare @db_name sysname set @db_name = db_name() raiserror(22901, 16, -1, @db_name) return 1 end if (@capture_instance is null) or (rtrim(@capture_instance) = N'') begin raiserror(22963, 16, -1, N'@capture_instance') return 1 end if ([sys].[fn_cdc_has_select_access](rtrim(@capture_instance)) = 0) begin raiserror(22981, 16, -1) return 1 end exec sys.sp_cdc_ddl_history @capture_instance return 0 end p < (|s set @>$g!)"xM )Wti0-ƃ% W@capture_instancel ) oh&5in>$g)#)4 @6ƃ% 4@capture_instance ) y7dbo.cd>$ go"#"b_i() ƃ%  " J a>$ go"$ "inu us ƃ%  " Je_0#g L#ontinu%H%$@$# (ate msdb.dbo.cdc_jobs set maxtrans = @maxtrans where database_id = db_id() and job_type = @job_type and @maxtrans is not null update msdb.dbo.cdc_jobs set maxscans = @maxscans where database_id = db_id() and job_type = @job_type and @maxscans is not null end else begin update msdb.dbo.cdc_jobs set retention = @retention where database_id = db_id() and job_type = @job_type and @retention is not null update msdb.dbo.cdc_jobs set threshold @threshold where database_id = db_id() and job_type = @job_type and @threshold is not null end return(0) end  < f$B_get_a>#g)#8)Gfn0-(G@job_typed ) C R% ]>#gX )#X )$ >6$@job_type ) <% roll>#g)#)G =0-88 G@maxtransr ) 8dte>#gc)#)$ER6$@maxtrans ) ;D) as n>#g)#)GOR0-88 G@maxscansa ) ZtJh @># g[)#)$d 6@maxscans ) (CBtr>#!g)# )K0-hhK@continuous ) bQh>#>#"g )#)(R6(@continuous ) t?4>##g)#")U 0-U@pollinginterval ) T>#$g)#)262@pollingintervala ) 9) as sy>#%g )#$)Isp0-I@retention ) {)I>#&g 2)#)&6&@retent p  0 evb r -Airra D 0$(2@g3 L*CreatProc transaction T$(g  i)>$(g3""O"X0,i)P  L L Xsp_cdc_ddl_history "  >$(g)"#"2&i)2sp_cdc_ddl_history_ " hJT">$(g"#"2&i)2sp_cdc_ddl_history_ " c,g_ >$(gto"#x" i) " A2ı" >$(gQ<"O<C0i) C8create procedure [sys].[sp_cdc_ddl_history] ( @capture_instance sysname ) with execute as 'dbo as begin select object_schema_name(t.source_object_id) as source_schema, object_name(t.source_object_id) as source_table, t.capture_instance, h.required_column_update, h.ddl_command, h.ddl_lsn, h.ddl_time from [cdc].[ddl_history] h inner join [cdc].[change_tables] t on h.object_id = t.object_id where t.capture_instance = @capture_instance order by h.ddl_lsn return 0 end n < l rai>$(gE )"PM)W([0-i)W@capture_instance8 ) ;ـ >$(g )$ )4tu6i)4@capture_instance ) Hж>$( g3"$("i) " u>$( g3"$( " i) " >$ gaJ#Ji) J G\#>$( gc*J#J= i) J %9k 0$(g L$( x ( L#ge_dat0 PX@(end o < @ȩN>#gA)#()Q0-dQ@source_schemaan ) zet>#g )# ).6d.@source_schema ) Sn># gB)#)M0-dM@source_name  ) T%ޥ># g()# )*6d@source_nameV ) NBWU># gh"#"d " pGi># gh"# " d " pG0#g L#  8 h pP( H)#)U0-ђU@pollinginterval^is ) tM>#g)#%)2"6ђ2@pollinginterval ) n(|l>#g I)#)I0-ђI@retention) ) @cc; | C >#g 3)#')& 6ђ&@retentionp ) # >#(8((' $0ꢠ%@g3/ L*CreatProc transactionceure$0g  O}>$0g6"# "t, 0,O}P / L/ L tsp_cdc_generate_wrapper_function " #Dner_db >$0g "#"N &O}Nsp_cd_generate_wrapper_functionar " \=Pnt>$0g"#"N &O}Nsp_cdc_generate_wrapper_function  " ar>$0gw"#"  O} @ " D1 decla>$0g<"M<  0O} 8create procedure [sys].[sp_cdc_generate_rapper_function] ( @capture_instance sysname = null, @closed_high_end_point bit = 1, @column_list nvarchar(max) = null, @update_flag_list nvarchar(max) = null ) as begin set nocount on declare @retcode int, @capture_cnt int, @object_id int, @quoted_change_table nvarchar(260), @db_name sysname set @quoted_change_table = N'[cdc].' + quotename(@capture_instance + N'_CT') set @db_name = db_name() -- Verify databse is currently enabled for change data capture if ([sys].[fn_cdc_is_db_enabled]() != 1) begin raiserror(22901, 16, -1, @db_name) return 1 end create table #capture_instances ( capture_instance sysname collate database_default, object_id int ) create table #create_scripts ( function_name nvarchar(145) collate database_default, create_script nvarchar(max) collate database_default ) if (@capture_instance is null) or (rtrim(@capture_instance) = N'' begin -- If the capture instance is not specified, the @column_list and -- @update_flag_list parameters must both be null if (@column_list is not null) or (@update_flag_list is not null) begin raiserror(22921, 16, -1) return 1 end -- Get a list of potential capture instances. exec @retcode = sys.sp_cdc_get_capture_instances null, null if @retcode <> 0 begin return 1 end end else begin -- Get a list of potential capture instances. exec @retcod = sys.sp_cdc_get_capture_instances null, null if @retcode <> 0 begin return 1 end -- If the capture instance is specified, it must exist if not exists ( select capture_instance from #capture_instances where capture_instance = @capture_instance ) begin raiserror(22920, 16, -1, @capture_instance, @db_name) return 1 end -- Remove all entries except the one for the named instance delete from #capture_instances where capture_instance <> @captre_instance end if (@closed_high_end_point is null) begin set @closed_high_end_point = 1 end -- Eliminate from the list any entries that the caller is not -- authorized to access delete from #capture_instances where sys.fn_cdc_has_select_access(capture_instance) = 0 -- If there are no elements in #capture_instances and -- an explicit capture instance was entered, return error select @capture_cnt = count(*) from #capture_instances if (@capture_cnt = 0) and (@capture_intance is not null) begin raiserror(22981, 16, -1) return 1 end -- Generate wrapper for the capture instances exec sys.sp_cdc_generate_wrapper_function_internal @closed_high_end_point ,@column_list ,@update_flag_list select function_name, create_script from #create_scripts return 0 end me < Mxsu>$0g3)"M)Wro0-O}W@capture_instancer ) o-ns>$0g)$( )4 6O}4@capture_instance ) =N)#ation >$0 g4)$0)a- 0-O}hha@closed_high_end_point.su ) Kiber_i>$0 g )"N)> =6O}>@closed_hig_end_pointet ) '5 @>$0 g5)$0 )M@l0-O}M@column_listoff ) v5 (>$0 g ])$0 )*o 6O}*@column_list0, ) >time =>$0 g6)$0 )W 0-O}W@update_flag_liste ) N堼wer>$0gx)"N)4en6O}4@update_flag_list ) 8`$x00000>$0g6"$0"unsatuO} " #Dn s>$0g6"$0"mat ateO} " #Dnti0$0g0 L$0 0(p00xpP(ed_tansactions = delivered_transactions, @delivered_commands = delivered_commands, @average_commands = average_commands, -- Note: return average rate here !!! delivery_rate column is current rate @delivery_rate = delivery_rate, @delivery_latency = delivery_latency, @error_id = error_id, @last_timestamp = timestamp from MSdistribution_history with (READPAST) where agent_id = @agent_id and timestamp = (select max(timestamp) from MSdistribution_history with (READPAST) where agent_id = @agent_id) -- For anonymous subscriptions, @subscriber_name is not NULL if @subscriber_name is NULL begin select @subscriber = srvname from master.dbo.sysservers where srvid=@subscriber_id select @subscriber_type = type from MSsubscriber_info where UPPER(publisher) = UPPER(@publisher) and UPPER(subscriber) = UPPER(@suscriber) end else begin select @subscriber = @subscriber_name select @subscriber_db = @subscriber_db + '-' + convert(nvarchar(30), @agent_id) -- Don't know the subscriber type for anonymous end insert into #subscriptions values ( @subscriber, @status, @subscriber_db, @type, @distribution_agent, @comments, @time, @start_time, @duration, @delivery_rate, @delivery_latency, @delivered_transactions, @delivered_commands, @deliery_time, @average_commands, @error_id, @job_id, @local_job, @profile_id, @agent_id, @last_timestamp, @offload_enabled, @offload_server, @subscriber_type) fetch hC into @agent_id, @distribution_agent, @subscriber_id, @subscriber_db, @job_id, @local_job, @type, @profile_id, @subscriber_name, @offload_enabled, @offload_server end select * from #subscriptions order by job_id asc drop table #subscriptions close hC dallocate hC end 0|7  8create view sys.trace_subclass_values as select * from OpenRowset(TABLE SYSTRACESUBCLASSVALUES) is<$g  <"p! (nuou>$g <$ et  >$g <"p!   raise>$g <#<nsX4  maxs0#hsue)awc  $@:Lg@g3g L*CreatProc transaction T$@g  ; >$@g"""O-"0,; P g Lg L sp_cdc_generate_wrapper_function_internal " D+h>$@g "$0"`r&; `sp_cdc_generate_wrapper_function_internal " n9s>$@g"$0"`&; `sp_cdc_generate_wrapper_function_internal " ,~Acrr>$@gvZ"#" ; 8 " 5sys].[>$@g<"x-<e 0;  8create procedure [sys].[sp_cdc_generate_wrapper_function_internal] ( @closed_high_end_point bit, @column_list nvarchar(max), @update_flag_list nvarchar(max) ) with execute as 'dbo' as begin set nocount on declare @object_id int ,@capture_instance sysname ,@function_name nvarchar(145) ,@mapping_option nvarchar(30) ,@create_script nvarchar(max) ,@supports_net_changes bit declare #hinstance cursor local fast_forward for selec capture_instance, object_id from #capture_instances if (@closed_high_end_point = 1) set @mapping_option = N'largest less than or equal' else set @mapping_option = N'largest less than' open #hinstance fetch #hinstance into @capture_instance, @object_id while (@@fetch_status <> -1) begin -- Generate the script to create a wrapper for the all changes function set @function_name = N'fn_all_changes_' + @capture_instance exec sys.sp_cdc_create_change_enumeration_wrapper_fnction @capture_instance, @function_name, @mapping_option, @column_list, @update_flag_list, @create_script OUTPUT insert into #create_scripts values(@function_name, @create_script) -- If the capture instance supports net changes, create a wrapper for the -- net changes query function if exists ( select capture_instance from cdc.change_tables where capture_instance = @capture_instance and supports_net_changes = 1 ) begin set @function_name = N'fn_net_changes_' + capture_instance exec sys.sp_cdc_create_change_enumeration_wrapper_function @capture_instance, @function_name, @mapping_option, @column_list, @update_flag_list, @create_script OUTPUT insert into #create_scripts values(@function_name, @create_script) end fetch #hinstance into @capture_instance, @object_id end close #hinstance deallocate #hinstance return 0 end > < y[(>$@g)!J@)ae0-; hha@closed_high_end_point ) .?>$@g )$0 )>6; >@closed_high_end_point ) ^(>$@ g)$@)MH0-; M@column_list ) i>$@ g ^$@ )*6; *@column_list ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@";  " D+h>$@g""$@") ;  " D+h>$@gaJ$( J;  J lsz>#>$@gcJ$( Jnu;  J hkk&0$@gg L$@ 0(p 0 0p(h|e0#gV L#tioXX h 8 (removable &H'Dsp_check_removable_sysusers& 8sp_check_sync_trigger&>sp_checkinvalidivarticle i&(6sp_checknojobsinmsdban&>[(Hsp_CheckOracleAdminPrivileges&?U"Fsp_checkOraclepackageversionve&u <sp_checkusernotloggedin& !Dsp_clean_db_file_free_space&):sp_clean_db_free_spaceyp&mLsp_cleanup_log_shipping_history&z<sp_cleanupdbreplication&D6sp_column_privileges &t<sp_column_privileges_ex&v&Dsp_column_privileges_rowset& tb.sp_column_privileges_rowset_rmt&%r~Fsp_column_privileges_rowset2 &G"sp_columns> &V*sp_columns_100 p&› 8sp_columns_100_rowset&C:sp_columns_100_rowset2(&q) (sp_columns_90&86sp_columns_90_rowset&>>sp_columns_90_rowset_rmt&,B#8sp_olumns_90_rowset2&?#(sp_columns_ex&K0sp_columns_ex_100<#g *"#R(># g"# rr># g""F># g ""' "P&Psp_cdc_drop_change_table_objcts0#gӠ L#>#g"#",&j$ ,sp_cdc_drop_job " Vre>#g~"#",&j$ ,sp_cdc_drop_job " (VY- >#gv "#@" j$ bi " f->#g <"<0j$  8create procedure sys.sp_cdc_drop_job ( @job_type nvarchar(20) ) as begin set nocount on declare @retval int -- -- Authorization check. -- if (isnull(is_srvrolemember('sysadmin'),0) = 0) and (isnull(is_member('db_owner'),0) = 0) begin raiserror(22904, 16, -1) return(1) end -- NOTE: The bit identifying a database as enabled for cdc is -- cleared before the jobs can be droppe, so only admin -- authorization is checked here. If this changes, then -- job security can be checked. -- -- CDC Job security check -- --exec @retcode = [sys].[sp_MScdc_job_security_check] --if @retcode <> 0 or @@error <> 0 -- return (1) set @job_type = rtrim(ltrim(lower(@job_type))) -- Verify parameter if ((@job_type is null) or (@job_type not in (N'capture', N'cleanup'))) begin raiserror(2)@ut *0 $P-3_Z@g3 L*CreatProc transactionceure$Pg  KE>$PglB""N"b, 0,KEFN L L bfn_cdc_check_parameters_ " J:\">$Pg ""M"<&KE<fn_cdc_check_arameters " 4IYnct>$Pgg)""M"<&KE<fn_cdc_check_parameters " app>$Pgc"$0" KE " |@g3 LSplitPage>$Pg <#c re[sy@].[@$Pg<P$P g <   >$P g <$P Wsy 0u W8create procedure sys.sp_copymergesnapshot ( @publication sysname, @destination_folder nvarchar(255) ) AS BEGIN SET NOCOUNT ON DECLARE @retcode int DECLARE @source_folder nvarchar(255) SELECT @retcode = 0 EXEC @retcode = dbo.sp_MSreplcheck_publish IF @@ERROR <> 0 or @retcode <> 0 return (1) CREATE TABLE #snapshot_folders ( id int identity, snapshot_folder nvarchar(255) collate database_default ) IF @@ERROR <> 0 BEGIN RETURN 1 END INSERT INTO #snapshot_folders EXEC @retcode = sys.sp_browsemergesnapshotfolder @publication = @publication IF @retcode <> 0 OR @@ERROR <> 0 BEGIN GOTO Failure END SELECT @source_folder = (select top 1 snapshot_folder FROM #snapshot_folders ORDER BY id ASC) IF @@ERROR <> 0 BEGIN GOTO Failure END SET ROWCOUNT 0 EXEC @retcode = sys.sp_MScopysnapshot @source_folder, @destination_folder IF @retcode <> 0 OR @@ERROR <> 0 BEGIN GOTO Failure END DROP TABLE #snapshot_folders RETURN 0 Failure: SET ROWCOUNT 0 DROP TABLE#snapshot_folders RETURN 1 END 0z s8create procedure sys.sp_scriptsupdproc ( @artid int -- id of the article we are processing ,@mode tinyint = 1 -- 1 = static scripting, 2 = dynamic scripting ,@publishertype tinyint=1 -- 1 = mssqlserver, 2 = heterogeneous ,@publisher sysname=NULL -- May only be non-NULL if @publishertype = 2 ) as begin declare @retcode int -- -- security check -- exec @retcde = sys.sp_MSreplcheck_publish if @@error <> 0 or @retcode <> 0 begin return (1) end -- -- call core function -- exec @retcode = sys.sp_scriptupdproccore @artid = @artid ,@format = 5 -- SCALL format ,@mode = @mode ,@publishertype = @publishertype ,@publisher = @publisher return @retcode end t0: y8CREATE VIEW sys.dm_exec_query_stats AS SELECT * FROM OpeRowset (TABLE QUERY_STATS) r0n 8create procedure sys.sp_MSdrop_6x_publication ( @job_id UNIQUEIDENTIFIER ) as begin declare @publisher sysname declare @publisher_db sysname declare @publication sysname declare @retcode int -- -- security check -- only db_owner can execute this -- if (is_member ('db_owner') != 1) begin raiserror(14260, 16, -1) return (1) end -- -- security check -- Has to be executed from distribution database -- if (sys.fn_MSrepl_isdistdb (db_name()) != 1) begin raiserror(21482, 16, -1, 'sp_MSdrop_6x_publication', 'distribution') return (1) end -- Get publication information select @publisher = srvname, @publisher_db = publisher_db, @publication = publication from MSsnapshot_agents, master.dbo.sysservers where job_id = @job_id and srvid = publisher_id -- Remove the publication and napshot agent exec @retcode = sys.sp_MSdrop_publication @publisher = @publisher, @publisher_db = @publisher_db, @publication = @publication if @@ERROR <> 0 or @retcode <> 0 return 1 end 0w 8create procedure sys.sp_MSget_session_statistics ( @session_id int ) as begin declare @agent_id int declare @retcode int -- the merge agent calls this proc select @agent_id = 0 select @agent_id = agent_id fromdbo.MSmerge_sessions where session_id = @session_id -- Security Check exec @retcode = sys.sp_MScheck_pull_access @agent_id = @agent_id, @agent_type = 1 -- merge agent if @@error <> 0 or @retcode <> 0 return (1) select duration, upload_time, download_time, prepare_snapshot_time, schema_change_time, schema_changes, bulk_inserts, metadata_rows_cleanedup, estimated_uploa_changes, estimated_download_changes from dbo.MSmerge_sessions with (nolock) where session_id = @session_id select phase_id, article_name, duration, inserts, updates, deletes, conflicts, rows_retried, estimated_changes from dbo.MSmerge_articlehistory with (nolock) where session_id = @session_id return 0 end <$P g  <"E  (se>$P g <$P    wh>$P g <"" s iption>$Pg <$< u  sel0$Pg L$Prs whe>$Pg <$P <cr0KE 8create function [sys].[fn_cdc_check_parameters] ( @capture_instance sysname, @from_lsn binary(10), @to_lsn binary(10), @row_filter_option nvarchar(30), @net_changes bit ) returns bit as begin declare @val bit select @capture_instance = rtrim(@capture_instance) if ([sys].[fn_cdc_has_select_access](@capture_instance) = 0) begin if (@net_changes is null) or (@net_changes = 0) begin -- Force error 229 execute permission denied on all changes dummy if exists( select * from cdc.[fn_cd_get_all_changes_...](0X00, 0X01, 'all') ) return 0 end else begin -- Force error 229 execute permission denied on net changes dummy if exists( select * from cdc.[fn_cdc_get_net_changes_...](0X00, 0X01, 'all') ) return 0 end return 0 end if ([sys].[fn_cdc_is_range_valid](@from_lsn, @to_lsn, @capture_instance) = 0) begin -- Force error 313 -- Insufficient number of arguments if ((@net_changes is null) or (@net_changes = 0)) begin select val = sys.fn_cdc_all_changes_range_error() return 0 end else begin select @val = sys.fn_cdc_net_changes_range_error() return 0 end end if ((@net_changes is null) or (@net_changes = 0)) begin if (@row_filter_option is NULL) or (lower(rtrim(ltrim(@row_filter_option))) not in (N'all', N'all update old')) begin -- Force error 313 -- Insufficient number of arguments select @val = sys.fn_cdc_all_changes_range_error() return 0 end end else begin if (@row_filter_option is NULL) or (lower(rtrim(ltrim(@row_filter_option))) not in (N'all', N'all with mask', N'all with merge')) begin -- Force error 313 -- Insufficient number of arguments select @val = sys.fn_cdc_net_changes_range_error() return 0 end end return 1 end s < )yd]() !>$PgS)"N)1) -KEhhtur ) /HRcaptur>$Pg>)"M )seKE,  ) %e'>$PgT)$P)Wap0-KEW@capture_instances ) 9@c>$Pg)$0 )46KE4@capture_instance ) Qz0`ti>$PgU)$P)Gi0-KE G@from_lsn ) 60 .>$Pgg>)"X-)$ 6KE$@from_lsn ) Oƿ#>$PgV)$P)C a0-KE C@to_lsn ) || ">$Pg )#) nu6KE@to_lsn ) Hax>$PgW)$P)Yb_0-KE<Y@row_filter_optioncan ) YKq = db_>$Pg)"0E()6 e6KE6@row_filter_optionon ) )B* d>$PgX)$P)Mno0-KEhhM@net_changes da )  B} a>$PgX=)"L )*tu6KE*@net_changes> ) 'l/a#>$PglB"$P"KE " J:\d>$PglB"$P") KE " J:\0$Pg L$P>#)0)(0('&(&%%x$#8#""x!X h0@0(0-88 G@maxtransr ) 8dte>#gc)#)$ER6$@maxtrans ) ;D) as n>#g)#)GOR0-88 G@maxscansa ) ZtJh @># g[)#)$d 6@maxscans ) (CBtr>#!g)# )K0-hhK@continuous ) bQh>#>#"g )#)(R6(@continuous ) t?4>##g)#")U 0-U@pollinginterval ) T>#$g)#)262@pollingintervala ) 9) as sy>#%g )#$)Isp0-I@retention ) {)I>#&g 2)#)&6&@retent p   @c d s no p 0$hJ@g3 L*CreatProc transaction T$hg  ;0>$hg"#x "p0,;0FN L L pfn_cdc_all_changes_range_error " Du>$hg "$P"J&;0Jfn_cdc_al_changes_range_errora " non_>$hgg)"$P"J&;0Jfn_cdc_all_changes_range_errore " ѳOKyr_f>$hgtI"$(" ;0 " ^rgX">$hg<"F <0;0 8 create function [sys].[fn_cdc_all_changes_rang_error]() returns bit as begin if exists ( select * from cdc.[fn_cdc_get_all_changes_ ... ]() ) return 0 return 0 end  < ?o, >$hgt)"O@)1n -;0hh@ca ) a ,>$hgv)$P)re;0rc ) zvs_>$h g"$h" slec;0 " Du >$h g"$h "map ing;0 " Duor0$hg L$hless t @hH( fetch #hinstance into @capture_instance, @object_id while (@@fetch_status <> -1) begin -- Generate the script to create a wrapper for the all changes function set @function_name = N'fn_all_changes_' + @capture_instance exec sys.sp_cdc_create_change_enumeration_wrapper_fnction @capture_instance, @function_name, @mapping_option, @column_list, @update_flag_list, @create_script OUTPUT insert into #create_scripts values(@function_name, @create_script) -- If the capture instance supports net changes, create a wrapper for the -- net changes query function if exists ( select capture_instance from cdc.change_tables where capture_instance = @capture_instance and supports_net_changes = 1 ) begin set @function_name = N'fn_net_changes_' + capture_instance exec sys.sp_cdc_create_change_enumeration_wrapper_function @capture_instance, @function_name, @mapping_option, @column_list, @update_flag_list, @create_script OUTPUT insert into #create_scripts values(@function_name, @create_script) end fetch #hinstance into @capture_instance, @object_id end close #hinstance deallocate #hinstance return 0 end > < y[(>$@g)!J@)ae0-; hha@closed_high_end_point ) .?>$@g )$0 )>6; >@closed_high_end_point ) ^(>$@ g)$@)MH0-; M@column_list ) i>$@ g ^$@ )*6; *@column_list ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@"el $pq(@g3 L*CreatProc transactionceure$pg  E9M.>$pgk""8I"p, 0,E9M.FN L L pfn_cdc_net_changes_range_error " %>$pg"$h"JKE&E9M.Jfn_cdc_ne_changes_range_errorn " c>$pgg?"$h"Jd&E9M.Jfn_cdc_net_changes_range_error " 4+1$>$pgt"$h" E9M. " %O (>$pg<"P$ <0E9M. 8 create function [sys].[fn_cdc_net_changes_rang_error]() returns bit as begin if exists ( select * from cdc.[fn_cdc_get_net_changes_ ... ]() ) return 0 return 0 end  < v,U#>$pg| )"`F)1 -E9M.hh (  ) N-ĭ] s>$pgt)$h ) E9M.  ) Э,Ac >$p gk"$p"  E9M. " %re>$p gk"$p " E9M. " %s 0$pg L$p  @hH((255) collate database_default ) IF @@ERROR <> 0 BEGIN RETURN 1 END INSERT INTO #snapshot_folders EXEC @retcode = sys.sp_browsemergesnapshotfolder @publication = @publication IF @retcode <> 0 OR @@ERROR <> 0 BEGIN GOTO Failure END SELECT @source_folder = (select top 1 snapshot_folder FROM #snapshot_folders ORDER BY id ASC) IF @@ERROR <> 0 BEGIN GOTO Failure END SET ROWCOUNT 0 EXEC @retcode = sys.sp_MScopysnapshot @source_folder, @destination_folder IF @retcode <> 0 OR @@ERROR <> 0 BEGIN GOTO Failure END DROP TABLE #snapshot_folders RETURN 0 Failure: SET ROWCOUNT 0 DROP TABLE#snapshot_folders RETURN 1 END 0z s8create procedure sys.sp_scriptsupdproc ( @artid int -- id of the article we are processing ,@mode tinyint = 1 -- 1 = static scripting, 2 = dynamic scripting ,@publishertype tinyint=1 -- 1 = mssqlserver, 2 = heterogeneous ,@publisher sysname=NULL -- May only be non-NULL if @publishertype = 2 ) as begin declare @retcode int -- -- security check -- exec @retcde = sys.sp_MSreplcheck_publish if @@error <> 0 or @retcode <> 0 begin return (1) end -- -- call core function -- exec @retcode = sys.sp_scriptupdproccore @artid = @artid ,@format = 5 -- SCALL format ,@mode = @mode ,@publishertype = @publishertype ,@publisher = @publisher return @retcode end t0: y8CREATE VIEW sys.dm_exec_query_stats AS SELECT * FROM OpeRowset (TABLE QUERY_STATS) r0n 8create procedure sys.sp_MSdrop_6x_publication ( @job_id UNIQUEIDENTIFIER ) as begin declare @publisher sysname declare @publisher_db sysname declare @publication sysname declare @retcode int -- -- security check -- only db_owner can execute this -- if (is_member ('db_owner') != 1) begin raiserror(14260, 16, -1) return (1) end -- -- security chet^ $x@g3y L*CreatProc transaction T$xg  >$xg ""L"d0,FNy Ly L dfn_cdc_has_select_access " %# >$xg"$p">&>fn_cdc_has_seect_accessa " ao> >$xgg7"$p">&>fn_cdc_has_select_accessh " W"_>$xgz`"#P" I " i^>$xg%<"L<0 8create function [sys].[fn_cdc_has_select_access] ( @capture_instanc sysname ) returns bit with returns null on null input as begin declare @quoted_source nvarchar(780) ,@role sysname -- Determine the name of the gating role if one exists select @role = [sys].[fn_cdc_get_role](@capture_instance) -- If the gating role is not null and the caller is not a member -- of the role, the db_owner, or sysadmin, deny access if (isnull(is_srvrolemember('sysadmin'),0) = 0) and (isnull(is_member('db_owner'),0) = 0) and (@role is not null and (isnull(is_member(@role),0) = 0) begin return 0 end -- Determine the name of the associated source table select @quoted_source = [sys].[fn_cdc_get_source](@capture_instance) select @quoted_source = db_name() + N'.' + @quoted_source -- Determine whether the caller has select access on the tracked columns if exists ( select name from sys.fn_cdc_get_column_list(@capture_instance) where has_perms_by_name(@quoted_source, 'OBJECT', 'SELECT', name, 'COLUMN') = 0 ) begin return 0 end return 1 end  < DI_list,>$xg )"L )1ti-hhe i ) hanges>$xg)$p )tsca ) _[-c.>$x g )$x)Wup0-W@capture_instancee ) N]D.s>$x g)$P)4 64@capture_instance ) F '_scrip>$x g "$x"te_cri " %#in>$x g "$x "all cat " %#d >$x g "$x " , " #0$xgy L$x ( h `@0(end_point ) .?>$@g )$0 )>6; >@closed_high_end_point ) ^(>$@ g)$@)MH0-; M@column_list ) i>$@ g ^$@ )*6; *@column_list ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@"% )el $@g3 L*CreatProc transactionceure$g  N,>$g)"#"x, 0,N,FN L L xfn_cdc_get_column_ordinal_internal " y>$g"$x"RE9&N,Rfn_cd_get_column_ordinal_internal  " ;>r>$gg3"$x"Rf&N,Rfn_cdc_get_column_ordinal_internal " C3˴>$gt"$p" N, " Ƭ>$g <"'<0 0N, 08create function sys.fn_cc_get_column_ordinal_internal ( @source_schema sysname, @source_name sysname, @column_name sysname ) returns int with execute as 'dbo' as begin declare @ordinal_position int select @ordinal_position = t.ordinal_position - 5 from INFORMATION_SCHEMA.COLUMNS t where t.table_catalog = db_name() and t.table_schema = @source_schema and t.table_name = @source_name and t.column_name = @column_name return @ordinal_position end  < Ϳ]">$gV)#)1-N,88  ) 7; 9>$gp)$x )daN,  ) x><>>$ gW)$)Qfo0-N,Q@source_schemacat ) {P'5> 0 OR>$ g )# ).EC6N,.@source_schemaer ) وews >$ gX)$ )M 0-N,M@source_namenap ) O~ >$ g,)# )*et6N,*@source_name  ) ہ=LND >$ gY)$ )MOU0-N,M@column_namez ) >$g  )"hM)* 6N,*@column_name  ) qU >$g)"$"nt= N, " yge>$g)"$"typ = N, " yre>$gaJ$@JsyN, J j))retcod>$gc.J$@JreN,  J !.sp_sc0$g L$ @ P P  `X( ,@mode = @mode ,@publishertype = @publishertype ,@publisher = @publisher return @retcode end t0: y8CREATE VIEW sys.dm_exec_query_stats AS SELECT * FROM OpeRowset (TABLE QUERY_STATS) r0n 8create procedure sys.sp_MSdrop_6x_publication ( @job_id UNIQUEIDENTIFIER ) as begin declare @publisher sysname declare @publisher_db sysname declare @publication sysname declare @retcode int -- -- security check -- only db_owner can execute this -- if (is_member ('db_owner') != 1) begin raiserror(14260, 16, -1) return (1) end -- -- security chdc $@g3ϸ L*CreatProc transaction T$g  @=>$g $""M"f0,@=FNϸ Lϸ L ffn_cdc_get_column_ordinal  " Adv >$g"$"@&@=@fn_cdc_get_coumn_ordinal " hK >$gg3"$"@&@=@fn_cdc_get_column_ordinal " yN _>$guV"#" I@= " "vS>$gm <"<0@= 8create function sys.fn_cdc_get_column_ordinal ( @capture_instance ssname, @column_name sysname ) returns int with returns null on null input as begin declare @ordinal_position int ,@source_schema sysname ,@source_name sysname -- Verify capture instance is not null or empty if (@capture_instance is null) or (rtrim(@capture_instance) = N'') begin return null end -- Verify column name is not null or empty if (@column_name is null) or (rtrim(@column_name) = N'') begin return null end set @source_schema = Ncdc' set @source_name = @capture_instance + N'_CT' -- Caller must have select access to the source table if ([sys].[fn_cdc_has_select_access](@capture_instance) != 1) begin return null end select @ordinal_position = sys.fn_cdc_get_column_ordinal_internal( @source_schema, @source_name, @column_name) return @ordinal_position end nam < @ ncolumn>$g)")1OB-@=88   ) xnturn 1>$g)$ )@= ) ʏz>$ g)$)W0-@=W@capture_instance ) "|>$ g))$x )46@=4@capture_instance ) pYR|>$ g$ )M0-@=M@column_name ) aӊZn>$ g )$)* 6@=*@column_namee_ ) "d\ >$ g $"$"@= " Adv >$g $"$" @= " Adv >$g $"$" h ,`@= " Advt0$gϸ L$p H  @0(>6; >@closed_high_end_point ) ^(>$@ g)$@)MH0-; M@column_list ) i>$@ g ^$@ )*6; *@column_list ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@")'yl $Y}@g3 L*CreatProc transactionceure$g  >$go/"$ "^, 0, FN L L ^fn_cdc_is_range_validi " :9W]l>$g"$"8& 8fn_cdc_is_range_vlid "  d>$gg?"$"8& 8fn_cdc_is_range_valid " ʟұd>$gv"$@"   " v+sx>$g<!D <Q0  Q8create function [sys].[fn_cdc_is_range_valid] ( @from_lsn binary(10), @to_lsn binary(10) @capture_instance sysname ) returns bit with execute as 'dbo' as begin declare @max_lsn binary(10) if @from_lsn is null or @to_lsn is null or @capture_instance is null begin return 0 end if @from_lsn > @to_lsn begin return 0 end select @max_lsn = max(start_lsn) from [cdc].[lsn_time_mapping] if @max_lsn is null begin return 0 end if exists ( select start_lsn from [cdc].[change_tables] WITH (REPEATABLEREAD where capture_instance = rtrim(@capture_instance) and (@from_lsn >= start_lsn) and (@to_lsn <= @max_lsn) ) begin return 1 end return 0 end  < ;̬[)>$g5)#@ )1- hh ) iⳅ>$g)$ ) OR ) P{ ->$ g6)$)Go0-  G@from_lsn ) %$`>$ gg>)$P)$6 $@from_lsn ) 5d% >$>$ g7)$ )C0-  C@to_lsn ) 0Y>$ g )$P)6  @to_lsn ) Al;)>$ g8)$ )W0- W@capture_instance  ) ]$g)$ )4"6 4@capture_instance ) +æ>$go/"$"  " :9W]>$go/"$"   " :9W]>$gaJ$Jsc  J n >$gcJ$J  er J  0$g L$de enh p @  x( (TE VIEW sys.dm_exec_query_stats AS SELECT * FROM OpeRowset (TABLE QUERY_STATS) r0n 8create procedure sys.sp_MSdrop_6x_publication ( @job_id UNIQUEIDENTIFIER ) as begin declare @publisher sysname declare @publisher_db sysname declare @publication sysname declare @retcode int -- -- security check -- only db_owner can execute this -- if (is_member ('db_owner') != 1) begin raiserror(14260, 16, -1) return (1) end -- -- security ch ),a $U%@g3T L*CreatProc transaction T$g  ?>$gm""M"X0,?FNT LT L Xfn_cdc_get_min_lsn " J/">$g"$"2&?2fn_cdc_get_min_lsn_ " Xnal>$gg6"$"2&?2fn_cdc_get_min_lsn_ " Yord>$gw"#" ?" " |LE@>$g<"xL<0? 8create function [sys].[fn_cdc_get_min_lsn] ( @capture_instance sysname ) returns binary(10) as begin declare @min_lsn binary(10) select @min_lsn = 0x00000000000000000000 -- Caller must have select access to the source table if (@capture_instance is null) or ([sys].[fn_cdc_has_select_access](rtrim(@capture_instance)) != 1) begin return @min_lsn end select @min_lsn = [sys].[fn_cdc_get_start_lsn](rtrim(@capture_instance)) if (@min_lsn > [sys].[fn_cdc_get_max_lsn]()) begin set @min_lsn = NULL end return @min_lsn end  < %8{us>$g)"F)1t_-? n n ) +L.1@ordin>$gR)$ )a,? @ ) Kirn>$ g )$)W0-?W@capture_instance ) .= >$ g!)$)46?4@capture_instance ) ( $ >$ gm"$"? " J/c>$ gm"$ "g ? " J/0$gT L$_in  PH (pYR|>$ g$ )M0-@=M@column_name ) aӊZn>$ g )$)* 6@=*@column_namee_ ) "d\ >$ g $"$"@= " Adv >$g $"$" @= " Adv >$g $"$" h ,`@= " Advt0$gϸ L$p H  @0(>6; >@closed_high_end_point ) ^(>$@ g)$@)MH0-; M@column_list ) i>$@ g ^$@ )*6; *@column_list ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@"  $ќ|@g3 L*CreatProc transactionceure$g  $>$g"#0"X, 0,$FN L L Xfn_cdc_get_max_lsn " ܴ9%F >$g"$"2&$2fn_cdc_get_max_lsne " M@ >$gg6"$"2&$2fn_cdc_get_max_lsne " ^S >$gw?"$" $ " +] v+>$g0<! <e0$ e8create function [sys].[fn_cdc_get_max_lsn]() returns binary(10) as begin declare @ax_lsn binary(10) select @max_lsn = 0x00000000000000000000 select @max_lsn = max(start_lsn) from [cdc].[lsn_time_mapping] return @max_lsn end anc < Qٿet>$g)#-)1 -$ sn_ ) @>a @max_>$gI)$ )ar$[c ) TH>$ g"$" ad $ " ܴ9%Fd >$ g"$ " nd $ " ܴ9%F0$g L$#` (1- hh ) iⳅ>$g)$ ) OR ) P{ ->$ g6)$)Go0-  G@from_lsn ) %$`>$ gg>)$P)$6 $@from_lsn ) 5d% >$>$ g7)$ )C0-  C@to_lsn ) 0Y>$ g )$P)6  @to_lsn ) Al;)>$ g8)$ )W0- W@capture_instance  ) ]$g)$ )4"6 4@capture_instance ) +æ>$go/"$"  " :9W]>$go/"$"   " :9W]>$gaJ$Jsc  J n >$gcJ$J  er J  0$g L$de enh p @  x( (TE VIEW sys.dm_exec_query_stats AS SELECT * FROM OpeRowset (TABLE QUERY_STATS) r0n 8create procedure sys.sp_MSdrop_6x_publication ( @job_id UNIQUEIDENTIFIER ) as begin declare @publisher sysname declare @publisher_db sysname declare @publication sysname declare @retcode int -- -- security check -- only db_owner can execute this -- if (is_member ('db_owner') != 1) begin raiserror(14260, 16, -1) return (1) end -- -- security chm $s|j@g3e L*CreatProc transaction T$g  + >$g1"$@"`0, + FNe Le L `fn_cdc_map_lsn_to_time " >$g%"$":?& + :fn_cdc_map_lsn_totime  " \xd>$ggE"$":f& + :fn_cdc_map_lsn_to_timeo " }9\>$gvj"$"  +  " Ws>$g<"*< 0 +  8create function [sys].[fn_cdc_map_lsn_to_time] ( @lsn binary(10) ) returns datetime with returns null on null input as begin declare @lsn_end_time datetime select @lsn_end_time = tran_end_time from [cdc].[lsn_time_mapping] where start_lsn = @lsn return @lsn_end_time end  < P) end >$g  )# )1re- + ==x_l ) WBU @min_l>$g&)$ )  +   ) ƼĆ2>$ g  )$)=0- +  =@lsndin ) >$ g=)# ))6 + @lsn ) J9u$>$ g1"$" +  " a>$ g1"$ "  +  " >$ g1"$ " >, +  " 0$ge L$ "XxXP8((gm"$ "g ? " J/0$gT L$_in  PH (pYR|>$ g$ )M0-@=M@column_name ) aӊZn>$ g )$)* 6@=*@column_namee_ ) "d\ >$ g $"$"@= " Adv >$g $"$" @= " Adv >$g $"$" h ,`@= " Advt0$gϸ L$p H  @0(>6; >@closed_high_end_point ) ^(>$@ g)$@)MH0-; M@column_list ) i>$@ g ^$@ )*6; *@column_list ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@" _!0$+@g3a L*CreatProc transactionceure$g  >$g*"$x"`, 0,FNa La L `fn_cdc_map_time_to_lsn " C'>$g&"$":$&:fn_cdc_map_time_t_lsn  " 6b>$ggF"$":f&:fn_cdc_map_time_to_lsn " ,L8>$gv"$"   " u>$g(<" <] 0 ]8create function [sys].[fn_cdc_map_time_to_lsn] ( @relational_operator nvarcar(30), @tracking_time datetime ) returns binary(10) with returns null on null input as begin declare @lsn binary(10) select @relational_operator = rtrim(ltrim(lower(@relational_operator))) if (@relational_operator not in (N'largest less than', N'largest less than or equal', N'smallest greater than', N'smallest greater than or equal')) begin return null end set @lsn = null if (@relational_operator = N'largest lss than') begin select @lsn = max(start_lsn) from [cdc].[lsn_time_mapping] where tran_end_time < @tracking_time end else if (@relational_operator = N'largest less than or equal') begin select @lsn = max(start_lsn) from [cdc].[lsn_time_mapping] where tran_end_time <= @tracking_time end else if (@relational_operator = N'smallest greater than') begin select @lsn = min(start_lsn) from [cdc].[lsn_time_mapping] where tran_end_time > @tracking_time end else if @relational_operator = N'smallest greater than or equal') begin select @lsn = min(start_lsn) from [cdc].[lsn_time_mapping] where tran_end_time >= @tracking_time end return @lsn end  < S.q?l>$g)"h$%)1-   ) k>$g )$ ) ) Fݪ>$ g)$)]0-<]@relational_operator ) c>$ g)"0E'):6:@relational_operator ) jqtur>$ g)$ )Q0-==Q@tracking_time9W ) ڊsg@g3a L"SplitPage>>$ g )$Pc @@$g)P$g )    >$g )$\&&&&&&2222222222BBBBBBBBBB0::*(0""""&& $ &""&&&&&&&22.&(("""""400 &08@,&&&&(((6W)&@thresholdUN6>A*&@thresholdar64C:&@thresholdli6N:&@thresholdio6!;&@threshold 6 u<&@thresholdnl6^" 2@threshold_alertmb6a  2@threshold_alertor6 2@threshold_alert--6T 2@threhold_alert f6+ 2@threshold_alertMS6=! 2@threshold_alert 642@threshold_alert',6KQ62@threshold_alert -6i9 2@threshold_alerter6_3= 2@threshold_alertti6^" B@threshold_alert_enableder6a  B@threshold_alert_enabledr_6  B@threshold_lert_enabledre6T B@threshold_alert_enabled, 6+ B@threshold_alert_enabledub6=! B@threshold_alert_enabled e64B@threshold_alert_enabledse6KQ6 B@threshold_alert_enabled @6i9 B@threshold_alert_enabledal6_3= B@threshold_alert_enablednt60@thresholdindex6b?;:@thresholdmetricname s6AY:@thresholdmetricnamepe6H*@throw_errorr 6 (@thumbprint6@time6h@time63w#"@time61@time65@time67 0@time_remaining6."@timeouta_6l"@timeoutat6Q<7"@timeoutti69"@timeoutbo6f &@timestampse6&@timestampph6  @to_lsn6KE @to_lsn6>$@toolpath6il  @topNum6j  @topNum6W8 @topnum6s4@tosetge6Xh'&@total_colss6;N="@toupperre6Q"@traceid6&@tracr_id65%&@tracer_id6-.,&@tracer_id 6-6-&@tracer_id6M!6&@tracer_id6!8&@tracer_id6C;&@tracer_id6U 2@tracer_token_id6|O2@tracer_token_id6(]x.@tracercmdtype6(]x&@tracerstr86$(@tran_artid6Y~<(@tranartid6+%"@tran_idbi66_"@tran_id@r6("@tran_idne6]."@tran_idet6<"@tran_id d6Y~<4@tran_pub_options6R\t0@tran_sub_table6Ya(>0@tran_sub_table6 @tranid6v @tranid6@h% @tranid6]tk1 @tranid6nE:&@tranpubid[f6n0@transaction_id6n8@transaction_status6n@@transactions_processed6q?,@transpublish6&@trig_only) 6w &@trig_only e6m &@trig_onlyd]6Π&@trig_only) 6`ё (@trigger_id6g\4(@trigger_id6 (@trigger_op<$g `)$  Zerro>$g )$ne ges_ra>$g)$@  r change>$gD)" O)(im6W) (@threshold0$ ga L$ or 313>$ g @)$).ch6.@tracking_timeen ) ۩,2 (>$g*"$"n)) no " C', >$g*"$"r o ar " C'fn>$g*"$" 1 ,  " C' 0$ga L$S`!  H(`  x  ` 8((hhtur ) /HRcaptur>$Pg>)"M )seKE,  ) %e'>$PgT)$P)Wap0-KEW@capture_instances ) 9@c>$Pg)$0 )46KE4@capture_instance ) Qz0`ti>$PgU)$P)Gi0-KE G@from_lsn ) 60 .>$Pgg>)"X-)$ 6KE$@from_lsn ) Oƿ#>$PgV)$P)C a0-KE C@to_lsn ) || ">$Pg )#) nu6KE@to_lsn ) Hax>$PgW)$P)Yb_0-KE<Y@row_filter_optioncan ) YKq = db_>$Pg)"0E()6 e6KE6@row_filter_optionon ) )B* d>$PgX)$P)Mno0-KEhhM@net_changes da )  B} a>$PgX=)"L )*tu6KE*@net_changes> ) 'l/a#>$PglB"$P"KE " J:\d>$PglB"$P") KE " J:\0$Pg L$P>#)0)(0('&(&%%x$#8#""x!X h0@0(0-88 G@maxtransr ) 8dte>#gc)#)$ER6$@maxtrans ) ;D) as n>#g)#)GOR0-88 G@maxscansa ) ZtJh @># g[)#)$d 6@maxscans ) (CBtr>#!g)# )K0-hhK@continuous ) bQh>#>#"g )#)(R6(@continuous ) t?4>##g)#")U 0-U@pollinginterval ) T>#$g)#)262@pollingintervala ) 9) as sy>#%g )#$)Isp0-I@retention ) {)I>#&g 2)#)&6&@retent p  _eas (ehoN0$Ʀ@g3Ľ L*CreatProc transaction T$g  P>$g0/"#@ "f0,PFNĽ LĽ L ffn_cdc_has_column_changed" " -n>$g"$"@ &P@fn_cdc_has_coumn_changed " Ww!>$gg;"$"@ &P@fn_cdc_has_column_changed " Ew>$gz"$x"  P" " O >$>$g<#@<%+0P %8create function sys.fn_cdc_has_column_changed ( @capture_instance ysname, @column_name sysname, @update_mask varbinary(128) ) returns bit with returns null on null input as begin declare @ordinal_position int ,@is_bit_set bit ,@change_table nvarchar(1000) if @capture_instance is null or rtrim(@capture_instance) = N'' or @column_name is null or rtrim(@column_name) = N'' or @update_mask is null begin return null end set @change_table = N'[cdc].' + quotename(rtrim(@capture_instance) + N'_CT' if not exists ( select name from sys.columns where object_id = object_id(@change_table) and name = rtrim(@column_name) ) begin return null end select @ordinal_position = [sys].[fn_cdc_get_column_ordinal] (rtrim(@capture_instance) ,@column_name) select @is_bit_set = [sys].[fn_cdc_is_bit_set](@ordinal_position, @update_mask) return @is_bit_set end  < ӽR>$gC1)"HN)1-Phh  ) >$>$g)$ )P" ) 3b>$ gC2)$)W0-PW@capture_instance ) gO>$ g)$ )46P4@capture_instane ) 9J(>$ gC3)$ )Mm0-PM@column_name ) I¥>$ g d)$@ )*d6P*@column_name ) n>$ gC4)$ )M0-PM@update_mask  ) "W'>$g|)$)*6P*@update_mask ) |p>$g0/"$"@lP " -no>$g0/"$" P " -n >$g0/"$"  ,)P " -n0$gŽ L$   ` `@0(st ) 8 t@po>$@ g)$@ )W0-; W@update_flag_list ) Vz^r>$@ gx)$0)46; 4@update_flag_list ) uF!ent>$@ g""$@"c)sl(@*0$oX@g3= L*CreatProc transactionceure$g  _>$gh"# "N, 0,_V = L= L Ndm_cdc_errorsm " Vq%">$gM" p"(&_(dm_cdc_errors " )t>$g<" "(F&_(dm_cdc_errors " id>$gz"$P" _ " `c >$gk<!<d0_ d8CREATE view sys.dm_cdc_errors as SELECT [session_id] ,[phase_number] ,[entry_time] ,[error_number] ,[error_severit] ,[error_state] ,[error_message] ,[start_lsn] ,[begin_lsn] ,[sequence_value] FROM OpenRowset(TABLE DM_CDC_ERRORS)  < >Ect @re>$g!)# )I (0-_88 Isession_idn o ) x@#{'small>$g)N)"Q)&rn6_&session_id@r ) /'l>$ g")$)Mc]0-_88 Mphase_numberf ( ) !no N>$ gX)")* 6_*phase_numberan ) _\km_time >$ g#)$ )I b0-_==Ientry_timewhe ) amacking>$ gI)"U)&n 6_&entry_timen( ) t*c]>$ g$)$ )Met0-_88 Merror_number ) YH2qn>$gS)$ )*6_*error_number> ) 9" >$g%)$)Q 0-_88 Qerror_severity- ) Y拲>$gT)$).)6_.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date-OQf@0-OQf?@type0-OQfC@length0-OQf?@prec 0-OQf88 A@scaleh0-OQfhhG@nullable0-oG@password0-G4Ocache_address0-G44=namen0-G4x4x=type_0-G488 Ktable_level0-G488 Obuckets_count0-G488 ]buckets_in_use_counth0-G488 Ybuckets_min_lengthn0-G488 Ybuckets_max_lengthh0-G4 88 Ybuckets_avg_lengthH0-G4 88 cbuckets_max_length_ever0-G4 Ihits_count0-G4 Mmisses_countm0-G4 88 kbuckets_avg_scan_hit_length0-G488 mbuckets_avg_scan_miss_lengthi0-?88 K@EndpointID0-?hhA@IsSSLN0-??@Host0-?M@QueryString;N0-?I@UserAgent0-dQ@source_schema0-dM@source_name0-88 ?docid0-88 ?colid0-88 ?score0-88 G@clausenox0-88 C@exprno0-A@table@0-Y@expected_rowcount]0-ll Y@expected_checksumr0-44Q@rowcount_only0-A@ownern0-00O@full_or_fast0-hhS@shutdown_agent0-K@table_name0- M@column_list0- Q@filter_clause0-m"44=dbidl0-m"88 Eobjectidg0-m"44Anumber0-m"hhGencrypted0-m"@Iquery_plan0-m"@C@handle0-@I@directory0-@K@scriptfile0-RQ@source_schemag0-RM@source_namec0-RW@capture_instance0-RS@filegroup_name0-h?@namer0-h==?@time0-D44=dbid"0-D88 EobjectidS0-D44Anumber0-DhhGencrypted0-D##4=text, <$g ')$ D$>$g)$ W@c>$g)"0'  >$go)#')rSa e 0$g> L$U>$g')$)O0-_4Oerror_message ) |>$gS)$), 6_,error_message ) v`#$>$g()$)G0-_040Gstart_lsn ) 0z{>$ g^\) Y)$ 6_$start_lsn ) pe_)>$!g))$ )Gr0-_ 040Gbegin_lsn ) 6rs>$"g[)"K)$i6_ $begin_lsn ) PB>$#g*)$")Qhh0-_ 040Qsequence_value  ) )\cT>$$g))$ ).e6_ .sequence_value ) k>$%gh"$" _ " Vq%>$&gh"$&"  _ " Vq%0$g> L$x$#8#)H)(H(''`&%%$##X##"h"x 0 h p8px(G@maxtransr ) 8dte>#gc)#)$ER6$@maxtrans ) ;D) as n>#g)#)GOR0-88 G@maxscansa ) ZtJh @># g[)#)$d 6@maxscans ) (CBtr>#!g)# )K0-hhK@continuous ) bQh>#>#"g )#)(R6(@continuous ) t?4>##g)#")U 0-U@pollinginterval ) T>#$g)#)262@pollingintervala ) 9) as sy>#%g )#$)Isp0-I@retention ) {)I>#&g 2)#)&6&@retent p  0?(y4@"00$#@g3Ͼ L*CreatProc transaction T$g  c>$gm"$ "d0,cV Ͼ LϾ L ddm_cdc_log_scan_sessions " xU;n>$gN"$"> &c>dm_cdc_log_scn_sessionsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q>$g ')$)C0-c 040Cend_lsn ) ch>$g.)$) 6c  end_lsn ) 9e>֬>$g ()$)Inu0-c Itran_count  ) R6 >$g1)+ )&6c &tran_count ) "~>$g ))$)Sa0-c 040Slast_commit_lsn ) zǝcki>$g )"A)0b6c 0last_commit_lsn ) C(Qr>$g *)$)Ue0-c ==Ulast_commit_time! ) _b>$g)$)2f6c 2last_commit_timeu ) iUIing>$g +)$)Ui0-c Ulog_record_countu ) jze>$ gp)!@ )2s6c log_record_counte ) {Drmt>$!g ,)$ )[ 0-c88 [schema_change_count ) ' _10>$"g5)$)8t6c8schema_change_count ) qe |_>$#g -)$")Oe0-cOcommand_count ) skޛ[_>$$gX)"M),6c,command_count ) Aٽ$%g .)$$)[0-c040[first_begin_cdc_lsn ) r,0-s">$&gN)")8_6c8first_bgin_cdc_lsn ) +e =>$'g /)$&)[0-c040[last_commit_cdc_lsn ) G~>$(g )$)8r6c8last_commit_cdc_lsn ) >$)g 0)$()]0-c==]last_commit_cdc_time  ) ki( re>$*g)$)):et6c:last_commit_cdc_timeho ) ,77- >$+g 1)$*)C('0-c88 Clatency  ) d >$,gS)$+)  6c latency ) in>$-g 2)$,)U- 0-c88 Uempty_scan_count -- ) 56[s>$.g)$)2 6c2empty_scan_countrt )  ype)))>$/g 3)$.)_jo0-c88 _failed_sessions_count) ) S^` >$0g9)"E)<va6c<failed_sessions_count ) vIϟ re>$1gm"$"gc " xU;>$2gm"$2"ob _tc " xU;0$gо L$)!0! `H0H@XX p8  X h 8P@0(2 "#" j$  " *wf>#g2 "#"  j$  " *wf0#gӠ L#h#"("! `@pp0(pHX@(urce_schemain ) ahhpo>"Og )"O)de0- ?M@source_namec.k ) 4׬Id >"Og,)"O3)*_i6 ?*@source_name_c ) #;0ject_i>"Og )"O)Wum0- ?W@capture_instance_ ) @IE !>"Og)"O=)4, ?4@capture_instance ) E>Oured_c>"Og""O"d bt  ? " m3/Cnc>"Og""O"our e t ? " m3/Cis0"Ogp L"Olumns 0'&P&%%p$#0#x"`pp( (mn_list] @source_schema ,@source_name ,@captured_column_list if (@retcode != 0) or (@error != 0) begin raiserror(22942, 16, -1, @source_schema, @source_name) return 1 end end else -- If @captured_columns is null, all of the table columns will be tracked begin -- Insert all of the table columns into #captured_columns insert into #captured_columns select name, isnull(type_name(system_type_id), type_name(user_type_id)), is_computed from [sys].[columns] where object_id = @source_object_id order by column_id end -- Verify tht none of the reserved change table metadata columns -- appear as columns to be tracked. if exists ( select top 1 column_name from #captured_columns where lower(column_name) collate database_default in ('__$start_lsn', '__$end_lsn', '__$seqval', '__$operation', '__$update_mask') ) begin raiserror(22975, 16, -1) return 1 end -- Make certain that all of the index columns appear as captured columns if exists ( sele4 c"O DA@g3 LSpaceAlloctn>"Og <"Oc ish@er@"Og<P"Og <ica"Og  0"Og L"Ohh>"Og <"O<A R <4 c"O A@› >"O!g <"O!<Ahct column_name from #index_columns where column_name collate database_default not in ( select column_name collate database_default from #captured_columns ) ) begin raiserror(22943, 16, -1) return 1 end -- Verify that the filegroup if non-null is a valid filegroup if (@filee2 ra 0$1K@g3^ L*CreatProc transactionceure$g  n>$g36"# "`, 0,nP ^ L^ L `sp_MScdccheck_ddladmin " XL7>$g,"#":d&n:sp_MScdccheck_ddldmin " kF >$g&"#":s&n:sp_MScdccheck_ddladmin " Kw>$gv"$" n " zI>$g<",< a0n 8create procedure sys.sp_MScdccheck_ddladmin as begin -- -- Do the sysadmin check fist as it is 4 times more efficient -- than is_member call and reduces performance overhead in case -- the user has sysadmin privileges -- if is_srvrolemember('sysadmin') = 1 or is_member ('db_owner') = 1 or is_member ('db_ddladmin') = 1 begin return (0) end else begin raiserror(22914, 16, -1) return (1) end end N < y%M7>$g36"$"/'ln " XL7">$g36"$" n " XL7b0$g^ L$8(()* 6_*phase_numberan ) _\km_time >$ g#)$ )I b0-_==Ientry_timewhe ) amacking>$ gI)"U)&n 6_&entry_timen( ) t*c]>$ g$)$ )Met0-_88 Merror_number ) YH2qn>$gS)$ )*6_*error_number> ) 9" >$g%)$)Q 0-_88 Qerror_severity- ) Y拲>$gT)$).)6_.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_datera$6:@g3{ L INSERTo>$g6+"xJ;0P m L;sp_MScdc_logddl  U!>$g/"@B+e&+sp_MScdc_logddl  %la'N0$g{ L$>d (c_log_scn_sessionsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q $@g3| L INSERTo>$g\ ,!"HI088  I@source_object_id, "5 pqE >$g*A""H!1"&1@source_object_id "5 S>$g\ -!$? 0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$3@g3| L INVOKEo$g  >$gl,"$P"$mc|l " {N >$gl,"$" e " {Nl0$g| L$( L$>d (c_log_scn_sessionsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$ 0@g3| L INSERTo>$ g"`JA0P[P k LAsp_MScdc_ddl_eventt_  ȕ@7 >$ g/$1&P[1sp_MScdc_ddl_eventt_  r>. 0$ g| L$ ((? 0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$(ם@g3| L INSERTo>$(gf!"h; ;,0P[ ;@EventData  "5 d>$(gZw""hJ#e&P[#@EventData "5 x0$(g| L$( ( (c_log_scn_sessionsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$0!@g3| L INVOKEo$0g  >$0g?""N"$kc|d " b >$0g?"$0"  " b c0$0g| L$0. (g| L$ ((? 0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$8o@g3| L INSERTo>$8gI &"X>G,0P i LGsp_MScdc_db_ddl_event  v\x>$8g/$ 7@&7sp_MScdc_db_ddl_event  K|(0$8g| L$8n_s0(onsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$@)ɣU@g3| L INSERTo>$@g1!" 9;?0 ;@EventData  "5 8;X>$@g\i"" 9#&#@EventData "5 nN> 0$@g| L$@ L (((? 0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$Ho@g3| L INVOKEo$Hg  '7*>$Hg:"$( "$ic|d'7* " i>$Hg:"$H" '7* " ip0$Hg| L$H((0$8g| L$8n_s0(onsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$PÚ@g3} L INSERTo>$Pg5"?E?0P `f LEsp_MScdc_capture_job  H>>$Pg/$85@&5sp_MScdc_capture_job  Knfm@0$Pg} L$P0(0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$XP@g3} L INVOKEo$Xg  +)>$Xg "#P"$`fc}d+) " &(>$Xg "$X" +) " &(p0$Xg} L$X((0$8g| L$8n_s0(onsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$`Q-@g3} L INSERTo>$`g0"JE?0dP ۘ LEsp_MScdc_cleanup_job  @>$`g/ $P5@&d5sp_MScdc_cleanup_job  \-@0$`g} L$`0(0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$hX@g3} L INVOKEo$hg  b>$hg61"#H "$ۘc}db " =1>$hg61"$h" b " =1p0$hg} L$h((0$8g| L$8n_s0(onsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$p=0P@g3ڿ L  INSERTo>$pg4"J=?0NP L=sp_cdc_enable_db_j  0< @>$pg*"(K-&N-sp_cdc_enable_dban  v0$pgڿ L$p`((0(0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$xH@g3ڿ L  INVOKEo$xg  :>$xg  ""8O "$cڿd: " Ej>$xg  "$x" : " Ejp0$xgڿ L$x((0$8g| L$8n_s0(onsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$Dc@g3ڿ L INSERTo>$gcI"(K??0:]P ] L?sp_cdc_disable_dbj  5 @>$g*$p/&:]/sp_cdc_disable_dbn  emdY0$gڿ L$`((0(0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$r@g3ڿ L INVOKEo$g  ƢY$>$gA"#`"$]cڿdƢY$ " vw>$gA"$" ƢY$ " vwp0$gڿ L$((0$8g| L$8n_s0(onsd " *>$g="$"> &c>dm_cdc_log_scan_sessionsd " j>>$gw"$"  c" " N{>$>$g<$<+0c 8CREATE view sys.dm_cdc_log_scan_sessions as SELECT [session_id] ,[stat_time] ,[end_time] ,[duration] ,[scan_phase] ,[error_count] ,[start_lsn] ,[current_lsn] ,[end_lsn] ,[tran_count] ,[last_commit_lsn] ,[last_commit_time] ,[log_record_count] ,[schema_change_count] ,[command_count] ,[first_begin_cdc_lsn] ,[last_commit_cdc_lsn] ,[last_commit_cdc_time] ,[latency] ,[empty_scan_count] ,[failed_sessions_count] FROM OpenRowset(TABLE DM_CDC_LOGSCAN_SESSIONS) sy < 9oNJect_id>$g )"xL)Igi0-c88 Isession_idt_c ) !@captu>$g)P)$%)&dc6c&session_idda ) X賞 @>$ g  )$)I0-c==Istart_time ) FL>$ g^^)$!)&6c&start_time )  )>$ g !)$ )E0-c==Eend_time@c ) Y@a>$ g.)$)"6c"end_timeP ) mtur>$ g ")$ )E0-c88 Eduration ) "|5>$g)$ )"6c"duration) ) H&pP>$g #)$)I0-c4Iscan_phase ) 0*9>$g*)"HM)&6c&scan_phase ) EDK>$g $)$)K0-c88 Kerror_count ) ; >$gU)$)(6c(error_count ) {1>$g %)$)G0-c040Gstart_lsn ) H >$g^])$ )$6c$start_lsn ) Yj7-; >$g &)$)Kl0-c040Kcurrent_lsn ) KN7o>$g)"-)(F6c(current_lsn ) Q$D@g3ڿ L INSERTo>$g1%"JC?0P z LCsp_cdc_enable_table   MW]>$g* $3&3sp_cdc_enable_table   Eۏ0$gڿ L$`((0(0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date* $~Zu@g3ۿ L INSERTo>$guw!">CA0 C@source_schema "5 7Z>$gbA"">+&+@source_schema "5 ^=>$gux!$? ?@source_name "5 c?89>$gbA"$'s&'@source_name "5 3:U@g3ۿ LSplitPage6$g!#P!zc>$g !$c  S>$g !$c io] @ 6$ g P!"@z_lsn] @$ g6c#P&zP$ g !uqd_coun>$ g !$ 519;A?0 5@dbnamepty0 1@typeFRO0hh 9@reserved0 ;@publisher0 A@publisher_db0 ?@publicationu<$g uy!$ f>$gu!$q>  >$gq!!(' u >$gY!"J  g0$gۿ L$c>$guy!$I0 I@capture_instance "5 xLQ>$gbA"$1&1@capture_instancec "5 c=_^m>$guz!$Q0hh Q@supports_net_changesE "5 m&% )>$gbD"$9&9@supports_net_changes) "5 rY>$gu{!$;0 ;@role_namea "5 |*RMח>$gbB"$#&#@role_name "5 At >$gu|!$=0 =@index_nameer "5 ?]Z()>$gbB"$%&%@index_namer "5 %ب| >$gu}!$Q0 Q@captured_column_list  "5 D)%>$gbB"$9&9@captured_column_list> "5 H#&@g3ۿ L#0SplitPageKcu>$g !$ c @@$gP$ g !u >$!gu!$ C _ls>$"g !$u )>$#gY!$ g0$gۿ L$-c>$g !$!E 0 E@filegroup_name "5 )+c >$&gbC"$-&-@filegroup_name "5 {0>$'g !$&U0 hh U@allow_partition_switchb "5 nC _co>$(gbA"$'=*& =@allow_partition_switch "5 q GUla0$gۿ L$b x p8(@@ P ( 8 P@Hx8P`((2last_commit_timeu ) iUIing>$g +)$)Ui0-c Ulog_record_countu ) jze>$ gp)!@ )2s6c log_record_counte ) {Drmt>$!g ,)$ )[ 0-c88 [schema_change_count ) ' _10>$"g5)$)8t6c8schema_change_count ) qe |_>$#g -)$")Oe0-cOcommand_count ) skޛ[_>$$gX)"M),6c,command_count ) Aٽ$%g .)$$)[0-c040[first_begin_cdc_lsn ) r,0-s">$&gN)")8_6c8first_bgin_cdc_lsn ) +e =>$'g /)$&)[0-c040[last_commit_cdc_lsn ) G~>$(g )$)8r6c8last_commit_cdc_lsn ) >$)g 0)$()]0-c==]last_commit_cdc_time  ) ki( re>$*g)$)):et6c:last_commit_cdc_timeho ) ,77- >$+g 1)$*)C('0-c88 Clatency  ) d >$,gS)$+)  6c latency ) in>$-g 2)$,)U- 0-c88 Uempty_scan_count -- ) 56[s>$.g)$)2 6c2empty_scan_countrt )  ype)))>$/g 3)$.)_jo0-c88 _failed_ses0 $y@g3ۿ L$ INVOKEo$g  _* >$g-"$"$zeۿa_*  " :>$g-"$" _*  " :c0$gۿ L$ۏ(gڿ L$`((0(0 ?@ddl_command "5 8s>$g*A"$'&'@ddl_command "5 !JFk">$g\ .!$70 7@ddl_lsna "5 Dn!8>$g*B"$- &@ddl_lsni "5 qt >$g\ /!$9 -0 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$9@g3ۿ L* INSERTo>$g"HJEA0*P p LEsp_cdc_disable_table   Gu>$>$g*$5&*5sp_cdc_disable_table   $ 0$gۿ L$0( ?@source_name "5 c?89>$gbA"$'s&'@source_name "5 3:U@g3ۿ LSplitPage6$g!#P!zc>$g !$c  S>$g !$c io] @ 6$ g P!"@z_lsn] @$ g6c#P&zP$ g !uqd_coun>$ g !$ 519;A?0 5@dbnamepty0 1@typeFRO0hh 9@reserved0 ;@publisher0 A@publisher_db0 ?@publicationu<$g uy!$ f>$gu!$q>  >$gq!!(' u >$gY!"J  g0$gۿ L$c>$guy!$I0 I@capture_instance "5 xLQ>$gbA"$1&1@capture_instancec "5 c=_^m>$guz!$Q0hh Q@supports_net_changesE "5 m&% )>$gbD"$9&9@supports_net_changes) "5 rY>$gu{!$;0 ;@role_namea "5 |*RMח>$gbB"$#&#@role_name "5 At >$gu|!$=0 =@index_nameer "5 ?]Z()>$gbB"$%&%@index_namer "5 %ب| >$gu}!$Q0 Q@captured_column_list  "5 D)%>$gbB"$9&9@captured_column_list> "5 H#&@g3ۿ L#0SplitPageKcu>$g !$ c @@$gP$ g !$@g3ۿ L+ INSERTo>$gOb!"pA C-0* C@source_schema "5 ,\>$gYb""pA +&*+@source_schema "5 щ\>$gOc!$?(* ?@source_name_ "5 Cg>$gYb"$'&*'@source_name_ "5 '@f>$gOd!$I0* I@capture_instance  "5 `|>$gYb"$1- &*1@capture_instance  "5 ܋I)i0$gۿ L$ -8`(( 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date0$<&@g3ۿ L/ INVOKEo$g  ?>$g""O"$pdۿs ? " m3/C>$g"$"  ? " m3/Cp0$gۿ L$(0$gۿ L$0( ?@source_name "5 c?89>$gbA"$'s&'@source_name "5 3:U@g3ۿ LSplitPage6$g!#P!zc>$g !$c  S>$g !$c io] @ 6$ g P!"@z_lsn] @$ g6c#P&zP$ g !uqd_coun>$ g !$ 519;A?0 5@dbnamepty0 1@typeFRO0hh 9@reserved0 ;@publisher0 A@publisher_db0 ?@publicationu<$g uy!$ f>$gu!$q>  >$gq!!(' u >$gY!"J  g0$gۿ L$c>$guy!$I0 I@capture_instance "5 xLQ>$gbA"$1&1@capture_instancec "5 c=_^m>$guz!$Q0hh Q@supports_net_changesE "5 m&% )>$gbD"$9&9@supports_net_changes) "5 rY>$gu{!$;0 ;@role_namea "5 |*RMח>$gbB"$#&#@role_name "5 At >$gu|!$=0 =@index_nameer "5 ?]Z()>$gbB"$%&%@index_namer "5 %ب| >$gu}!$Q0 Q@captured_column_list  "5 D)%>$gbB"$9&9@captured_column_list> "5 H#&@g3ۿ L#0SplitPageKcu>$g !$ c @@$gP$ g !$i_X@h3ۿ L5 INSERTo>$hc'$3-0+HP d L3sp_cdc_scane  >$h*"$#&+H#sp_cdc_scano  ѻӮ 0$hۿ L$c(?(* ?@source_name_ "5 Cg>$gYb"$'&*'@source_name_ "5 '@f>$gOd!$I0* I@capture_instance  "5 `|>$gYb"$1- &*1@capture_instance  "5 ܋I)i0$gۿ L$ -8`(( 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_datex $i@h3ۿ L6 INSERTo>$h^{!"8;90+H88  9@maxtrans  "5 ϱfO>$h[@""8;!&+H!@maxtrans0 "5 ic@h3ۿ L7SplitPag>$h !$c  @?89@$hP$h !^z>$h^!$zp Pag>$hz!" ^> >$ h-!$$+H g 0$hۿ L$ @ >$h !$90+H88  9@maxscans6 "5 R>$ h[@"$!&+H!@maxscansd_ "5 WVeI>$ h !$ =0+H00 =@continuous "5 ʡʀRO0>$h[@"$ %&+H%@continuoushe "5 :S>$h !$G 0+H G@pollinginterval "5 մd>$>$h[C"$/&+H/@pollinginterval "5 7mu>$h $?0+H88  ?@is_from_job "5 MԜic>$h[A"$'&+H'@is_from_job@ "5 +fnce0$hۿ L$ H`8HX (1&1@capture_instancec "5 c=_^m>$guz!$Q0hh Q@supports_net_changesE "5 m&% )>$gbD"$9&9@supports_net_changes) "5 rY>$gu{!$;0 ;@role_namea "5 |*RMח>$gbB"$#&#@role_name "5 At >$gu|!$=0 =@index_nameer "5 ?]Z()>$gbB"$%&%@index_namer "5 %ب| >$gu}!$Q0 Q@captured_column_list  "5 D)%>$gbB"$9&9@captured_column_list> "5 H#&@g3ۿ L#0SplitPageKcu>$g !$ c @@$gP$ g !!e$FQ@h3ۿ L8 INVOKEo$h  o&>$h1 "#"$dsۿao& " 6}>$h1 "$" +Ho& " 6} 0$hܿ L$ L(c(?(* ?@source_name_ "5 Cg>$gYb"$'&*'@source_name_ "5 '@f>$gOd!$I0* I@capture_instance  "5 `|>$gYb"$1- &*1@capture_instance  "5 ܋I)i0$gۿ L$ -8`(( 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date $oz<@h3ܿ L> INSERTo>$hfI"JS0U<P - LSsp_cdc_cleanup_change_tablef  q'q7>$h*$Ct&U<Csp_cdc_cleanup_change_table  h_N۔N0$hܿ L8(!$c  @?89@$hP$h !^z>$h^!$zp Pag>$hz!" ^> >$ h-!$$+H g 0$hۿ L$ @ >$h !$90+H88  9@maxscans6 "5 R>$ h[@"$!&+H!@maxscansd_ "5 WVeI>$ h !$ =0+H00 =@continuous "5 ʡʀRO0>$h[@"$ %&+H%@continuoushe "5 :S>$h !$G 0+H G@pollinginterval "5 մd>$>$h[C"$/&+H/@pollinginterval "5 7mu>$h $?0+H88  ?@is_from_job "5 MԜic>$h[A"$'&+H'@is_from_job@ "5 +fnce0$hۿ L$ H`8HX (1&1@capture_instancec "5 c=_^m>$guz!$Q0hh Q@supports_net_changesE "5 m&% )>$gbD"$9&9@supports_net_changes) "5 rY>$gu{!$;0 ;@role_namea "5 |*RMח>$gbB"$#&#@role_name "5 At >$gu|!$=0 =@index_nameer "5 ?]Z()>$gbB"$%&%@index_namer "5 %ب| >$gu}!$Q0 Q@captured_column_list  "5 D)%>$gbB"$9&9@captured_column_list> "5 H#&@g3ۿ L#0SplitPageKcu>$g !$ c @@$gP$ g !$$@h3ܿ L? INSERTo>$h!!"7I 0U< I@capture_instance} "5 @=>$h_a""@1"&U<1@capture_instance "5 JEo>$h"!$E0U< E@low_water_markg "5 ip>$h_b"$-r&U<-@low_water_mark "5 9fgd>$h#!$; 0U< ;@threshold "5 ".ۭ>$h_c"$#@&U<#@threshold  "5 9$Y0$hܿ L$ -8x0( 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date$uȨ@h3ܿ LA INVOKEo$h  I>$h;"$X"$-cܿeI " f hl>$h;"$" I " f h<0$hܿ L$abl(  h_N۔N0$hܿ L8(!$c  @?89@$hP$h !^z>$h^!$zp Pag>$hz!" ^> >$ h-!$$+H g 0$hۿ L$ @ >$h !$90+H88  9@maxscans6 "5 R>$ h[@"$!&+H!@maxscansd_ "5 WVeI>$ h !$ =0+H00 =@continuous "5 ʡʀRO0>$h[@"$ %&+H%@continuoushe "5 :S>$h !$G 0+H G@pollinginterval "5 մd>$>$h[C"$/&+H/@pollinginterval "5 7mu>$h $?0+H88  ?@is_from_job "5 MԜic>$h[A"$'&+H'@is_from_job@ "5 +fnce0$hۿ L$ H`8HX (1&1@capture_instancec "5 c=_^m>$guz!$Q0hh Q@supports_net_changesE "5 m&% )>$gbD"$9&9@supports_net_changes) "5 rY>$gu{!$;0 ;@role_namea "5 |*RMח>$gbB"$#&#@role_name "5 At >$gu|!$=0 =@index_nameer "5 ?]Z()>$gbB"$%&%@index_namer "5 %ب| >$gu}!$Q0 Q@captured_column_list  "5 D)%>$gbB"$9&9@captured_column_list> "5 H#&@g3ۿ L#0SplitPageKcu>$g !$ c @@$gP$ g !$'c@h3ܿ LG INSERTo>$hc$9 0_XP L9sp_cdc_add_jobin  0ރ>$h*$)&_X)sp_cdc_add_jobur   0$hܿ L$" (E0U< E@low_water_markg "5 ip>$h_b"$-r&U<-@low_water_mark "5 9fgd>$h#!$; 0U< ;@threshold "5 ".ۭ>$h_c"$#@&U<#@threshold  "5 9$Y0$hܿ L$ -8x0( 9@ddl_timesrv "5 [j o>$g*C"$!mi&!@ddl_timen ( "5 ;B- b>$ g\ 0!$=<0 =@commit_lsn "5 -p:/'l>$ g*A"$ %&%@commit_lsn "5 j7b>$ g\ 1!$ I088  I@source_column_idan "5 7e >$ g*E"$ 1 b&1@source_column_idI "5 خ3 >$ g\ 2!$ I0hh I@fis_alter_column "5 C lj:>$g*E"$ 188&1@fis_alter_columnnu "5 v0 >$g\ 3!$E0hh E@fis_drop_table9 "5 .;>$g*F"$-&-@fis_drop_tableve "5 ,jj Y0$g| L$`  8P(p0(.error_severity ) w\>$g&)$)Ko0-_88 Kerror_state ) @0wiO>$gU)$)(_6_error_state ) o@g3> LSplitPage >$g )$c g@@$g)P$g )->$g )$F=GGU=K1?C?AGGO==KO]YYYcIMkmKA?MIQM??GCAYYQAOSKMQ=EAGICIKQMWS??=EAG=0-Sa=name>A0-Sa88 Gobject_id0-Sa88 Gschema_id0-Sa44Uprocedure_numberl0-Sa=typer0-Sa==Kcreate_date