@@ -11,94 +11,76 @@ versions: '[3,)'
11
11
12
12
Scripts and SQL statements used when interacting with a [ PostgreSQL] ( https://www.postgresql.org/ ) database.
13
13
14
-
15
14
## Build Time
16
15
17
16
Scripts are created at build time and can be executed manually as part of a deployment or decommissioning of an endpoint.
18
-
19
17
20
18
### Outbox
21
19
22
-
23
20
#### Create Table
24
21
25
22
snippet: PostgreSQL_OutboxCreateSql
26
23
27
-
28
24
#### Drop Table
29
25
30
26
snippet: PostgreSQL_OutboxDropSql
31
27
32
-
33
28
### Saga
34
29
35
- For a Saga with the following structure
30
+ For a Saga with the following structure
36
31
37
32
snippet: CreationScriptSaga
38
33
39
-
40
34
#### Create Table
41
35
42
36
snippet: PostgreSQL_SagaCreateSql
43
37
44
-
45
38
#### Drop Table
46
39
47
40
snippet: PostgreSQL_SagaDropSql
48
41
49
-
50
42
### Subscription
51
43
52
-
53
44
#### Create Table
54
45
55
46
snippet: PostgreSQL_SubscriptionCreateSql
56
47
57
-
58
48
#### Drop Table
59
49
60
50
snippet: PostgreSQL_SubscriptionDropSql
61
51
62
-
63
52
### Timeout
64
53
65
-
66
54
#### Create Table
67
55
68
56
snippet: PostgreSQL_TimeoutCreateSql
69
57
70
-
71
58
#### Drop Table
72
59
73
60
snippet: PostgreSQL_TimeoutDropSql
74
61
75
-
76
62
## Run Time
77
63
78
64
These are the SQL scripts used at runtime to query and update data.
79
65
80
-
81
66
### Outbox
82
67
83
68
Used at intervals to cleanup old outbox records.
84
69
85
70
snippet: PostgreSQL_OutboxCleanupSql
86
71
87
-
88
72
#### Get
89
73
90
74
Used by ` IOutboxStorage.SetAsDispatched ` .
91
75
92
76
snippet: PostgreSQL_OutboxGetSql
93
77
94
-
95
78
#### SetAsDispatched
96
79
97
80
Used by ` IOutboxStorage.SetAsDispatched ` .
98
81
99
82
snippet: PostgreSQL_OutboxSetAsDispatchedSql
100
83
101
-
102
84
#### Store
103
85
104
86
Used by ` IOutboxStorage.Store ` .
@@ -107,88 +89,74 @@ partial: outbox
107
89
108
90
### Saga
109
91
110
-
111
92
#### Complete
112
93
113
94
Used by ` ISagaPersister.Complete ` .
114
95
115
96
snippet: PostgreSQL_SagaCompleteSql
116
97
117
-
118
98
#### Save
119
99
120
100
Used by ` ISagaPersister.Save ` .
121
101
122
102
snippet: PostgreSQL_SagaSaveSql
123
103
124
-
125
104
#### GetByProperty
126
105
127
106
Used by ` ISagaPersister.Get(propertyName...) ` .
128
107
129
108
snippet: PostgreSQL_SagaGetByPropertySql
130
109
131
-
132
110
#### GetBySagaId
133
111
134
112
Used by ` ISagaPersister.Get(sagaId...) ` .
135
113
136
114
snippet: PostgreSQL_SagaGetBySagaIdSql
137
115
138
-
139
116
#### Update
140
117
141
118
Used by ` ISagaPersister.Update ` .
142
119
143
120
snippet: PostgreSQL_SagaUpdateSql
144
121
145
-
146
122
#### Select used by Saga Finder
147
123
148
124
snippet: postgresql_SagaSelectSql
149
125
150
-
151
126
### Subscriptions
152
127
153
-
154
128
#### GetSubscribers
155
129
156
130
Used by ` ISubscriptionStorage.GetSubscriberAddressesForMessage ` .
157
131
158
132
snippet: PostgreSQL_SubscriptionGetSubscribersSql
159
133
160
-
161
134
#### Subscribe
162
135
163
136
Used by ` ISubscriptionStorage.Subscribe ` .
164
137
165
138
snippet: PostgreSQL_SubscriptionSubscribeSql
166
139
167
-
168
140
#### Unsubscribe
169
141
170
142
Used by ` ISubscriptionStorage.Unsubscribe ` .
171
143
172
144
snippet: PostgreSQL_SubscriptionUnsubscribeSql
173
145
174
-
175
146
### Timeouts
176
147
177
-
178
148
#### Peek
179
149
180
150
Used by ` IPersistTimeouts.Peek ` .
181
151
182
152
snippet: PostgreSQL_TimeoutPeekSql
183
153
184
-
185
154
#### Add
186
155
187
156
Used by ` IPersistTimeouts.Add ` .
188
157
189
158
snippet: PostgreSQL_TimeoutAddSql
190
159
191
-
192
160
#### GetNextChunk
193
161
194
162
Used by ` IQueryTimeouts.GetNextChunk ` .
@@ -197,14 +165,12 @@ snippet: PostgreSQL_TimeoutNextSql
197
165
198
166
snippet: PostgreSQL_TimeoutRangeSql
199
167
200
-
201
168
#### TryRemove
202
169
203
170
Used by ` IPersistTimeouts.TryRemove ` .
204
171
205
172
snippet: PostgreSQL_TimeoutRemoveByIdSql
206
173
207
-
208
174
#### RemoveTimeoutBy
209
175
210
176
Used by ` IPersistTimeouts.RemoveTimeoutBy ` .
0 commit comments