easy_retry_sqlserver.sql 73 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749
  1. -- er_distributed_lock
  2. CREATE TABLE er_distributed_lock
  3. (
  4. id bigint PRIMARY KEY IDENTITY,
  5. name nvarchar(64) NOT NULL,
  6. lock_until datetime2 NOT NULL DEFAULT GETDATE(),
  7. locked_at datetime2 NOT NULL DEFAULT GETDATE(),
  8. locked_by nvarchar(255) NOT NULL,
  9. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  10. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  11. )
  12. GO
  13. CREATE UNIQUE NONCLUSTERED INDEX uk_name ON er_distributed_lock (name ASC)
  14. GO
  15. EXEC sp_addextendedproperty
  16. 'MS_Description', N'主键',
  17. 'SCHEMA', N'dbo',
  18. 'TABLE', N'er_distributed_lock',
  19. 'COLUMN', N'id'
  20. GO
  21. EXEC sp_addextendedproperty
  22. 'MS_Description', N'锁名称',
  23. 'SCHEMA', N'dbo',
  24. 'TABLE', N'er_distributed_lock',
  25. 'COLUMN', N'name'
  26. GO
  27. EXEC sp_addextendedproperty
  28. 'MS_Description', N'锁定时长',
  29. 'SCHEMA', N'dbo',
  30. 'TABLE', N'er_distributed_lock',
  31. 'COLUMN', N'lock_until'
  32. GO
  33. EXEC sp_addextendedproperty
  34. 'MS_Description', N'锁定时间',
  35. 'SCHEMA', N'dbo',
  36. 'TABLE', N'er_distributed_lock',
  37. 'COLUMN', N'locked_at'
  38. GO
  39. EXEC sp_addextendedproperty
  40. 'MS_Description', N'锁定者',
  41. 'SCHEMA', N'dbo',
  42. 'TABLE', N'er_distributed_lock',
  43. 'COLUMN', N'locked_by'
  44. GO
  45. EXEC sp_addextendedproperty
  46. 'MS_Description', N'创建时间',
  47. 'SCHEMA', N'dbo',
  48. 'TABLE', N'er_distributed_lock',
  49. 'COLUMN', N'create_dt'
  50. GO
  51. EXEC sp_addextendedproperty
  52. 'MS_Description', N'修改时间',
  53. 'SCHEMA', N'dbo',
  54. 'TABLE', N'er_distributed_lock',
  55. 'COLUMN', N'update_dt'
  56. GO
  57. EXEC sp_addextendedproperty
  58. 'MS_Description', N'锁定表',
  59. 'SCHEMA', N'dbo',
  60. 'TABLE', N'er_distributed_lock'
  61. GO
  62. -- er_group_config
  63. CREATE TABLE er_group_config
  64. (
  65. id bigint PRIMARY KEY IDENTITY,
  66. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  67. group_name nvarchar(64) NOT NULL DEFAULT '',
  68. description nvarchar(256) NOT NULL DEFAULT '',
  69. token nvarchar(64) NOT NULL DEFAULT 'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT',
  70. group_status tinyint NOT NULL DEFAULT '0',
  71. version int NOT NULL,
  72. group_partition int NOT NULL,
  73. id_generator_mode tinyint NOT NULL DEFAULT '1',
  74. init_scene tinyint NOT NULL DEFAULT '0',
  75. bucket_index int NOT NULL DEFAULT '0',
  76. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  77. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  78. )
  79. GO
  80. CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name ON er_group_config (namespace_id ASC, group_name ASC)
  81. GO
  82. EXEC sp_addextendedproperty
  83. 'MS_Description', N'主键',
  84. 'SCHEMA', N'dbo',
  85. 'TABLE', N'er_group_config',
  86. 'COLUMN', N'id'
  87. GO
  88. EXEC sp_addextendedproperty
  89. 'MS_Description', N'命名空间id',
  90. 'SCHEMA', N'dbo',
  91. 'TABLE', N'er_group_config',
  92. 'COLUMN', N'namespace_id'
  93. GO
  94. EXEC sp_addextendedproperty
  95. 'MS_Description', N'组名称',
  96. 'SCHEMA', N'dbo',
  97. 'TABLE', N'er_group_config',
  98. 'COLUMN', N'group_name'
  99. GO
  100. EXEC sp_addextendedproperty
  101. 'MS_Description', N'组描述',
  102. 'SCHEMA', N'dbo',
  103. 'TABLE', N'er_group_config',
  104. 'COLUMN', N'description'
  105. GO
  106. EXEC sp_addextendedproperty
  107. 'MS_Description', N'token',
  108. 'SCHEMA', N'dbo',
  109. 'TABLE', N'er_group_config',
  110. 'COLUMN', N'token'
  111. GO
  112. EXEC sp_addextendedproperty
  113. 'MS_Description', N'组状态 0、未启用 1、启用',
  114. 'SCHEMA', N'dbo',
  115. 'TABLE', N'er_group_config',
  116. 'COLUMN', N'group_status'
  117. GO
  118. EXEC sp_addextendedproperty
  119. 'MS_Description', N'版本号',
  120. 'SCHEMA', N'dbo',
  121. 'TABLE', N'er_group_config',
  122. 'COLUMN', N'version'
  123. GO
  124. EXEC sp_addextendedproperty
  125. 'MS_Description', N'分区',
  126. 'SCHEMA', N'dbo',
  127. 'TABLE', N'er_group_config',
  128. 'COLUMN', N'group_partition'
  129. GO
  130. EXEC sp_addextendedproperty
  131. 'MS_Description', N'唯一id生成模式 默认号段模式',
  132. 'SCHEMA', N'dbo',
  133. 'TABLE', N'er_group_config',
  134. 'COLUMN', N'id_generator_mode'
  135. GO
  136. EXEC sp_addextendedproperty
  137. 'MS_Description', N'是否初始化场景 0:否 1:是',
  138. 'SCHEMA', N'dbo',
  139. 'TABLE', N'er_group_config',
  140. 'COLUMN', N'init_scene'
  141. GO
  142. EXEC sp_addextendedproperty
  143. 'MS_Description', N'bucket',
  144. 'SCHEMA', N'dbo',
  145. 'TABLE', N'er_group_config',
  146. 'COLUMN', N'bucket_index'
  147. GO
  148. EXEC sp_addextendedproperty
  149. 'MS_Description', N'创建时间',
  150. 'SCHEMA', N'dbo',
  151. 'TABLE', N'er_group_config',
  152. 'COLUMN', N'create_dt'
  153. GO
  154. EXEC sp_addextendedproperty
  155. 'MS_Description', N'修改时间',
  156. 'SCHEMA', N'dbo',
  157. 'TABLE', N'er_group_config',
  158. 'COLUMN', N'update_dt'
  159. GO
  160. EXEC sp_addextendedproperty
  161. 'MS_Description', N'组配置',
  162. 'SCHEMA', N'dbo',
  163. 'TABLE', N'er_group_config'
  164. GO
  165. INSERT INTO er_group_config(namespace_id, group_name, description, token, group_status, version, group_partition, id_generator_mode, init_scene, bucket_index, create_dt, update_dt) VALUES (N'dev', N'ruoyi_group', N'', N'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', N'1', N'1', N'0', N'1', N'1', N'4', getdate(), getdate());
  166. GO
  167. -- er_job
  168. CREATE TABLE er_job
  169. (
  170. id bigint PRIMARY KEY IDENTITY,
  171. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  172. group_name nvarchar(64) NOT NULL,
  173. job_name nvarchar(64) NOT NULL,
  174. args_str nvarchar(max) NULL,
  175. args_type tinyint NOT NULL DEFAULT '1',
  176. next_trigger_at bigint NOT NULL,
  177. job_status tinyint NOT NULL DEFAULT '1',
  178. task_type tinyint NOT NULL DEFAULT '1',
  179. route_key tinyint NOT NULL DEFAULT '4',
  180. executor_type tinyint NOT NULL DEFAULT '1',
  181. executor_info nvarchar(255) NULL DEFAULT '',
  182. trigger_type tinyint NOT NULL,
  183. trigger_interval nvarchar(255) NOT NULL,
  184. block_strategy tinyint NOT NULL DEFAULT '1',
  185. executor_timeout int NOT NULL DEFAULT '0',
  186. max_retry_times int NOT NULL DEFAULT '0',
  187. parallel_num int NOT NULL DEFAULT '1',
  188. retry_interval int NOT NULL DEFAULT '0',
  189. bucket_index int NOT NULL DEFAULT '0',
  190. resident tinyint NOT NULL DEFAULT '0',
  191. description nvarchar(256) NOT NULL DEFAULT '',
  192. ext_attrs nvarchar(256) NULL DEFAULT '',
  193. create_dt datetime2 DEFAULT GETDATE(),
  194. update_dt datetime2 DEFAULT GETDATE(),
  195. deleted BIT NOT NULL DEFAULT 0
  196. )
  197. GO
  198. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job (namespace_id ASC, group_name ASC)
  199. GO
  200. CREATE NONCLUSTERED INDEX idx_job_status_bucket_index ON er_job (job_status ASC, bucket_index ASC)
  201. GO
  202. CREATE NONCLUSTERED INDEX idx_create_dt ON er_job (create_dt ASC)
  203. GO
  204. EXEC sp_addextendedproperty
  205. 'MS_Description', N'主键',
  206. 'SCHEMA', N'dbo',
  207. 'TABLE', N'er_job',
  208. 'COLUMN', N'id'
  209. GO
  210. EXEC sp_addextendedproperty
  211. 'MS_Description', N'命名空间id',
  212. 'SCHEMA', N'dbo',
  213. 'TABLE', N'er_job',
  214. 'COLUMN', N'namespace_id'
  215. GO
  216. EXEC sp_addextendedproperty
  217. 'MS_Description', N'组名称',
  218. 'SCHEMA', N'dbo',
  219. 'TABLE', N'er_job',
  220. 'COLUMN', N'group_name'
  221. GO
  222. EXEC sp_addextendedproperty
  223. 'MS_Description', N'名称',
  224. 'SCHEMA', N'dbo',
  225. 'TABLE', N'er_job',
  226. 'COLUMN', N'job_name'
  227. GO
  228. EXEC sp_addextendedproperty
  229. 'MS_Description', N'执行方法参数',
  230. 'SCHEMA', N'dbo',
  231. 'TABLE', N'er_job',
  232. 'COLUMN', N'args_str'
  233. GO
  234. EXEC sp_addextendedproperty
  235. 'MS_Description', N'参数类型 ',
  236. 'SCHEMA', N'dbo',
  237. 'TABLE', N'er_job',
  238. 'COLUMN', N'args_type'
  239. GO
  240. EXEC sp_addextendedproperty
  241. 'MS_Description', N'下次触发时间',
  242. 'SCHEMA', N'dbo',
  243. 'TABLE', N'er_job',
  244. 'COLUMN', N'next_trigger_at'
  245. GO
  246. EXEC sp_addextendedproperty
  247. 'MS_Description', N'任务状态 0、关闭、1、开启',
  248. 'SCHEMA', N'dbo',
  249. 'TABLE', N'er_job',
  250. 'COLUMN', N'job_status'
  251. GO
  252. EXEC sp_addextendedproperty
  253. 'MS_Description', N'任务类型 1、集群 2、广播 3、切片',
  254. 'SCHEMA', N'dbo',
  255. 'TABLE', N'er_job',
  256. 'COLUMN', N'task_type'
  257. GO
  258. EXEC sp_addextendedproperty
  259. 'MS_Description', N'路由策略',
  260. 'SCHEMA', N'dbo',
  261. 'TABLE', N'er_job',
  262. 'COLUMN', N'route_key'
  263. GO
  264. EXEC sp_addextendedproperty
  265. 'MS_Description', N'执行器类型',
  266. 'SCHEMA', N'dbo',
  267. 'TABLE', N'er_job',
  268. 'COLUMN', N'executor_type'
  269. GO
  270. EXEC sp_addextendedproperty
  271. 'MS_Description', N'执行器名称',
  272. 'SCHEMA', N'dbo',
  273. 'TABLE', N'er_job',
  274. 'COLUMN', N'executor_info'
  275. GO
  276. EXEC sp_addextendedproperty
  277. 'MS_Description', N'触发类型 1.CRON 表达式 2. 固定时间',
  278. 'SCHEMA', N'dbo',
  279. 'TABLE', N'er_job',
  280. 'COLUMN', N'trigger_type'
  281. GO
  282. EXEC sp_addextendedproperty
  283. 'MS_Description', N'间隔时长',
  284. 'SCHEMA', N'dbo',
  285. 'TABLE', N'er_job',
  286. 'COLUMN', N'trigger_interval'
  287. GO
  288. EXEC sp_addextendedproperty
  289. 'MS_Description', N'阻塞策略 1、丢弃 2、覆盖 3、并行',
  290. 'SCHEMA', N'dbo',
  291. 'TABLE', N'er_job',
  292. 'COLUMN', N'block_strategy'
  293. GO
  294. EXEC sp_addextendedproperty
  295. 'MS_Description', N'任务执行超时时间,单位秒',
  296. 'SCHEMA', N'dbo',
  297. 'TABLE', N'er_job',
  298. 'COLUMN', N'executor_timeout'
  299. GO
  300. EXEC sp_addextendedproperty
  301. 'MS_Description', N'最大重试次数',
  302. 'SCHEMA', N'dbo',
  303. 'TABLE', N'er_job',
  304. 'COLUMN', N'max_retry_times'
  305. GO
  306. EXEC sp_addextendedproperty
  307. 'MS_Description', N'并行数',
  308. 'SCHEMA', N'dbo',
  309. 'TABLE', N'er_job',
  310. 'COLUMN', N'parallel_num'
  311. GO
  312. EXEC sp_addextendedproperty
  313. 'MS_Description', N'重试间隔(s)',
  314. 'SCHEMA', N'dbo',
  315. 'TABLE', N'er_job',
  316. 'COLUMN', N'retry_interval'
  317. GO
  318. EXEC sp_addextendedproperty
  319. 'MS_Description', N'bucket',
  320. 'SCHEMA', N'dbo',
  321. 'TABLE', N'er_job',
  322. 'COLUMN', N'bucket_index'
  323. GO
  324. EXEC sp_addextendedproperty
  325. 'MS_Description', N'是否是常驻任务',
  326. 'SCHEMA', N'dbo',
  327. 'TABLE', N'er_job',
  328. 'COLUMN', N'resident'
  329. GO
  330. EXEC sp_addextendedproperty
  331. 'MS_Description', N'描述',
  332. 'SCHEMA', N'dbo',
  333. 'TABLE', N'er_job',
  334. 'COLUMN', N'description'
  335. GO
  336. EXEC sp_addextendedproperty
  337. 'MS_Description', N'扩展字段',
  338. 'SCHEMA', N'dbo',
  339. 'TABLE', N'er_job',
  340. 'COLUMN', N'ext_attrs'
  341. GO
  342. EXEC sp_addextendedproperty
  343. 'MS_Description', N'创建时间',
  344. 'SCHEMA', N'dbo',
  345. 'TABLE', N'er_job',
  346. 'COLUMN', N'create_dt'
  347. GO
  348. EXEC sp_addextendedproperty
  349. 'MS_Description', N'修改时间',
  350. 'SCHEMA', N'dbo',
  351. 'TABLE', N'er_job',
  352. 'COLUMN', N'update_dt'
  353. GO
  354. EXEC sp_addextendedproperty
  355. 'MS_Description', N'逻辑删除 1、删除',
  356. 'SCHEMA', N'dbo',
  357. 'TABLE', N'er_job',
  358. 'COLUMN', N'deleted'
  359. GO
  360. EXEC sp_addextendedproperty
  361. 'MS_Description', N'任务信息',
  362. 'SCHEMA', N'dbo',
  363. 'TABLE', N'er_job'
  364. GO
  365. -- er_job_log_message
  366. CREATE TABLE er_job_log_message
  367. (
  368. id bigint PRIMARY KEY IDENTITY,
  369. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  370. group_name nvarchar(64) NOT NULL,
  371. job_id bigint NOT NULL,
  372. task_batch_id bigint NOT NULL,
  373. task_id bigint NOT NULL,
  374. message nvarchar(max) NOT NULL,
  375. log_num int NOT NULL DEFAULT '1',
  376. real_time bigint NOT NULL DEFAULT '0',
  377. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  378. ext_attrs nvarchar(256) NULL DEFAULT ''
  379. )
  380. GO
  381. CREATE NONCLUSTERED INDEX idx_task_batch_id_task_id ON er_job_log_message (task_batch_id ASC, task_id ASC)
  382. GO
  383. CREATE NONCLUSTERED INDEX idx_create_dt ON er_job_log_message (create_dt ASC)
  384. GO
  385. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job_log_message (namespace_id ASC, group_name ASC)
  386. GO
  387. EXEC sp_addextendedproperty
  388. 'MS_Description', N'主键',
  389. 'SCHEMA', N'dbo',
  390. 'TABLE', N'er_job_log_message',
  391. 'COLUMN', N'id'
  392. GO
  393. EXEC sp_addextendedproperty
  394. 'MS_Description', N'命名空间id',
  395. 'SCHEMA', N'dbo',
  396. 'TABLE', N'er_job_log_message',
  397. 'COLUMN', N'namespace_id'
  398. GO
  399. EXEC sp_addextendedproperty
  400. 'MS_Description', N'组名称',
  401. 'SCHEMA', N'dbo',
  402. 'TABLE', N'er_job_log_message',
  403. 'COLUMN', N'group_name'
  404. GO
  405. EXEC sp_addextendedproperty
  406. 'MS_Description', N'任务信息id',
  407. 'SCHEMA', N'dbo',
  408. 'TABLE', N'er_job_log_message',
  409. 'COLUMN', N'job_id'
  410. GO
  411. EXEC sp_addextendedproperty
  412. 'MS_Description', N'任务批次id',
  413. 'SCHEMA', N'dbo',
  414. 'TABLE', N'er_job_log_message',
  415. 'COLUMN', N'task_batch_id'
  416. GO
  417. EXEC sp_addextendedproperty
  418. 'MS_Description', N'调度任务id',
  419. 'SCHEMA', N'dbo',
  420. 'TABLE', N'er_job_log_message',
  421. 'COLUMN', N'task_id'
  422. GO
  423. EXEC sp_addextendedproperty
  424. 'MS_Description', N'调度信息',
  425. 'SCHEMA', N'dbo',
  426. 'TABLE', N'er_job_log_message',
  427. 'COLUMN', N'message'
  428. GO
  429. EXEC sp_addextendedproperty
  430. 'MS_Description', N'日志数量',
  431. 'SCHEMA', N'dbo',
  432. 'TABLE', N'er_job_log_message',
  433. 'COLUMN', N'log_num'
  434. GO
  435. EXEC sp_addextendedproperty
  436. 'MS_Description', N'上报时间',
  437. 'SCHEMA', N'dbo',
  438. 'TABLE', N'er_job_log_message',
  439. 'COLUMN', N'real_time'
  440. GO
  441. EXEC sp_addextendedproperty
  442. 'MS_Description', N'创建时间',
  443. 'SCHEMA', N'dbo',
  444. 'TABLE', N'er_job_log_message',
  445. 'COLUMN', N'create_dt'
  446. GO
  447. EXEC sp_addextendedproperty
  448. 'MS_Description', N'扩展字段',
  449. 'SCHEMA', N'dbo',
  450. 'TABLE', N'er_job_log_message',
  451. 'COLUMN', N'ext_attrs'
  452. GO
  453. EXEC sp_addextendedproperty
  454. 'MS_Description', N'调度日志',
  455. 'SCHEMA', N'dbo',
  456. 'TABLE', N'er_job_log_message'
  457. GO
  458. -- er_job_notify_config
  459. CREATE TABLE er_job_notify_config
  460. (
  461. id bigint PRIMARY KEY IDENTITY,
  462. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  463. group_name nvarchar(64) NOT NULL,
  464. job_id bigint NOT NULL,
  465. notify_status tinyint NOT NULL DEFAULT '0',
  466. notify_type tinyint NOT NULL DEFAULT '0',
  467. notify_attribute nvarchar(512) NOT NULL,
  468. notify_threshold int NOT NULL DEFAULT '0',
  469. notify_scene tinyint NOT NULL DEFAULT '0',
  470. rate_limiter_status tinyint NOT NULL DEFAULT '0',
  471. rate_limiter_threshold int NOT NULL DEFAULT '0',
  472. description nvarchar(256) NOT NULL DEFAULT '',
  473. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  474. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  475. )
  476. GO
  477. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_job_id ON er_job_notify_config (namespace_id ASC, group_name ASC, job_id ASC)
  478. GO
  479. EXEC sp_addextendedproperty
  480. 'MS_Description', N'主键',
  481. 'SCHEMA', N'dbo',
  482. 'TABLE', N'er_job_notify_config',
  483. 'COLUMN', N'id'
  484. GO
  485. EXEC sp_addextendedproperty
  486. 'MS_Description', N'命名空间id',
  487. 'SCHEMA', N'dbo',
  488. 'TABLE', N'er_job_notify_config',
  489. 'COLUMN', N'namespace_id'
  490. GO
  491. EXEC sp_addextendedproperty
  492. 'MS_Description', N'组名称',
  493. 'SCHEMA', N'dbo',
  494. 'TABLE', N'er_job_notify_config',
  495. 'COLUMN', N'group_name'
  496. GO
  497. EXEC sp_addextendedproperty
  498. 'MS_Description', N'任务id',
  499. 'SCHEMA', N'dbo',
  500. 'TABLE', N'er_job_notify_config',
  501. 'COLUMN', N'job_id'
  502. GO
  503. EXEC sp_addextendedproperty
  504. 'MS_Description', N'通知状态 0、未启用 1、启用',
  505. 'SCHEMA', N'dbo',
  506. 'TABLE', N'er_job_notify_config',
  507. 'COLUMN', N'notify_status'
  508. GO
  509. EXEC sp_addextendedproperty
  510. 'MS_Description', N'通知类型 1、钉钉 2、邮件 3、企业微信',
  511. 'SCHEMA', N'dbo',
  512. 'TABLE', N'er_job_notify_config',
  513. 'COLUMN', N'notify_type'
  514. GO
  515. EXEC sp_addextendedproperty
  516. 'MS_Description', N'配置属性',
  517. 'SCHEMA', N'dbo',
  518. 'TABLE', N'er_job_notify_config',
  519. 'COLUMN', N'notify_attribute'
  520. GO
  521. EXEC sp_addextendedproperty
  522. 'MS_Description', N'通知阈值',
  523. 'SCHEMA', N'dbo',
  524. 'TABLE', N'er_job_notify_config',
  525. 'COLUMN', N'notify_threshold'
  526. GO
  527. EXEC sp_addextendedproperty
  528. 'MS_Description', N'通知场景',
  529. 'SCHEMA', N'dbo',
  530. 'TABLE', N'er_job_notify_config',
  531. 'COLUMN', N'notify_scene'
  532. GO
  533. EXEC sp_addextendedproperty
  534. 'MS_Description', N'限流状态 0、未启用 1、启用',
  535. 'SCHEMA', N'dbo',
  536. 'TABLE', N'er_job_notify_config',
  537. 'COLUMN', N'rate_limiter_status'
  538. GO
  539. EXEC sp_addextendedproperty
  540. 'MS_Description', N'每秒限流阈值',
  541. 'SCHEMA', N'dbo',
  542. 'TABLE', N'er_job_notify_config',
  543. 'COLUMN', N'rate_limiter_threshold'
  544. GO
  545. EXEC sp_addextendedproperty
  546. 'MS_Description', N'描述',
  547. 'SCHEMA', N'dbo',
  548. 'TABLE', N'er_job_notify_config',
  549. 'COLUMN', N'description'
  550. GO
  551. EXEC sp_addextendedproperty
  552. 'MS_Description', N'创建时间',
  553. 'SCHEMA', N'dbo',
  554. 'TABLE', N'er_job_notify_config',
  555. 'COLUMN', N'create_dt'
  556. GO
  557. EXEC sp_addextendedproperty
  558. 'MS_Description', N'修改时间',
  559. 'SCHEMA', N'dbo',
  560. 'TABLE', N'er_job_notify_config',
  561. 'COLUMN', N'update_dt'
  562. GO
  563. EXEC sp_addextendedproperty
  564. 'MS_Description', N'job通知配置',
  565. 'SCHEMA', N'dbo',
  566. 'TABLE', N'er_job_notify_config'
  567. GO
  568. -- er_job_summary
  569. CREATE TABLE er_job_summary
  570. (
  571. id bigint PRIMARY KEY IDENTITY,
  572. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  573. group_name nvarchar(64) NOT NULL,
  574. business_id bigint NOT NULL,
  575. system_task_type tinyint NOT NULL DEFAULT '3',
  576. trigger_at datetime2 NOT NULL,
  577. success_num int NOT NULL DEFAULT '0',
  578. fail_num int NOT NULL DEFAULT '0',
  579. fail_reason nvarchar(512) NOT NULL DEFAULT '',
  580. stop_num int NOT NULL DEFAULT '0',
  581. stop_reason nvarchar(512) NOT NULL DEFAULT '',
  582. cancel_num int NOT NULL DEFAULT '0',
  583. cancel_reason nvarchar(512) NOT NULL DEFAULT '',
  584. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  585. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  586. )
  587. GO
  588. CREATE UNIQUE NONCLUSTERED INDEX uk_trigger_at_system_task_type_business_id ON er_job_summary (trigger_at ASC, system_task_type ASC, business_id ASC)
  589. GO
  590. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_business_id ON er_job_summary (namespace_id ASC, group_name ASC, business_id ASC)
  591. GO
  592. EXEC sp_addextendedproperty
  593. 'MS_Description', N'主键',
  594. 'SCHEMA', N'dbo',
  595. 'TABLE', N'er_job_summary',
  596. 'COLUMN', N'id'
  597. GO
  598. EXEC sp_addextendedproperty
  599. 'MS_Description', N'命名空间id',
  600. 'SCHEMA', N'dbo',
  601. 'TABLE', N'er_job_summary',
  602. 'COLUMN', N'namespace_id'
  603. GO
  604. EXEC sp_addextendedproperty
  605. 'MS_Description', N'组名称',
  606. 'SCHEMA', N'dbo',
  607. 'TABLE', N'er_job_summary',
  608. 'COLUMN', N'group_name'
  609. GO
  610. EXEC sp_addextendedproperty
  611. 'MS_Description', N'业务id (job_id或workflow_id)',
  612. 'SCHEMA', N'dbo',
  613. 'TABLE', N'er_job_summary',
  614. 'COLUMN', N'business_id'
  615. GO
  616. EXEC sp_addextendedproperty
  617. 'MS_Description', N'任务类型 3、JOB任务 4、WORKFLOW任务',
  618. 'SCHEMA', N'dbo',
  619. 'TABLE', N'er_job_summary',
  620. 'COLUMN', N'system_task_type'
  621. GO
  622. EXEC sp_addextendedproperty
  623. 'MS_Description', N'统计时间',
  624. 'SCHEMA', N'dbo',
  625. 'TABLE', N'er_job_summary',
  626. 'COLUMN', N'trigger_at'
  627. GO
  628. EXEC sp_addextendedproperty
  629. 'MS_Description', N'执行成功-日志数量',
  630. 'SCHEMA', N'dbo',
  631. 'TABLE', N'er_job_summary',
  632. 'COLUMN', N'success_num'
  633. GO
  634. EXEC sp_addextendedproperty
  635. 'MS_Description', N'执行失败-日志数量',
  636. 'SCHEMA', N'dbo',
  637. 'TABLE', N'er_job_summary',
  638. 'COLUMN', N'fail_num'
  639. GO
  640. EXEC sp_addextendedproperty
  641. 'MS_Description', N'失败原因',
  642. 'SCHEMA', N'dbo',
  643. 'TABLE', N'er_job_summary',
  644. 'COLUMN', N'fail_reason'
  645. GO
  646. EXEC sp_addextendedproperty
  647. 'MS_Description', N'执行失败-日志数量',
  648. 'SCHEMA', N'dbo',
  649. 'TABLE', N'er_job_summary',
  650. 'COLUMN', N'stop_num'
  651. GO
  652. EXEC sp_addextendedproperty
  653. 'MS_Description', N'失败原因',
  654. 'SCHEMA', N'dbo',
  655. 'TABLE', N'er_job_summary',
  656. 'COLUMN', N'stop_reason'
  657. GO
  658. EXEC sp_addextendedproperty
  659. 'MS_Description', N'执行失败-日志数量',
  660. 'SCHEMA', N'dbo',
  661. 'TABLE', N'er_job_summary',
  662. 'COLUMN', N'cancel_num'
  663. GO
  664. EXEC sp_addextendedproperty
  665. 'MS_Description', N'失败原因',
  666. 'SCHEMA', N'dbo',
  667. 'TABLE', N'er_job_summary',
  668. 'COLUMN', N'cancel_reason'
  669. GO
  670. EXEC sp_addextendedproperty
  671. 'MS_Description', N'创建时间',
  672. 'SCHEMA', N'dbo',
  673. 'TABLE', N'er_job_summary',
  674. 'COLUMN', N'create_dt'
  675. GO
  676. EXEC sp_addextendedproperty
  677. 'MS_Description', N'修改时间',
  678. 'SCHEMA', N'dbo',
  679. 'TABLE', N'er_job_summary',
  680. 'COLUMN', N'update_dt'
  681. GO
  682. EXEC sp_addextendedproperty
  683. 'MS_Description', N'DashBoard_Job',
  684. 'SCHEMA', N'dbo',
  685. 'TABLE', N'er_job_summary'
  686. GO
  687. -- er_job_task
  688. CREATE TABLE er_job_task
  689. (
  690. id bigint PRIMARY KEY IDENTITY,
  691. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  692. group_name nvarchar(64) NOT NULL,
  693. job_id bigint NOT NULL,
  694. task_batch_id bigint NOT NULL,
  695. parent_id bigint NOT NULL DEFAULT '0',
  696. task_status tinyint NOT NULL DEFAULT '0',
  697. retry_count int NOT NULL DEFAULT '0',
  698. client_info nvarchar(128) NULL,
  699. result_message nvarchar(max) NOT NULL,
  700. args_str nvarchar(max) NULL,
  701. args_type tinyint NOT NULL DEFAULT '1',
  702. ext_attrs nvarchar(256) NULL DEFAULT '',
  703. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  704. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  705. )
  706. GO
  707. CREATE NONCLUSTERED INDEX idx_task_batch_id_task_status ON er_job_task (task_batch_id ASC, task_status ASC)
  708. GO
  709. CREATE NONCLUSTERED INDEX idx_create_dt ON er_job_task (create_dt ASC)
  710. GO
  711. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job_task (namespace_id ASC, group_name ASC)
  712. GO
  713. EXEC sp_addextendedproperty
  714. 'MS_Description', N'主键',
  715. 'SCHEMA', N'dbo',
  716. 'TABLE', N'er_job_task',
  717. 'COLUMN', N'id'
  718. GO
  719. EXEC sp_addextendedproperty
  720. 'MS_Description', N'命名空间id',
  721. 'SCHEMA', N'dbo',
  722. 'TABLE', N'er_job_task',
  723. 'COLUMN', N'namespace_id'
  724. GO
  725. EXEC sp_addextendedproperty
  726. 'MS_Description', N'组名称',
  727. 'SCHEMA', N'dbo',
  728. 'TABLE', N'er_job_task',
  729. 'COLUMN', N'group_name'
  730. GO
  731. EXEC sp_addextendedproperty
  732. 'MS_Description', N'任务信息id',
  733. 'SCHEMA', N'dbo',
  734. 'TABLE', N'er_job_task',
  735. 'COLUMN', N'job_id'
  736. GO
  737. EXEC sp_addextendedproperty
  738. 'MS_Description', N'调度任务id',
  739. 'SCHEMA', N'dbo',
  740. 'TABLE', N'er_job_task',
  741. 'COLUMN', N'task_batch_id'
  742. GO
  743. EXEC sp_addextendedproperty
  744. 'MS_Description', N'父执行器id',
  745. 'SCHEMA', N'dbo',
  746. 'TABLE', N'er_job_task',
  747. 'COLUMN', N'parent_id'
  748. GO
  749. EXEC sp_addextendedproperty
  750. 'MS_Description', N'执行的状态 0、失败 1、成功',
  751. 'SCHEMA', N'dbo',
  752. 'TABLE', N'er_job_task',
  753. 'COLUMN', N'task_status'
  754. GO
  755. EXEC sp_addextendedproperty
  756. 'MS_Description', N'重试次数',
  757. 'SCHEMA', N'dbo',
  758. 'TABLE', N'er_job_task',
  759. 'COLUMN', N'retry_count'
  760. GO
  761. EXEC sp_addextendedproperty
  762. 'MS_Description', N'客户端地址 clientId#ip:port',
  763. 'SCHEMA', N'dbo',
  764. 'TABLE', N'er_job_task',
  765. 'COLUMN', N'client_info'
  766. GO
  767. EXEC sp_addextendedproperty
  768. 'MS_Description', N'执行结果',
  769. 'SCHEMA', N'dbo',
  770. 'TABLE', N'er_job_task',
  771. 'COLUMN', N'result_message'
  772. GO
  773. EXEC sp_addextendedproperty
  774. 'MS_Description', N'执行方法参数',
  775. 'SCHEMA', N'dbo',
  776. 'TABLE', N'er_job_task',
  777. 'COLUMN', N'args_str'
  778. GO
  779. EXEC sp_addextendedproperty
  780. 'MS_Description', N'参数类型 ',
  781. 'SCHEMA', N'dbo',
  782. 'TABLE', N'er_job_task',
  783. 'COLUMN', N'args_type'
  784. GO
  785. EXEC sp_addextendedproperty
  786. 'MS_Description', N'扩展字段',
  787. 'SCHEMA', N'dbo',
  788. 'TABLE', N'er_job_task',
  789. 'COLUMN', N'ext_attrs'
  790. GO
  791. EXEC sp_addextendedproperty
  792. 'MS_Description', N'创建时间',
  793. 'SCHEMA', N'dbo',
  794. 'TABLE', N'er_job_task',
  795. 'COLUMN', N'create_dt'
  796. GO
  797. EXEC sp_addextendedproperty
  798. 'MS_Description', N'修改时间',
  799. 'SCHEMA', N'dbo',
  800. 'TABLE', N'er_job_task',
  801. 'COLUMN', N'update_dt'
  802. GO
  803. EXEC sp_addextendedproperty
  804. 'MS_Description', N'任务实例',
  805. 'SCHEMA', N'dbo',
  806. 'TABLE', N'er_job_task'
  807. GO
  808. -- er_job_task_batch
  809. CREATE TABLE er_job_task_batch
  810. (
  811. id bigint PRIMARY KEY IDENTITY,
  812. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  813. group_name nvarchar(64) NOT NULL,
  814. job_id bigint NOT NULL,
  815. workflow_node_id bigint NOT NULL DEFAULT '0',
  816. parent_workflow_node_id bigint NOT NULL DEFAULT '0',
  817. workflow_task_batch_id bigint NOT NULL DEFAULT '0',
  818. task_batch_status tinyint NOT NULL DEFAULT '0',
  819. operation_reason tinyint NOT NULL DEFAULT '0',
  820. execution_at bigint NOT NULL DEFAULT '0',
  821. system_task_type tinyint NOT NULL DEFAULT '3',
  822. parent_id nvarchar(64) NOT NULL DEFAULT '',
  823. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  824. update_dt datetime2 NOT NULL DEFAULT GETDATE(),
  825. deleted BIT DEFAULT 0,
  826. ext_attrs nvarchar(256) NULL DEFAULT ''
  827. )
  828. GO
  829. CREATE NONCLUSTERED INDEX idx_job_id_task_batch_status ON er_job_task_batch (job_id ASC, task_batch_status ASC)
  830. GO
  831. CREATE NONCLUSTERED INDEX idx_create_dt ON er_job_task_batch (create_dt ASC)
  832. GO
  833. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job_task_batch (namespace_id ASC, group_name ASC)
  834. GO
  835. CREATE NONCLUSTERED INDEX idx_workflow_task_batch_id_workflow_node_id ON er_job_task_batch (workflow_task_batch_id ASC, workflow_node_id ASC)
  836. GO
  837. EXEC sp_addextendedproperty
  838. 'MS_Description', N'主键',
  839. 'SCHEMA', N'dbo',
  840. 'TABLE', N'er_job_task_batch',
  841. 'COLUMN', N'id'
  842. GO
  843. EXEC sp_addextendedproperty
  844. 'MS_Description', N'命名空间id',
  845. 'SCHEMA', N'dbo',
  846. 'TABLE', N'er_job_task_batch',
  847. 'COLUMN', N'namespace_id'
  848. GO
  849. EXEC sp_addextendedproperty
  850. 'MS_Description', N'组名称',
  851. 'SCHEMA', N'dbo',
  852. 'TABLE', N'er_job_task_batch',
  853. 'COLUMN', N'group_name'
  854. GO
  855. EXEC sp_addextendedproperty
  856. 'MS_Description', N'任务id',
  857. 'SCHEMA', N'dbo',
  858. 'TABLE', N'er_job_task_batch',
  859. 'COLUMN', N'job_id'
  860. GO
  861. EXEC sp_addextendedproperty
  862. 'MS_Description', N'工作流节点id',
  863. 'SCHEMA', N'dbo',
  864. 'TABLE', N'er_job_task_batch',
  865. 'COLUMN', N'workflow_node_id'
  866. GO
  867. EXEC sp_addextendedproperty
  868. 'MS_Description', N'工作流任务父批次id',
  869. 'SCHEMA', N'dbo',
  870. 'TABLE', N'er_job_task_batch',
  871. 'COLUMN', N'parent_workflow_node_id'
  872. GO
  873. EXEC sp_addextendedproperty
  874. 'MS_Description', N'工作流任务批次id',
  875. 'SCHEMA', N'dbo',
  876. 'TABLE', N'er_job_task_batch',
  877. 'COLUMN', N'workflow_task_batch_id'
  878. GO
  879. EXEC sp_addextendedproperty
  880. 'MS_Description', N'任务批次状态 0、失败 1、成功',
  881. 'SCHEMA', N'dbo',
  882. 'TABLE', N'er_job_task_batch',
  883. 'COLUMN', N'task_batch_status'
  884. GO
  885. EXEC sp_addextendedproperty
  886. 'MS_Description', N'操作原因',
  887. 'SCHEMA', N'dbo',
  888. 'TABLE', N'er_job_task_batch',
  889. 'COLUMN', N'operation_reason'
  890. GO
  891. EXEC sp_addextendedproperty
  892. 'MS_Description', N'任务执行时间',
  893. 'SCHEMA', N'dbo',
  894. 'TABLE', N'er_job_task_batch',
  895. 'COLUMN', N'execution_at'
  896. GO
  897. EXEC sp_addextendedproperty
  898. 'MS_Description', N'任务类型 3、JOB任务 4、WORKFLOW任务',
  899. 'SCHEMA', N'dbo',
  900. 'TABLE', N'er_job_task_batch',
  901. 'COLUMN', N'system_task_type'
  902. GO
  903. EXEC sp_addextendedproperty
  904. 'MS_Description', N'父节点',
  905. 'SCHEMA', N'dbo',
  906. 'TABLE', N'er_job_task_batch',
  907. 'COLUMN', N'parent_id'
  908. GO
  909. EXEC sp_addextendedproperty
  910. 'MS_Description', N'创建时间',
  911. 'SCHEMA', N'dbo',
  912. 'TABLE', N'er_job_task_batch',
  913. 'COLUMN', N'create_dt'
  914. GO
  915. EXEC sp_addextendedproperty
  916. 'MS_Description', N'修改时间',
  917. 'SCHEMA', N'dbo',
  918. 'TABLE', N'er_job_task_batch',
  919. 'COLUMN', N'update_dt'
  920. GO
  921. EXEC sp_addextendedproperty
  922. 'MS_Description', N'逻辑删除 1、删除',
  923. 'SCHEMA', N'dbo',
  924. 'TABLE', N'er_job_task_batch',
  925. 'COLUMN', N'deleted'
  926. GO
  927. EXEC sp_addextendedproperty
  928. 'MS_Description', N'扩展字段',
  929. 'SCHEMA', N'dbo',
  930. 'TABLE', N'er_job_task_batch',
  931. 'COLUMN', N'ext_attrs'
  932. GO
  933. EXEC sp_addextendedproperty
  934. 'MS_Description', N'任务批次',
  935. 'SCHEMA', N'dbo',
  936. 'TABLE', N'er_job_task_batch'
  937. GO
  938. -- er_namespace
  939. CREATE TABLE er_namespace
  940. (
  941. id bigint PRIMARY KEY IDENTITY,
  942. name nvarchar(64) NOT NULL,
  943. unique_id nvarchar(64) NOT NULL,
  944. description nvarchar(256) NOT NULL DEFAULT '',
  945. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  946. update_dt datetime2 NOT NULL DEFAULT GETDATE(),
  947. deleted BIT NOT NULL DEFAULT 0
  948. )
  949. GO
  950. CREATE UNIQUE NONCLUSTERED INDEX uk_unique_id ON er_namespace (unique_id ASC)
  951. GO
  952. CREATE NONCLUSTERED INDEX idx_name ON er_namespace (name ASC)
  953. GO
  954. EXEC sp_addextendedproperty
  955. 'MS_Description', N'主键',
  956. 'SCHEMA', N'dbo',
  957. 'TABLE', N'er_namespace',
  958. 'COLUMN', N'id'
  959. GO
  960. EXEC sp_addextendedproperty
  961. 'MS_Description', N'名称',
  962. 'SCHEMA', N'dbo',
  963. 'TABLE', N'er_namespace',
  964. 'COLUMN', N'name'
  965. GO
  966. EXEC sp_addextendedproperty
  967. 'MS_Description', N'唯一id',
  968. 'SCHEMA', N'dbo',
  969. 'TABLE', N'er_namespace',
  970. 'COLUMN', N'unique_id'
  971. GO
  972. EXEC sp_addextendedproperty
  973. 'MS_Description', N'描述',
  974. 'SCHEMA', N'dbo',
  975. 'TABLE', N'er_namespace',
  976. 'COLUMN', N'description'
  977. GO
  978. EXEC sp_addextendedproperty
  979. 'MS_Description', N'创建时间',
  980. 'SCHEMA', N'dbo',
  981. 'TABLE', N'er_namespace',
  982. 'COLUMN', N'create_dt'
  983. GO
  984. EXEC sp_addextendedproperty
  985. 'MS_Description', N'修改时间',
  986. 'SCHEMA', N'dbo',
  987. 'TABLE', N'er_namespace',
  988. 'COLUMN', N'update_dt'
  989. GO
  990. EXEC sp_addextendedproperty
  991. 'MS_Description', N'逻辑删除 1、删除',
  992. 'SCHEMA', N'dbo',
  993. 'TABLE', N'er_namespace',
  994. 'COLUMN', N'deleted'
  995. GO
  996. EXEC sp_addextendedproperty
  997. 'MS_Description', N'命名空间',
  998. 'SCHEMA', N'dbo',
  999. 'TABLE', N'er_namespace'
  1000. GO
  1001. INSERT INTO er_namespace(name, unique_id, description, create_dt, update_dt, deleted) VALUES (N'Development', N'dev', N'', getdate(), getdate(), N'0');
  1002. INSERT INTO er_namespace(name, unique_id, description, create_dt, update_dt, deleted) VALUES (N'Production', N'prod', N'', getdate(), getdate(), N'0');
  1003. GO
  1004. -- er_notify_config
  1005. CREATE TABLE er_notify_config
  1006. (
  1007. id bigint PRIMARY KEY IDENTITY,
  1008. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1009. group_name nvarchar(64) NOT NULL,
  1010. scene_name nvarchar(64) NOT NULL,
  1011. notify_status tinyint NOT NULL DEFAULT '0',
  1012. notify_type tinyint NOT NULL DEFAULT '0',
  1013. notify_attribute nvarchar(512) NOT NULL,
  1014. notify_threshold int NOT NULL DEFAULT '0',
  1015. notify_scene tinyint NOT NULL DEFAULT '0',
  1016. rate_limiter_status tinyint NOT NULL DEFAULT '0',
  1017. rate_limiter_threshold int NOT NULL DEFAULT '0',
  1018. description nvarchar(256) NOT NULL DEFAULT '',
  1019. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1020. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1021. )
  1022. GO
  1023. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_notify_config (namespace_id ASC, group_name ASC, scene_name ASC)
  1024. GO
  1025. EXEC sp_addextendedproperty
  1026. 'MS_Description', N'主键',
  1027. 'SCHEMA', N'dbo',
  1028. 'TABLE', N'er_notify_config',
  1029. 'COLUMN', N'id'
  1030. GO
  1031. EXEC sp_addextendedproperty
  1032. 'MS_Description', N'命名空间id',
  1033. 'SCHEMA', N'dbo',
  1034. 'TABLE', N'er_notify_config',
  1035. 'COLUMN', N'namespace_id'
  1036. GO
  1037. EXEC sp_addextendedproperty
  1038. 'MS_Description', N'组名称',
  1039. 'SCHEMA', N'dbo',
  1040. 'TABLE', N'er_notify_config',
  1041. 'COLUMN', N'group_name'
  1042. GO
  1043. EXEC sp_addextendedproperty
  1044. 'MS_Description', N'场景名称',
  1045. 'SCHEMA', N'dbo',
  1046. 'TABLE', N'er_notify_config',
  1047. 'COLUMN', N'scene_name'
  1048. GO
  1049. EXEC sp_addextendedproperty
  1050. 'MS_Description', N'通知状态 0、未启用 1、启用',
  1051. 'SCHEMA', N'dbo',
  1052. 'TABLE', N'er_notify_config',
  1053. 'COLUMN', N'notify_status'
  1054. GO
  1055. EXEC sp_addextendedproperty
  1056. 'MS_Description', N'通知类型 1、钉钉 2、邮件 3、企业微信',
  1057. 'SCHEMA', N'dbo',
  1058. 'TABLE', N'er_notify_config',
  1059. 'COLUMN', N'notify_type'
  1060. GO
  1061. EXEC sp_addextendedproperty
  1062. 'MS_Description', N'配置属性',
  1063. 'SCHEMA', N'dbo',
  1064. 'TABLE', N'er_notify_config',
  1065. 'COLUMN', N'notify_attribute'
  1066. GO
  1067. EXEC sp_addextendedproperty
  1068. 'MS_Description', N'通知阈值',
  1069. 'SCHEMA', N'dbo',
  1070. 'TABLE', N'er_notify_config',
  1071. 'COLUMN', N'notify_threshold'
  1072. GO
  1073. EXEC sp_addextendedproperty
  1074. 'MS_Description', N'通知场景',
  1075. 'SCHEMA', N'dbo',
  1076. 'TABLE', N'er_notify_config',
  1077. 'COLUMN', N'notify_scene'
  1078. GO
  1079. EXEC sp_addextendedproperty
  1080. 'MS_Description', N'限流状态 0、未启用 1、启用',
  1081. 'SCHEMA', N'dbo',
  1082. 'TABLE', N'er_notify_config',
  1083. 'COLUMN', N'rate_limiter_status'
  1084. GO
  1085. EXEC sp_addextendedproperty
  1086. 'MS_Description', N'每秒限流阈值',
  1087. 'SCHEMA', N'dbo',
  1088. 'TABLE', N'er_notify_config',
  1089. 'COLUMN', N'rate_limiter_threshold'
  1090. GO
  1091. EXEC sp_addextendedproperty
  1092. 'MS_Description', N'描述',
  1093. 'SCHEMA', N'dbo',
  1094. 'TABLE', N'er_notify_config',
  1095. 'COLUMN', N'description'
  1096. GO
  1097. EXEC sp_addextendedproperty
  1098. 'MS_Description', N'创建时间',
  1099. 'SCHEMA', N'dbo',
  1100. 'TABLE', N'er_notify_config',
  1101. 'COLUMN', N'create_dt'
  1102. GO
  1103. EXEC sp_addextendedproperty
  1104. 'MS_Description', N'修改时间',
  1105. 'SCHEMA', N'dbo',
  1106. 'TABLE', N'er_notify_config',
  1107. 'COLUMN', N'update_dt'
  1108. GO
  1109. EXEC sp_addextendedproperty
  1110. 'MS_Description', N'通知配置',
  1111. 'SCHEMA', N'dbo',
  1112. 'TABLE', N'er_notify_config'
  1113. GO
  1114. -- er_retry_dead_letter_0
  1115. CREATE TABLE er_retry_dead_letter_0
  1116. (
  1117. id bigint PRIMARY KEY IDENTITY,
  1118. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1119. unique_id nvarchar(64) NOT NULL,
  1120. group_name nvarchar(64) NOT NULL,
  1121. scene_name nvarchar(64) NOT NULL,
  1122. idempotent_id nvarchar(64) NOT NULL,
  1123. biz_no nvarchar(64) NOT NULL DEFAULT '',
  1124. executor_name nvarchar(512) NOT NULL DEFAULT '',
  1125. args_str nvarchar(max) NOT NULL,
  1126. ext_attrs nvarchar(max) NOT NULL,
  1127. task_type tinyint NOT NULL DEFAULT '1',
  1128. create_dt datetime2 NOT NULL DEFAULT GETDATE()
  1129. )
  1130. GO
  1131. CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name_unique_id ON er_retry_dead_letter_0 (namespace_id ASC, group_name ASC, unique_id ASC)
  1132. GO
  1133. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_retry_dead_letter_0 (namespace_id ASC, group_name ASC, scene_name ASC)
  1134. GO
  1135. CREATE NONCLUSTERED INDEX idx_idempotent_id ON er_retry_dead_letter_0 (idempotent_id ASC)
  1136. GO
  1137. CREATE NONCLUSTERED INDEX idx_biz_no ON er_retry_dead_letter_0 (biz_no ASC)
  1138. GO
  1139. CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_dead_letter_0 (create_dt ASC)
  1140. GO
  1141. EXEC sp_addextendedproperty
  1142. 'MS_Description', N'主键',
  1143. 'SCHEMA', N'dbo',
  1144. 'TABLE', N'er_retry_dead_letter_0',
  1145. 'COLUMN', N'id'
  1146. GO
  1147. EXEC sp_addextendedproperty
  1148. 'MS_Description', N'命名空间id',
  1149. 'SCHEMA', N'dbo',
  1150. 'TABLE', N'er_retry_dead_letter_0',
  1151. 'COLUMN', N'namespace_id'
  1152. GO
  1153. EXEC sp_addextendedproperty
  1154. 'MS_Description', N'同组下id唯一',
  1155. 'SCHEMA', N'dbo',
  1156. 'TABLE', N'er_retry_dead_letter_0',
  1157. 'COLUMN', N'unique_id'
  1158. GO
  1159. EXEC sp_addextendedproperty
  1160. 'MS_Description', N'组名称',
  1161. 'SCHEMA', N'dbo',
  1162. 'TABLE', N'er_retry_dead_letter_0',
  1163. 'COLUMN', N'group_name'
  1164. GO
  1165. EXEC sp_addextendedproperty
  1166. 'MS_Description', N'场景名称',
  1167. 'SCHEMA', N'dbo',
  1168. 'TABLE', N'er_retry_dead_letter_0',
  1169. 'COLUMN', N'scene_name'
  1170. GO
  1171. EXEC sp_addextendedproperty
  1172. 'MS_Description', N'幂等id',
  1173. 'SCHEMA', N'dbo',
  1174. 'TABLE', N'er_retry_dead_letter_0',
  1175. 'COLUMN', N'idempotent_id'
  1176. GO
  1177. EXEC sp_addextendedproperty
  1178. 'MS_Description', N'业务编号',
  1179. 'SCHEMA', N'dbo',
  1180. 'TABLE', N'er_retry_dead_letter_0',
  1181. 'COLUMN', N'biz_no'
  1182. GO
  1183. EXEC sp_addextendedproperty
  1184. 'MS_Description', N'执行器名称',
  1185. 'SCHEMA', N'dbo',
  1186. 'TABLE', N'er_retry_dead_letter_0',
  1187. 'COLUMN', N'executor_name'
  1188. GO
  1189. EXEC sp_addextendedproperty
  1190. 'MS_Description', N'执行方法参数',
  1191. 'SCHEMA', N'dbo',
  1192. 'TABLE', N'er_retry_dead_letter_0',
  1193. 'COLUMN', N'args_str'
  1194. GO
  1195. EXEC sp_addextendedproperty
  1196. 'MS_Description', N'扩展字段',
  1197. 'SCHEMA', N'dbo',
  1198. 'TABLE', N'er_retry_dead_letter_0',
  1199. 'COLUMN', N'ext_attrs'
  1200. GO
  1201. EXEC sp_addextendedproperty
  1202. 'MS_Description', N'任务类型 1、重试数据 2、回调数据',
  1203. 'SCHEMA', N'dbo',
  1204. 'TABLE', N'er_retry_dead_letter_0',
  1205. 'COLUMN', N'task_type'
  1206. GO
  1207. EXEC sp_addextendedproperty
  1208. 'MS_Description', N'创建时间',
  1209. 'SCHEMA', N'dbo',
  1210. 'TABLE', N'er_retry_dead_letter_0',
  1211. 'COLUMN', N'create_dt'
  1212. GO
  1213. EXEC sp_addextendedproperty
  1214. 'MS_Description', N'死信队列表',
  1215. 'SCHEMA', N'dbo',
  1216. 'TABLE', N'er_retry_dead_letter_0'
  1217. GO
  1218. -- er_retry_summary
  1219. CREATE TABLE er_retry_summary
  1220. (
  1221. id bigint PRIMARY KEY IDENTITY,
  1222. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1223. group_name nvarchar(64) NOT NULL DEFAULT '',
  1224. scene_name nvarchar(50) NOT NULL DEFAULT '',
  1225. trigger_at datetime2 NOT NULL DEFAULT GETDATE(),
  1226. running_num int NOT NULL DEFAULT '0',
  1227. finish_num int NOT NULL DEFAULT '0',
  1228. max_count_num int NOT NULL DEFAULT '0',
  1229. suspend_num int NOT NULL DEFAULT '0',
  1230. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1231. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1232. )
  1233. GO
  1234. CREATE UNIQUE NONCLUSTERED INDEX uk_scene_name_trigger_at ON er_retry_summary (namespace_id ASC, group_name ASC,
  1235. scene_name ASC, trigger_at ASC)
  1236. GO
  1237. EXEC sp_addextendedproperty
  1238. 'MS_Description', N'主键',
  1239. 'SCHEMA', N'dbo',
  1240. 'TABLE', N'er_retry_summary',
  1241. 'COLUMN', N'id'
  1242. GO
  1243. EXEC sp_addextendedproperty
  1244. 'MS_Description', N'命名空间id',
  1245. 'SCHEMA', N'dbo',
  1246. 'TABLE', N'er_retry_summary',
  1247. 'COLUMN', N'namespace_id'
  1248. GO
  1249. EXEC sp_addextendedproperty
  1250. 'MS_Description', N'组名称',
  1251. 'SCHEMA', N'dbo',
  1252. 'TABLE', N'er_retry_summary',
  1253. 'COLUMN', N'group_name'
  1254. GO
  1255. EXEC sp_addextendedproperty
  1256. 'MS_Description', N'场景名称',
  1257. 'SCHEMA', N'dbo',
  1258. 'TABLE', N'er_retry_summary',
  1259. 'COLUMN', N'scene_name'
  1260. GO
  1261. EXEC sp_addextendedproperty
  1262. 'MS_Description', N'统计时间',
  1263. 'SCHEMA', N'dbo',
  1264. 'TABLE', N'er_retry_summary',
  1265. 'COLUMN', N'trigger_at'
  1266. GO
  1267. EXEC sp_addextendedproperty
  1268. 'MS_Description', N'重试中-日志数量',
  1269. 'SCHEMA', N'dbo',
  1270. 'TABLE', N'er_retry_summary',
  1271. 'COLUMN', N'running_num'
  1272. GO
  1273. EXEC sp_addextendedproperty
  1274. 'MS_Description', N'重试完成-日志数量',
  1275. 'SCHEMA', N'dbo',
  1276. 'TABLE', N'er_retry_summary',
  1277. 'COLUMN', N'finish_num'
  1278. GO
  1279. EXEC sp_addextendedproperty
  1280. 'MS_Description', N'重试到达最大次数-日志数量',
  1281. 'SCHEMA', N'dbo',
  1282. 'TABLE', N'er_retry_summary',
  1283. 'COLUMN', N'max_count_num'
  1284. GO
  1285. EXEC sp_addextendedproperty
  1286. 'MS_Description', N'暂停重试-日志数量',
  1287. 'SCHEMA', N'dbo',
  1288. 'TABLE', N'er_retry_summary',
  1289. 'COLUMN', N'suspend_num'
  1290. GO
  1291. EXEC sp_addextendedproperty
  1292. 'MS_Description', N'创建时间',
  1293. 'SCHEMA', N'dbo',
  1294. 'TABLE', N'er_retry_summary',
  1295. 'COLUMN', N'create_dt'
  1296. GO
  1297. EXEC sp_addextendedproperty
  1298. 'MS_Description', N'修改时间',
  1299. 'SCHEMA', N'dbo',
  1300. 'TABLE', N'er_retry_summary',
  1301. 'COLUMN', N'update_dt'
  1302. GO
  1303. EXEC sp_addextendedproperty
  1304. 'MS_Description', N'DashBoard_Retry',
  1305. 'SCHEMA', N'dbo',
  1306. 'TABLE', N'er_retry_summary'
  1307. GO
  1308. -- er_retry_task_0
  1309. CREATE TABLE er_retry_task_0
  1310. (
  1311. id bigint PRIMARY KEY IDENTITY,
  1312. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1313. unique_id nvarchar(64) NOT NULL,
  1314. group_name nvarchar(64) NOT NULL,
  1315. scene_name nvarchar(64) NOT NULL,
  1316. idempotent_id nvarchar(64) NOT NULL,
  1317. biz_no nvarchar(64) NOT NULL DEFAULT '',
  1318. executor_name nvarchar(512) NOT NULL DEFAULT '',
  1319. args_str nvarchar(max) NOT NULL,
  1320. ext_attrs nvarchar(max) NOT NULL,
  1321. next_trigger_at datetime2 NOT NULL,
  1322. retry_count int NOT NULL DEFAULT '0',
  1323. retry_status tinyint NOT NULL DEFAULT '0',
  1324. task_type tinyint NOT NULL DEFAULT '1',
  1325. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1326. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1327. )
  1328. GO
  1329. CREATE UNIQUE NONCLUSTERED INDEX uk_name_unique_id ON er_retry_task_0 (namespace_id ASC, group_name ASC, unique_id ASC)
  1330. GO
  1331. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_retry_task_0 (namespace_id ASC, group_name ASC, scene_name ASC)
  1332. GO
  1333. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_task_type ON er_retry_task_0 (namespace_id ASC, group_name ASC, task_type ASC)
  1334. GO
  1335. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_retry_status ON er_retry_task_0 (namespace_id ASC, group_name ASC, retry_status ASC)
  1336. GO
  1337. CREATE NONCLUSTERED INDEX idx_idempotent_id ON er_retry_task_0 (idempotent_id ASC)
  1338. GO
  1339. CREATE NONCLUSTERED INDEX idx_biz_no ON er_retry_task_0 (biz_no ASC)
  1340. GO
  1341. CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_task_0 (create_dt ASC)
  1342. GO
  1343. EXEC sp_addextendedproperty
  1344. 'MS_Description', N'主键',
  1345. 'SCHEMA', N'dbo',
  1346. 'TABLE', N'er_retry_task_0',
  1347. 'COLUMN', N'id'
  1348. GO
  1349. EXEC sp_addextendedproperty
  1350. 'MS_Description', N'命名空间id',
  1351. 'SCHEMA', N'dbo',
  1352. 'TABLE', N'er_retry_task_0',
  1353. 'COLUMN', N'namespace_id'
  1354. GO
  1355. EXEC sp_addextendedproperty
  1356. 'MS_Description', N'同组下id唯一',
  1357. 'SCHEMA', N'dbo',
  1358. 'TABLE', N'er_retry_task_0',
  1359. 'COLUMN', N'unique_id'
  1360. GO
  1361. EXEC sp_addextendedproperty
  1362. 'MS_Description', N'组名称',
  1363. 'SCHEMA', N'dbo',
  1364. 'TABLE', N'er_retry_task_0',
  1365. 'COLUMN', N'group_name'
  1366. GO
  1367. EXEC sp_addextendedproperty
  1368. 'MS_Description', N'场景名称',
  1369. 'SCHEMA', N'dbo',
  1370. 'TABLE', N'er_retry_task_0',
  1371. 'COLUMN', N'scene_name'
  1372. GO
  1373. EXEC sp_addextendedproperty
  1374. 'MS_Description', N'幂等id',
  1375. 'SCHEMA', N'dbo',
  1376. 'TABLE', N'er_retry_task_0',
  1377. 'COLUMN', N'idempotent_id'
  1378. GO
  1379. EXEC sp_addextendedproperty
  1380. 'MS_Description', N'业务编号',
  1381. 'SCHEMA', N'dbo',
  1382. 'TABLE', N'er_retry_task_0',
  1383. 'COLUMN', N'biz_no'
  1384. GO
  1385. EXEC sp_addextendedproperty
  1386. 'MS_Description', N'执行器名称',
  1387. 'SCHEMA', N'dbo',
  1388. 'TABLE', N'er_retry_task_0',
  1389. 'COLUMN', N'executor_name'
  1390. GO
  1391. EXEC sp_addextendedproperty
  1392. 'MS_Description', N'执行方法参数',
  1393. 'SCHEMA', N'dbo',
  1394. 'TABLE', N'er_retry_task_0',
  1395. 'COLUMN', N'args_str'
  1396. GO
  1397. EXEC sp_addextendedproperty
  1398. 'MS_Description', N'扩展字段',
  1399. 'SCHEMA', N'dbo',
  1400. 'TABLE', N'er_retry_task_0',
  1401. 'COLUMN', N'ext_attrs'
  1402. GO
  1403. EXEC sp_addextendedproperty
  1404. 'MS_Description', N'下次触发时间',
  1405. 'SCHEMA', N'dbo',
  1406. 'TABLE', N'er_retry_task_0',
  1407. 'COLUMN', N'next_trigger_at'
  1408. GO
  1409. EXEC sp_addextendedproperty
  1410. 'MS_Description', N'重试次数',
  1411. 'SCHEMA', N'dbo',
  1412. 'TABLE', N'er_retry_task_0',
  1413. 'COLUMN', N'retry_count'
  1414. GO
  1415. EXEC sp_addextendedproperty
  1416. 'MS_Description', N'重试状态 0、重试中 1、成功 2、最大重试次数',
  1417. 'SCHEMA', N'dbo',
  1418. 'TABLE', N'er_retry_task_0',
  1419. 'COLUMN', N'retry_status'
  1420. GO
  1421. EXEC sp_addextendedproperty
  1422. 'MS_Description', N'任务类型 1、重试数据 2、回调数据',
  1423. 'SCHEMA', N'dbo',
  1424. 'TABLE', N'er_retry_task_0',
  1425. 'COLUMN', N'task_type'
  1426. GO
  1427. EXEC sp_addextendedproperty
  1428. 'MS_Description', N'创建时间',
  1429. 'SCHEMA', N'dbo',
  1430. 'TABLE', N'er_retry_task_0',
  1431. 'COLUMN', N'create_dt'
  1432. GO
  1433. EXEC sp_addextendedproperty
  1434. 'MS_Description', N'修改时间',
  1435. 'SCHEMA', N'dbo',
  1436. 'TABLE', N'er_retry_task_0',
  1437. 'COLUMN', N'update_dt'
  1438. GO
  1439. EXEC sp_addextendedproperty
  1440. 'MS_Description', N'任务表',
  1441. 'SCHEMA', N'dbo',
  1442. 'TABLE', N'er_retry_task_0'
  1443. GO
  1444. -- er_retry_task_log
  1445. CREATE TABLE er_retry_task_log
  1446. (
  1447. id bigint PRIMARY KEY IDENTITY,
  1448. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1449. unique_id nvarchar(64) NOT NULL,
  1450. group_name nvarchar(64) NOT NULL,
  1451. scene_name nvarchar(64) NOT NULL,
  1452. idempotent_id nvarchar(64) NOT NULL,
  1453. biz_no nvarchar(64) NOT NULL DEFAULT '',
  1454. executor_name nvarchar(512) NOT NULL DEFAULT '',
  1455. args_str nvarchar(max) NOT NULL,
  1456. ext_attrs nvarchar(max) NOT NULL,
  1457. retry_status tinyint NOT NULL DEFAULT '0',
  1458. task_type tinyint NOT NULL DEFAULT '1',
  1459. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1460. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1461. )
  1462. GO
  1463. CREATE NONCLUSTERED INDEX idx_group_name_scene_name ON er_retry_task_log (namespace_id ASC, group_name ASC, scene_name ASC)
  1464. GO
  1465. CREATE NONCLUSTERED INDEX idx_retry_status ON er_retry_task_log (retry_status ASC)
  1466. GO
  1467. CREATE NONCLUSTERED INDEX idx_idempotent_id ON er_retry_task_log (idempotent_id ASC)
  1468. GO
  1469. CREATE NONCLUSTERED INDEX idx_unique_id ON er_retry_task_log (unique_id ASC)
  1470. GO
  1471. CREATE NONCLUSTERED INDEX idx_biz_no ON er_retry_task_log (biz_no ASC)
  1472. GO
  1473. CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_task_log (create_dt ASC)
  1474. GO
  1475. EXEC sp_addextendedproperty
  1476. 'MS_Description', N'主键',
  1477. 'SCHEMA', N'dbo',
  1478. 'TABLE', N'er_retry_task_log',
  1479. 'COLUMN', N'id'
  1480. GO
  1481. EXEC sp_addextendedproperty
  1482. 'MS_Description', N'命名空间id',
  1483. 'SCHEMA', N'dbo',
  1484. 'TABLE', N'er_retry_task_log',
  1485. 'COLUMN', N'namespace_id'
  1486. GO
  1487. EXEC sp_addextendedproperty
  1488. 'MS_Description', N'同组下id唯一',
  1489. 'SCHEMA', N'dbo',
  1490. 'TABLE', N'er_retry_task_log',
  1491. 'COLUMN', N'unique_id'
  1492. GO
  1493. EXEC sp_addextendedproperty
  1494. 'MS_Description', N'组名称',
  1495. 'SCHEMA', N'dbo',
  1496. 'TABLE', N'er_retry_task_log',
  1497. 'COLUMN', N'group_name'
  1498. GO
  1499. EXEC sp_addextendedproperty
  1500. 'MS_Description', N'场景名称',
  1501. 'SCHEMA', N'dbo',
  1502. 'TABLE', N'er_retry_task_log',
  1503. 'COLUMN', N'scene_name'
  1504. GO
  1505. EXEC sp_addextendedproperty
  1506. 'MS_Description', N'幂等id',
  1507. 'SCHEMA', N'dbo',
  1508. 'TABLE', N'er_retry_task_log',
  1509. 'COLUMN', N'idempotent_id'
  1510. GO
  1511. EXEC sp_addextendedproperty
  1512. 'MS_Description', N'业务编号',
  1513. 'SCHEMA', N'dbo',
  1514. 'TABLE', N'er_retry_task_log',
  1515. 'COLUMN', N'biz_no'
  1516. GO
  1517. EXEC sp_addextendedproperty
  1518. 'MS_Description', N'执行器名称',
  1519. 'SCHEMA', N'dbo',
  1520. 'TABLE', N'er_retry_task_log',
  1521. 'COLUMN', N'executor_name'
  1522. GO
  1523. EXEC sp_addextendedproperty
  1524. 'MS_Description', N'执行方法参数',
  1525. 'SCHEMA', N'dbo',
  1526. 'TABLE', N'er_retry_task_log',
  1527. 'COLUMN', N'args_str'
  1528. GO
  1529. EXEC sp_addextendedproperty
  1530. 'MS_Description', N'扩展字段',
  1531. 'SCHEMA', N'dbo',
  1532. 'TABLE', N'er_retry_task_log',
  1533. 'COLUMN', N'ext_attrs'
  1534. GO
  1535. EXEC sp_addextendedproperty
  1536. 'MS_Description', N'重试状态 0、重试中 1、成功 2、最大次数',
  1537. 'SCHEMA', N'dbo',
  1538. 'TABLE', N'er_retry_task_log',
  1539. 'COLUMN', N'retry_status'
  1540. GO
  1541. EXEC sp_addextendedproperty
  1542. 'MS_Description', N'任务类型 1、重试数据 2、回调数据',
  1543. 'SCHEMA', N'dbo',
  1544. 'TABLE', N'er_retry_task_log',
  1545. 'COLUMN', N'task_type'
  1546. GO
  1547. EXEC sp_addextendedproperty
  1548. 'MS_Description', N'创建时间',
  1549. 'SCHEMA', N'dbo',
  1550. 'TABLE', N'er_retry_task_log',
  1551. 'COLUMN', N'create_dt'
  1552. GO
  1553. EXEC sp_addextendedproperty
  1554. 'MS_Description', N'修改时间',
  1555. 'SCHEMA', N'dbo',
  1556. 'TABLE', N'er_retry_task_log',
  1557. 'COLUMN', N'update_dt'
  1558. GO
  1559. EXEC sp_addextendedproperty
  1560. 'MS_Description', N'任务日志基础信息表',
  1561. 'SCHEMA', N'dbo',
  1562. 'TABLE', N'er_retry_task_log'
  1563. GO
  1564. -- er_retry_task_log_message
  1565. CREATE TABLE er_retry_task_log_message
  1566. (
  1567. id bigint PRIMARY KEY IDENTITY,
  1568. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1569. group_name nvarchar(64) NOT NULL,
  1570. unique_id nvarchar(64) NOT NULL,
  1571. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1572. message nvarchar(max) NOT NULL,
  1573. log_num int NOT NULL DEFAULT 1,
  1574. real_time bigint NOT NULL DEFAULT 0
  1575. )
  1576. GO
  1577. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_retry_task_log_message (namespace_id ASC, group_name ASC, unique_id ASC)
  1578. GO
  1579. CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_task_log_message (create_dt ASC)
  1580. GO
  1581. EXEC sp_addextendedproperty
  1582. 'MS_Description', N'主键',
  1583. 'SCHEMA', N'dbo',
  1584. 'TABLE', N'er_retry_task_log_message',
  1585. 'COLUMN', N'id'
  1586. GO
  1587. EXEC sp_addextendedproperty
  1588. 'MS_Description', N'命名空间id',
  1589. 'SCHEMA', N'dbo',
  1590. 'TABLE', N'er_retry_task_log_message',
  1591. 'COLUMN', N'namespace_id'
  1592. GO
  1593. EXEC sp_addextendedproperty
  1594. 'MS_Description', N'组名称',
  1595. 'SCHEMA', N'dbo',
  1596. 'TABLE', N'er_retry_task_log_message',
  1597. 'COLUMN', N'group_name'
  1598. GO
  1599. EXEC sp_addextendedproperty
  1600. 'MS_Description', N'同组下id唯一',
  1601. 'SCHEMA', N'dbo',
  1602. 'TABLE', N'er_retry_task_log_message',
  1603. 'COLUMN', N'unique_id'
  1604. GO
  1605. EXEC sp_addextendedproperty
  1606. 'MS_Description', N'创建时间',
  1607. 'SCHEMA', N'dbo',
  1608. 'TABLE', N'er_retry_task_log_message',
  1609. 'COLUMN', N'create_dt'
  1610. GO
  1611. EXEC sp_addextendedproperty
  1612. 'MS_Description', N'异常信息',
  1613. 'SCHEMA', N'dbo',
  1614. 'TABLE', N'er_retry_task_log_message',
  1615. 'COLUMN', N'message'
  1616. GO
  1617. EXEC sp_addextendedproperty
  1618. 'MS_Description', N'日志数量',
  1619. 'SCHEMA', N'dbo',
  1620. 'TABLE', N'er_retry_task_log_message',
  1621. 'COLUMN', N'log_num'
  1622. GO
  1623. EXEC sp_addextendedproperty
  1624. 'MS_Description', N'上报时间',
  1625. 'SCHEMA', N'dbo',
  1626. 'TABLE', N'er_retry_task_log_message',
  1627. 'COLUMN', N'real_time'
  1628. GO
  1629. EXEC sp_addextendedproperty
  1630. 'MS_Description', N'任务调度日志信息记录表',
  1631. 'SCHEMA', N'dbo',
  1632. 'TABLE', N'er_retry_task_log_message'
  1633. GO
  1634. -- er_scene_config
  1635. CREATE TABLE er_scene_config
  1636. (
  1637. id bigint IDENTITY,
  1638. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1639. scene_name nvarchar(64) NOT NULL,
  1640. group_name nvarchar(64) NOT NULL,
  1641. scene_status tinyint NOT NULL DEFAULT '0',
  1642. max_retry_count int NOT NULL DEFAULT '5',
  1643. back_off tinyint NOT NULL DEFAULT '1',
  1644. trigger_interval nvarchar(16) NOT NULL DEFAULT '',
  1645. deadline_request bigint NOT NULL DEFAULT '60000',
  1646. executor_timeout int NOT NULL DEFAULT '5',
  1647. route_key tinyint NOT NULL DEFAULT '4',
  1648. description nvarchar(256) NOT NULL DEFAULT '',
  1649. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1650. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1651. )
  1652. GO
  1653. CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name_scene_name ON er_scene_config (namespace_id ASC, group_name ASC, scene_name ASC)
  1654. GO
  1655. EXEC sp_addextendedproperty
  1656. 'MS_Description', N'主键',
  1657. 'SCHEMA', N'dbo',
  1658. 'TABLE', N'er_scene_config',
  1659. 'COLUMN', N'id'
  1660. GO
  1661. EXEC sp_addextendedproperty
  1662. 'MS_Description', N'命名空间id',
  1663. 'SCHEMA', N'dbo',
  1664. 'TABLE', N'er_scene_config',
  1665. 'COLUMN', N'namespace_id'
  1666. GO
  1667. EXEC sp_addextendedproperty
  1668. 'MS_Description', N'场景名称',
  1669. 'SCHEMA', N'dbo',
  1670. 'TABLE', N'er_scene_config',
  1671. 'COLUMN', N'scene_name'
  1672. GO
  1673. EXEC sp_addextendedproperty
  1674. 'MS_Description', N'组名称',
  1675. 'SCHEMA', N'dbo',
  1676. 'TABLE', N'er_scene_config',
  1677. 'COLUMN', N'group_name'
  1678. GO
  1679. EXEC sp_addextendedproperty
  1680. 'MS_Description', N'组状态 0、未启用 1、启用',
  1681. 'SCHEMA', N'dbo',
  1682. 'TABLE', N'er_scene_config',
  1683. 'COLUMN', N'scene_status'
  1684. GO
  1685. EXEC sp_addextendedproperty
  1686. 'MS_Description', N'最大重试次数',
  1687. 'SCHEMA', N'dbo',
  1688. 'TABLE', N'er_scene_config',
  1689. 'COLUMN', N'max_retry_count'
  1690. GO
  1691. EXEC sp_addextendedproperty
  1692. 'MS_Description', N'1、默认等级 2、固定间隔时间 3、CRON 表达式',
  1693. 'SCHEMA', N'dbo',
  1694. 'TABLE', N'er_scene_config',
  1695. 'COLUMN', N'back_off'
  1696. GO
  1697. EXEC sp_addextendedproperty
  1698. 'MS_Description', N'间隔时长',
  1699. 'SCHEMA', N'dbo',
  1700. 'TABLE', N'er_scene_config',
  1701. 'COLUMN', N'trigger_interval'
  1702. GO
  1703. EXEC sp_addextendedproperty
  1704. 'MS_Description', N'Deadline Request 调用链超时 单位毫秒',
  1705. 'SCHEMA', N'dbo',
  1706. 'TABLE', N'er_scene_config',
  1707. 'COLUMN', N'deadline_request'
  1708. GO
  1709. EXEC sp_addextendedproperty
  1710. 'MS_Description', N'任务执行超时时间,单位秒',
  1711. 'SCHEMA', N'dbo',
  1712. 'TABLE', N'er_scene_config',
  1713. 'COLUMN', N'executor_timeout'
  1714. GO
  1715. EXEC sp_addextendedproperty
  1716. 'MS_Description', N'路由策略',
  1717. 'SCHEMA', N'dbo',
  1718. 'TABLE', N'er_scene_config',
  1719. 'COLUMN', N'route_key'
  1720. GO
  1721. EXEC sp_addextendedproperty
  1722. 'MS_Description', N'描述',
  1723. 'SCHEMA', N'dbo',
  1724. 'TABLE', N'er_scene_config',
  1725. 'COLUMN', N'description'
  1726. GO
  1727. EXEC sp_addextendedproperty
  1728. 'MS_Description', N'创建时间',
  1729. 'SCHEMA', N'dbo',
  1730. 'TABLE', N'er_scene_config',
  1731. 'COLUMN', N'create_dt'
  1732. GO
  1733. EXEC sp_addextendedproperty
  1734. 'MS_Description', N'修改时间',
  1735. 'SCHEMA', N'dbo',
  1736. 'TABLE', N'er_scene_config',
  1737. 'COLUMN', N'update_dt'
  1738. GO
  1739. EXEC sp_addextendedproperty
  1740. 'MS_Description', N'场景配置',
  1741. 'SCHEMA', N'dbo',
  1742. 'TABLE', N'er_scene_config'
  1743. GO
  1744. -- er_sequence_alloc
  1745. CREATE TABLE er_sequence_alloc
  1746. (
  1747. id bigint PRIMARY KEY IDENTITY,
  1748. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1749. group_name nvarchar(64) NOT NULL DEFAULT '',
  1750. max_id bigint NOT NULL DEFAULT '1',
  1751. step int NOT NULL DEFAULT '100',
  1752. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1753. )
  1754. GO
  1755. CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name ON er_sequence_alloc (namespace_id ASC, group_name ASC)
  1756. GO
  1757. EXEC sp_addextendedproperty
  1758. 'MS_Description', N'主键',
  1759. 'SCHEMA', N'dbo',
  1760. 'TABLE', N'er_sequence_alloc',
  1761. 'COLUMN', N'id'
  1762. GO
  1763. EXEC sp_addextendedproperty
  1764. 'MS_Description', N'命名空间id',
  1765. 'SCHEMA', N'dbo',
  1766. 'TABLE', N'er_sequence_alloc',
  1767. 'COLUMN', N'namespace_id'
  1768. GO
  1769. EXEC sp_addextendedproperty
  1770. 'MS_Description', N'组名称',
  1771. 'SCHEMA', N'dbo',
  1772. 'TABLE', N'er_sequence_alloc',
  1773. 'COLUMN', N'group_name'
  1774. GO
  1775. EXEC sp_addextendedproperty
  1776. 'MS_Description', N'最大id',
  1777. 'SCHEMA', N'dbo',
  1778. 'TABLE', N'er_sequence_alloc',
  1779. 'COLUMN', N'max_id'
  1780. GO
  1781. EXEC sp_addextendedproperty
  1782. 'MS_Description', N'步长',
  1783. 'SCHEMA', N'dbo',
  1784. 'TABLE', N'er_sequence_alloc',
  1785. 'COLUMN', N'step'
  1786. GO
  1787. EXEC sp_addextendedproperty
  1788. 'MS_Description', N'更新时间',
  1789. 'SCHEMA', N'dbo',
  1790. 'TABLE', N'er_sequence_alloc',
  1791. 'COLUMN', N'update_dt'
  1792. GO
  1793. EXEC sp_addextendedproperty
  1794. 'MS_Description', N'号段模式序号ID分配表',
  1795. 'SCHEMA', N'dbo',
  1796. 'TABLE', N'er_sequence_alloc'
  1797. GO
  1798. -- er_server_node
  1799. CREATE TABLE er_server_node
  1800. (
  1801. id bigint PRIMARY KEY IDENTITY,
  1802. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1803. group_name nvarchar(64) NOT NULL,
  1804. host_id nvarchar(64) NOT NULL,
  1805. host_ip nvarchar(64) NOT NULL,
  1806. context_path nvarchar(256) NOT NULL DEFAULT '/',
  1807. host_port int NOT NULL,
  1808. expire_at datetime2 NOT NULL,
  1809. node_type tinyint NOT NULL,
  1810. ext_attrs nvarchar(256) NULL DEFAULT '',
  1811. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1812. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1813. )
  1814. GO
  1815. CREATE UNIQUE NONCLUSTERED INDEX uk_host_id_host_ip ON er_server_node (host_id ASC, host_ip ASC)
  1816. GO
  1817. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_server_node (namespace_id ASC, group_name ASC)
  1818. GO
  1819. CREATE NONCLUSTERED INDEX idx_expire_at_node_type ON er_server_node (expire_at ASC, node_type ASC)
  1820. GO
  1821. EXEC sp_addextendedproperty
  1822. 'MS_Description', N'主键',
  1823. 'SCHEMA', N'dbo',
  1824. 'TABLE', N'er_server_node',
  1825. 'COLUMN', N'id'
  1826. GO
  1827. EXEC sp_addextendedproperty
  1828. 'MS_Description', N'命名空间id',
  1829. 'SCHEMA', N'dbo',
  1830. 'TABLE', N'er_server_node',
  1831. 'COLUMN', N'namespace_id'
  1832. GO
  1833. EXEC sp_addextendedproperty
  1834. 'MS_Description', N'组名称',
  1835. 'SCHEMA', N'dbo',
  1836. 'TABLE', N'er_server_node',
  1837. 'COLUMN', N'group_name'
  1838. GO
  1839. EXEC sp_addextendedproperty
  1840. 'MS_Description', N'主机id',
  1841. 'SCHEMA', N'dbo',
  1842. 'TABLE', N'er_server_node',
  1843. 'COLUMN', N'host_id'
  1844. GO
  1845. EXEC sp_addextendedproperty
  1846. 'MS_Description', N'机器ip',
  1847. 'SCHEMA', N'dbo',
  1848. 'TABLE', N'er_server_node',
  1849. 'COLUMN', N'host_ip'
  1850. GO
  1851. EXEC sp_addextendedproperty
  1852. 'MS_Description', N'客户端上下文路径 server.servlet.context-path',
  1853. 'SCHEMA', N'dbo',
  1854. 'TABLE', N'er_server_node',
  1855. 'COLUMN', N'context_path'
  1856. GO
  1857. EXEC sp_addextendedproperty
  1858. 'MS_Description', N'机器端口',
  1859. 'SCHEMA', N'dbo',
  1860. 'TABLE', N'er_server_node',
  1861. 'COLUMN', N'host_port'
  1862. GO
  1863. EXEC sp_addextendedproperty
  1864. 'MS_Description', N'过期时间',
  1865. 'SCHEMA', N'dbo',
  1866. 'TABLE', N'er_server_node',
  1867. 'COLUMN', N'expire_at'
  1868. GO
  1869. EXEC sp_addextendedproperty
  1870. 'MS_Description', N'节点类型 1、客户端 2、是服务端',
  1871. 'SCHEMA', N'dbo',
  1872. 'TABLE', N'er_server_node',
  1873. 'COLUMN', N'node_type'
  1874. GO
  1875. EXEC sp_addextendedproperty
  1876. 'MS_Description', N'扩展字段',
  1877. 'SCHEMA', N'dbo',
  1878. 'TABLE', N'er_server_node',
  1879. 'COLUMN', N'ext_attrs'
  1880. GO
  1881. EXEC sp_addextendedproperty
  1882. 'MS_Description', N'创建时间',
  1883. 'SCHEMA', N'dbo',
  1884. 'TABLE', N'er_server_node',
  1885. 'COLUMN', N'create_dt'
  1886. GO
  1887. EXEC sp_addextendedproperty
  1888. 'MS_Description', N'修改时间',
  1889. 'SCHEMA', N'dbo',
  1890. 'TABLE', N'er_server_node',
  1891. 'COLUMN', N'update_dt'
  1892. GO
  1893. EXEC sp_addextendedproperty
  1894. 'MS_Description', N'服务器节点',
  1895. 'SCHEMA', N'dbo',
  1896. 'TABLE', N'er_server_node'
  1897. GO
  1898. -- er_system_user
  1899. CREATE TABLE er_system_user
  1900. (
  1901. id bigint PRIMARY KEY IDENTITY,
  1902. username nvarchar(64) NOT NULL,
  1903. password nvarchar(128) NOT NULL,
  1904. role tinyint NOT NULL DEFAULT '0',
  1905. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1906. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1907. )
  1908. GO
  1909. CREATE UNIQUE NONCLUSTERED INDEX uk_username ON er_system_user (username ASC)
  1910. GO
  1911. EXEC sp_addextendedproperty
  1912. 'MS_Description', N'主键',
  1913. 'SCHEMA', N'dbo',
  1914. 'TABLE', N'er_system_user',
  1915. 'COLUMN', N'id'
  1916. GO
  1917. EXEC sp_addextendedproperty
  1918. 'MS_Description', N'账号',
  1919. 'SCHEMA', N'dbo',
  1920. 'TABLE', N'er_system_user',
  1921. 'COLUMN', N'username'
  1922. GO
  1923. EXEC sp_addextendedproperty
  1924. 'MS_Description', N'密码',
  1925. 'SCHEMA', N'dbo',
  1926. 'TABLE', N'er_system_user',
  1927. 'COLUMN', N'password'
  1928. GO
  1929. EXEC sp_addextendedproperty
  1930. 'MS_Description', N'角色:1-普通用户、2-管理员',
  1931. 'SCHEMA', N'dbo',
  1932. 'TABLE', N'er_system_user',
  1933. 'COLUMN', N'role'
  1934. GO
  1935. EXEC sp_addextendedproperty
  1936. 'MS_Description', N'创建时间',
  1937. 'SCHEMA', N'dbo',
  1938. 'TABLE', N'er_system_user',
  1939. 'COLUMN', N'create_dt'
  1940. GO
  1941. EXEC sp_addextendedproperty
  1942. 'MS_Description', N'修改时间',
  1943. 'SCHEMA', N'dbo',
  1944. 'TABLE', N'er_system_user',
  1945. 'COLUMN', N'update_dt'
  1946. GO
  1947. EXEC sp_addextendedproperty
  1948. 'MS_Description', N'系统用户表',
  1949. 'SCHEMA', N'dbo',
  1950. 'TABLE', N'er_system_user'
  1951. GO
  1952. -- pwd: admin
  1953. INSERT INTO er_system_user(username, password, role, create_dt, update_dt) VALUES (N'admin', N'465c194afb65670f38322df087f0a9bb225cc257e43eb4ac5a0c98ef5b3173ac', N'2', getdate(), getdate());
  1954. GO
  1955. -- er_system_user_permission
  1956. CREATE TABLE er_system_user_permission
  1957. (
  1958. id bigint PRIMARY KEY IDENTITY,
  1959. group_name nvarchar(64) NOT NULL,
  1960. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  1961. system_user_id bigint NOT NULL,
  1962. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  1963. update_dt datetime2 NOT NULL DEFAULT GETDATE()
  1964. )
  1965. GO
  1966. CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name_system_user_id ON er_system_user_permission (namespace_id ASC, group_name ASC, system_user_id ASC)
  1967. GO
  1968. EXEC sp_addextendedproperty
  1969. 'MS_Description', N'主键',
  1970. 'SCHEMA', N'dbo',
  1971. 'TABLE', N'er_system_user_permission',
  1972. 'COLUMN', N'id'
  1973. GO
  1974. EXEC sp_addextendedproperty
  1975. 'MS_Description', N'组名称',
  1976. 'SCHEMA', N'dbo',
  1977. 'TABLE', N'er_system_user_permission',
  1978. 'COLUMN', N'group_name'
  1979. GO
  1980. EXEC sp_addextendedproperty
  1981. 'MS_Description', N'命名空间id',
  1982. 'SCHEMA', N'dbo',
  1983. 'TABLE', N'er_system_user_permission',
  1984. 'COLUMN', N'namespace_id'
  1985. GO
  1986. EXEC sp_addextendedproperty
  1987. 'MS_Description', N'系统用户id',
  1988. 'SCHEMA', N'dbo',
  1989. 'TABLE', N'er_system_user_permission',
  1990. 'COLUMN', N'system_user_id'
  1991. GO
  1992. EXEC sp_addextendedproperty
  1993. 'MS_Description', N'创建时间',
  1994. 'SCHEMA', N'dbo',
  1995. 'TABLE', N'er_system_user_permission',
  1996. 'COLUMN', N'create_dt'
  1997. GO
  1998. EXEC sp_addextendedproperty
  1999. 'MS_Description', N'修改时间',
  2000. 'SCHEMA', N'dbo',
  2001. 'TABLE', N'er_system_user_permission',
  2002. 'COLUMN', N'update_dt'
  2003. GO
  2004. EXEC sp_addextendedproperty
  2005. 'MS_Description', N'系统用户权限表',
  2006. 'SCHEMA', N'dbo',
  2007. 'TABLE', N'er_system_user_permission'
  2008. GO
  2009. -- er_workflow
  2010. CREATE TABLE er_workflow
  2011. (
  2012. id bigint IDENTITY,
  2013. workflow_name nvarchar(64) NOT NULL,
  2014. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  2015. group_name nvarchar(64) NOT NULL,
  2016. workflow_status tinyint NOT NULL DEFAULT '1',
  2017. trigger_type tinyint NOT NULL,
  2018. trigger_interval nvarchar(255) NOT NULL,
  2019. next_trigger_at bigint NOT NULL,
  2020. block_strategy tinyint NOT NULL DEFAULT '1',
  2021. executor_timeout int NOT NULL DEFAULT '0',
  2022. description nvarchar(256) NOT NULL DEFAULT '',
  2023. flow_info nvarchar(max) NULL DEFAULT NULL,
  2024. bucket_index int NOT NULL DEFAULT '0',
  2025. version int NOT NULL,
  2026. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  2027. update_dt datetime2 NOT NULL DEFAULT GETDATE(),
  2028. deleted BIT DEFAULT 0,
  2029. ext_attrs nvarchar(256) NULL
  2030. )
  2031. GO
  2032. CREATE NONCLUSTERED INDEX idx_create_dt ON er_workflow (create_dt ASC)
  2033. GO
  2034. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_workflow (namespace_id ASC, group_name ASC)
  2035. GO
  2036. EXEC sp_addextendedproperty
  2037. 'MS_Description', N'主键',
  2038. 'SCHEMA', N'dbo',
  2039. 'TABLE', N'er_workflow',
  2040. 'COLUMN', N'id'
  2041. GO
  2042. EXEC sp_addextendedproperty
  2043. 'MS_Description', N'工作流名称',
  2044. 'SCHEMA', N'dbo',
  2045. 'TABLE', N'er_workflow',
  2046. 'COLUMN', N'workflow_name'
  2047. GO
  2048. EXEC sp_addextendedproperty
  2049. 'MS_Description', N'命名空间id',
  2050. 'SCHEMA', N'dbo',
  2051. 'TABLE', N'er_workflow',
  2052. 'COLUMN', N'namespace_id'
  2053. GO
  2054. EXEC sp_addextendedproperty
  2055. 'MS_Description', N'组名称',
  2056. 'SCHEMA', N'dbo',
  2057. 'TABLE', N'er_workflow',
  2058. 'COLUMN', N'group_name'
  2059. GO
  2060. EXEC sp_addextendedproperty
  2061. 'MS_Description', N'工作流状态 0、关闭、1、开启',
  2062. 'SCHEMA', N'dbo',
  2063. 'TABLE', N'er_workflow',
  2064. 'COLUMN', N'workflow_status'
  2065. GO
  2066. EXEC sp_addextendedproperty
  2067. 'MS_Description', N'触发类型 1.CRON 表达式 2. 固定时间',
  2068. 'SCHEMA', N'dbo',
  2069. 'TABLE', N'er_workflow',
  2070. 'COLUMN', N'trigger_type'
  2071. GO
  2072. EXEC sp_addextendedproperty
  2073. 'MS_Description', N'间隔时长',
  2074. 'SCHEMA', N'dbo',
  2075. 'TABLE', N'er_workflow',
  2076. 'COLUMN', N'trigger_interval'
  2077. GO
  2078. EXEC sp_addextendedproperty
  2079. 'MS_Description', N'下次触发时间',
  2080. 'SCHEMA', N'dbo',
  2081. 'TABLE', N'er_workflow',
  2082. 'COLUMN', N'next_trigger_at'
  2083. GO
  2084. EXEC sp_addextendedproperty
  2085. 'MS_Description', N'阻塞策略 1、丢弃 2、覆盖 3、并行',
  2086. 'SCHEMA', N'dbo',
  2087. 'TABLE', N'er_workflow',
  2088. 'COLUMN', N'block_strategy'
  2089. GO
  2090. EXEC sp_addextendedproperty
  2091. 'MS_Description', N'任务执行超时时间,单位秒',
  2092. 'SCHEMA', N'dbo',
  2093. 'TABLE', N'er_workflow',
  2094. 'COLUMN', N'executor_timeout'
  2095. GO
  2096. EXEC sp_addextendedproperty
  2097. 'MS_Description', N'描述',
  2098. 'SCHEMA', N'dbo',
  2099. 'TABLE', N'er_workflow',
  2100. 'COLUMN', N'description'
  2101. GO
  2102. EXEC sp_addextendedproperty
  2103. 'MS_Description', N'流程信息',
  2104. 'SCHEMA', N'dbo',
  2105. 'TABLE', N'er_workflow',
  2106. 'COLUMN', N'flow_info'
  2107. GO
  2108. EXEC sp_addextendedproperty
  2109. 'MS_Description', N'bucket',
  2110. 'SCHEMA', N'dbo',
  2111. 'TABLE', N'er_workflow',
  2112. 'COLUMN', N'bucket_index'
  2113. GO
  2114. EXEC sp_addextendedproperty
  2115. 'MS_Description', N'版本号',
  2116. 'SCHEMA', N'dbo',
  2117. 'TABLE', N'er_workflow',
  2118. 'COLUMN', N'version'
  2119. GO
  2120. EXEC sp_addextendedproperty
  2121. 'MS_Description', N'创建时间',
  2122. 'SCHEMA', N'dbo',
  2123. 'TABLE', N'er_workflow',
  2124. 'COLUMN', N'create_dt'
  2125. GO
  2126. EXEC sp_addextendedproperty
  2127. 'MS_Description', N'修改时间',
  2128. 'SCHEMA', N'dbo',
  2129. 'TABLE', N'er_workflow',
  2130. 'COLUMN', N'update_dt'
  2131. GO
  2132. EXEC sp_addextendedproperty
  2133. 'MS_Description', N'逻辑删除 1、删除',
  2134. 'SCHEMA', N'dbo',
  2135. 'TABLE', N'er_workflow',
  2136. 'COLUMN', N'deleted'
  2137. GO
  2138. EXEC sp_addextendedproperty
  2139. 'MS_Description', N'扩展字段',
  2140. 'SCHEMA', N'dbo',
  2141. 'TABLE', N'er_workflow',
  2142. 'COLUMN', N'ext_attrs'
  2143. GO
  2144. EXEC sp_addextendedproperty
  2145. 'MS_Description', N'工作流',
  2146. 'SCHEMA', N'dbo',
  2147. 'TABLE', N'er_workflow'
  2148. GO
  2149. -- er_workflow_node
  2150. CREATE TABLE er_workflow_node
  2151. (
  2152. id bigint PRIMARY KEY IDENTITY,
  2153. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  2154. node_name nvarchar(64) NOT NULL,
  2155. group_name nvarchar(64) NOT NULL,
  2156. job_id bigint NOT NULL,
  2157. workflow_id bigint NOT NULL,
  2158. node_type tinyint NOT NULL DEFAULT '1',
  2159. expression_type tinyint NOT NULL DEFAULT '0',
  2160. fail_strategy tinyint NOT NULL DEFAULT '1',
  2161. workflow_node_status tinyint NOT NULL DEFAULT '1',
  2162. priority_level int NOT NULL DEFAULT '1',
  2163. node_info nvarchar(max) NULL DEFAULT NULL,
  2164. version int NOT NULL,
  2165. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  2166. update_dt datetime2 NOT NULL DEFAULT GETDATE(),
  2167. deleted BIT DEFAULT 0,
  2168. ext_attrs nvarchar(256) NULL DEFAULT ''
  2169. )
  2170. GO
  2171. CREATE NONCLUSTERED INDEX idx_create_dt ON er_workflow_node (create_dt ASC)
  2172. GO
  2173. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_workflow_node (namespace_id ASC, group_name ASC)
  2174. GO
  2175. EXEC sp_addextendedproperty
  2176. 'MS_Description', N'主键',
  2177. 'SCHEMA', N'dbo',
  2178. 'TABLE', N'er_workflow_node',
  2179. 'COLUMN', N'id'
  2180. GO
  2181. EXEC sp_addextendedproperty
  2182. 'MS_Description', N'命名空间id',
  2183. 'SCHEMA', N'dbo',
  2184. 'TABLE', N'er_workflow_node',
  2185. 'COLUMN', N'namespace_id'
  2186. GO
  2187. EXEC sp_addextendedproperty
  2188. 'MS_Description', N'节点名称',
  2189. 'SCHEMA', N'dbo',
  2190. 'TABLE', N'er_workflow_node',
  2191. 'COLUMN', N'node_name'
  2192. GO
  2193. EXEC sp_addextendedproperty
  2194. 'MS_Description', N'组名称',
  2195. 'SCHEMA', N'dbo',
  2196. 'TABLE', N'er_workflow_node',
  2197. 'COLUMN', N'group_name'
  2198. GO
  2199. EXEC sp_addextendedproperty
  2200. 'MS_Description', N'任务信息id',
  2201. 'SCHEMA', N'dbo',
  2202. 'TABLE', N'er_workflow_node',
  2203. 'COLUMN', N'job_id'
  2204. GO
  2205. EXEC sp_addextendedproperty
  2206. 'MS_Description', N'工作流ID',
  2207. 'SCHEMA', N'dbo',
  2208. 'TABLE', N'er_workflow_node',
  2209. 'COLUMN', N'workflow_id'
  2210. GO
  2211. EXEC sp_addextendedproperty
  2212. 'MS_Description', N'1、任务节点 2、条件节点',
  2213. 'SCHEMA', N'dbo',
  2214. 'TABLE', N'er_workflow_node',
  2215. 'COLUMN', N'node_type'
  2216. GO
  2217. EXEC sp_addextendedproperty
  2218. 'MS_Description', N'1、SpEl、2、Aviator 3、QL',
  2219. 'SCHEMA', N'dbo',
  2220. 'TABLE', N'er_workflow_node',
  2221. 'COLUMN', N'expression_type'
  2222. GO
  2223. EXEC sp_addextendedproperty
  2224. 'MS_Description', N'失败策略 1、跳过 2、阻塞',
  2225. 'SCHEMA', N'dbo',
  2226. 'TABLE', N'er_workflow_node',
  2227. 'COLUMN', N'fail_strategy'
  2228. GO
  2229. EXEC sp_addextendedproperty
  2230. 'MS_Description', N'工作流节点状态 0、关闭、1、开启',
  2231. 'SCHEMA', N'dbo',
  2232. 'TABLE', N'er_workflow_node',
  2233. 'COLUMN', N'workflow_node_status'
  2234. GO
  2235. EXEC sp_addextendedproperty
  2236. 'MS_Description', N'优先级',
  2237. 'SCHEMA', N'dbo',
  2238. 'TABLE', N'er_workflow_node',
  2239. 'COLUMN', N'priority_level'
  2240. GO
  2241. EXEC sp_addextendedproperty
  2242. 'MS_Description', N'节点信息 ',
  2243. 'SCHEMA', N'dbo',
  2244. 'TABLE', N'er_workflow_node',
  2245. 'COLUMN', N'node_info'
  2246. GO
  2247. EXEC sp_addextendedproperty
  2248. 'MS_Description', N'版本号',
  2249. 'SCHEMA', N'dbo',
  2250. 'TABLE', N'er_workflow_node',
  2251. 'COLUMN', N'version'
  2252. GO
  2253. EXEC sp_addextendedproperty
  2254. 'MS_Description', N'创建时间',
  2255. 'SCHEMA', N'dbo',
  2256. 'TABLE', N'er_workflow_node',
  2257. 'COLUMN', N'create_dt'
  2258. GO
  2259. EXEC sp_addextendedproperty
  2260. 'MS_Description', N'修改时间',
  2261. 'SCHEMA', N'dbo',
  2262. 'TABLE', N'er_workflow_node',
  2263. 'COLUMN', N'update_dt'
  2264. GO
  2265. EXEC sp_addextendedproperty
  2266. 'MS_Description', N'逻辑删除 1、删除',
  2267. 'SCHEMA', N'dbo',
  2268. 'TABLE', N'er_workflow_node',
  2269. 'COLUMN', N'deleted'
  2270. GO
  2271. EXEC sp_addextendedproperty
  2272. 'MS_Description', N'扩展字段',
  2273. 'SCHEMA', N'dbo',
  2274. 'TABLE', N'er_workflow_node',
  2275. 'COLUMN', N'ext_attrs'
  2276. GO
  2277. EXEC sp_addextendedproperty
  2278. 'MS_Description', N'工作流节点',
  2279. 'SCHEMA', N'dbo',
  2280. 'TABLE', N'er_workflow_node'
  2281. GO
  2282. -- er_workflow_task_batch
  2283. CREATE TABLE er_workflow_task_batch
  2284. (
  2285. id bigint PRIMARY KEY IDENTITY,
  2286. namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a',
  2287. group_name nvarchar(64) NOT NULL,
  2288. workflow_id bigint NOT NULL,
  2289. task_batch_status tinyint NOT NULL DEFAULT '0',
  2290. operation_reason tinyint NOT NULL DEFAULT '0',
  2291. flow_info nvarchar(max) NULL DEFAULT NULL,
  2292. execution_at bigint NOT NULL DEFAULT '0',
  2293. create_dt datetime2 NOT NULL DEFAULT GETDATE(),
  2294. update_dt datetime2 NOT NULL DEFAULT GETDATE(),
  2295. deleted BIT DEFAULT 0,
  2296. ext_attrs nvarchar(256) NULL DEFAULT ''
  2297. )
  2298. GO
  2299. CREATE NONCLUSTERED INDEX idx_job_id_task_batch_status ON er_workflow_task_batch (workflow_id ASC, task_batch_status ASC)
  2300. GO
  2301. CREATE NONCLUSTERED INDEX idx_create_dt ON er_workflow_task_batch (create_dt ASC)
  2302. GO
  2303. CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_workflow_task_batch (namespace_id ASC, group_name ASC)
  2304. GO
  2305. EXEC sp_addextendedproperty
  2306. 'MS_Description', N'主键',
  2307. 'SCHEMA', N'dbo',
  2308. 'TABLE', N'er_workflow_task_batch',
  2309. 'COLUMN', N'id'
  2310. GO
  2311. EXEC sp_addextendedproperty
  2312. 'MS_Description', N'命名空间id',
  2313. 'SCHEMA', N'dbo',
  2314. 'TABLE', N'er_workflow_task_batch',
  2315. 'COLUMN', N'namespace_id'
  2316. GO
  2317. EXEC sp_addextendedproperty
  2318. 'MS_Description', N'组名称',
  2319. 'SCHEMA', N'dbo',
  2320. 'TABLE', N'er_workflow_task_batch',
  2321. 'COLUMN', N'group_name'
  2322. GO
  2323. EXEC sp_addextendedproperty
  2324. 'MS_Description', N'工作流任务id',
  2325. 'SCHEMA', N'dbo',
  2326. 'TABLE', N'er_workflow_task_batch',
  2327. 'COLUMN', N'workflow_id'
  2328. GO
  2329. EXEC sp_addextendedproperty
  2330. 'MS_Description', N'任务批次状态 0、失败 1、成功',
  2331. 'SCHEMA', N'dbo',
  2332. 'TABLE', N'er_workflow_task_batch',
  2333. 'COLUMN', N'task_batch_status'
  2334. GO
  2335. EXEC sp_addextendedproperty
  2336. 'MS_Description', N'操作原因',
  2337. 'SCHEMA', N'dbo',
  2338. 'TABLE', N'er_workflow_task_batch',
  2339. 'COLUMN', N'operation_reason'
  2340. GO
  2341. EXEC sp_addextendedproperty
  2342. 'MS_Description', N'流程信息',
  2343. 'SCHEMA', N'dbo',
  2344. 'TABLE', N'er_workflow_task_batch',
  2345. 'COLUMN', N'flow_info'
  2346. GO
  2347. EXEC sp_addextendedproperty
  2348. 'MS_Description', N'任务执行时间',
  2349. 'SCHEMA', N'dbo',
  2350. 'TABLE', N'er_workflow_task_batch',
  2351. 'COLUMN', N'execution_at'
  2352. GO
  2353. EXEC sp_addextendedproperty
  2354. 'MS_Description', N'创建时间',
  2355. 'SCHEMA', N'dbo',
  2356. 'TABLE', N'er_workflow_task_batch',
  2357. 'COLUMN', N'create_dt'
  2358. GO
  2359. EXEC sp_addextendedproperty
  2360. 'MS_Description', N'修改时间',
  2361. 'SCHEMA', N'dbo',
  2362. 'TABLE', N'er_workflow_task_batch',
  2363. 'COLUMN', N'update_dt'
  2364. GO
  2365. EXEC sp_addextendedproperty
  2366. 'MS_Description', N'逻辑删除 1、删除',
  2367. 'SCHEMA', N'dbo',
  2368. 'TABLE', N'er_workflow_task_batch',
  2369. 'COLUMN', N'deleted'
  2370. GO
  2371. EXEC sp_addextendedproperty
  2372. 'MS_Description', N'扩展字段',
  2373. 'SCHEMA', N'dbo',
  2374. 'TABLE', N'er_workflow_task_batch',
  2375. 'COLUMN', N'ext_attrs'
  2376. GO
  2377. EXEC sp_addextendedproperty
  2378. 'MS_Description', N'工作流批次',
  2379. 'SCHEMA', N'dbo',
  2380. 'TABLE', N'er_workflow_task_batch'
  2381. GO