oceanbase

1
tenant_ids = {}
2
print_to_client(usage())
3

4
print_to_client("now:", now())
5

6
tenant_ids = get_tenant_id_list()
7

8
print_to_client("tenant_cnt:", #tenant_ids)
9
print_to_client("tenant_id memory_limit")
10
for i=1,#tenant_ids do
11
    limit = get_tenant_mem_limit(tenant_ids[i])
12
    print_to_client(tenant_ids[i], limit)
13
end
14

15
print_to_client("rpc packet in bytes", get_tenant_sysstat_by_name(1, "rpc packet in bytes"), get_tenant_sysstat_by_id(1001, 10001))
16

17
print_to_client("memory usage", get_tenant_sysstat_by_name(1, "memory usage"), get_tenant_sysstat_by_id(1001, 140003))
18

19
-- to limit 10 rows
20
-- para["limit"] = {10}
21

22
-- equal to {10}
23
-- para["limit"] = {0, 10}
24

25
-- using dump mode, recommended
26
-- para["dump"] = true
27

28
para = {}
29
para["limit"] = {}
30
para["dump"] = true
31
para["select"] = {
32
    "id",
33
    "user",
34
    "tenant",
35
    "host",
36
    "db",
37
    "command",
38
    "sql_id",
39
    "time",
40
    "state",
41
    "info",
42
    "sql_port",
43
    "proxy_sessid",
44
    "master_sessid",
45
    "user_client_ip",
46
    "user_host",
47
    "trans_id",
48
    "thread_id",
49
    "ssl_cipher",
50
    "trace_id",
51
    "trans_state",
52
    "total_time",
53
    "retry_cnt",
54
    "retry_info",
55
    "action",
56
    "module",
57
    "client_info"
58
}
59
print_to_client("select_processlist")
60
select_processlist(para)
61

62
para = {}
63
para["limit"] = {10}
64
para["dump"] = true
65
para["select"] = {
66
    "tenant_id",
67
    "statistic",
68
    "value",
69
    "value_type",
70
    "stat_id",
71
    "name",
72
    "class",
73
    "can_visible"
74
}
75
print_to_client("select_sysstat")
76
select_sysstat(para)
77

78
para = {}
79
para["limit"] = {10}
80
para["dump"] = true
81
para["select"] = {"tenant_id", "ctx_name", "label", "hold"}
82
print_to_client("select_memory_info")
83
select_memory_info(para)
84

85
para = {}
86
para["limit"] = {10}
87
para["dump"] = true
88
para["select"] = {
89
    "tenant_id",
90
    "ctx_id",
91
    "ctx_name",
92
    "hold",
93
    "used",
94
    "limit"
95
}
96
print_to_client("select_tenant_ctx_memory_info")
97
select_tenant_ctx_memory_info(para)
98

99
para = {}
100
para["limit"] = {10}
101
para["dump"] = true
102
para["select"] = {
103
    "tenant_id",
104
    "tx_type",
105
    "tx_id",
106
    "session_id",
107
    "scheduler_addr",
108
    "is_decided",
109
    "ls_id",
110
    "participants",
111
    "tx_ctx_create_time",
112
    "expired_time",
113
    "ref_cnt",
114
    "last_op_sn",
115
    "pending_write",
116
    "state",
117
    "part_tx_action",
118
    "tx_ctx_addr",
119
    "mem_ctx_id",
120
    "pending_log_size",
121
    "flushed_log_size",
122
    "role_state",
123
    "is_exiting",
124
    "coord",
125
    "last_request_ts",
126
    "gtrid",
127
    "bqual",
128
    "format_id"
129
}
130
print_to_client("select_trans_stat")
131
select_trans_stat(para)
132

133
para = {}
134
para["limit"] = {}
135
para["dump"] = true
136
para["select"] = {
137
    "plan_id",
138
    "sql_id",
139
    "sql_exec_id",
140
    "operation_type",
141
    "operation_id",
142
    "sid",
143
    "active_time",
144
    "work_area_size",
145
    "expect_size",
146
    "actual_mem_used",
147
    "max_mem_used",
148
    "number_passes",
149
    "tempseg_size",
150
    "tenant_id",
151
    "policy"
152
}
153
print_to_client("select_sql_workarea_active")
154
select_sql_workarea_active(para)
155

156
para = {}
157
para["limit"] = {}
158
para["dump"] = true
159
para["select"] = {
160
    "start_time",
161
    "task_type",
162
    "task_id",
163
    "tenant_id",
164
    "comment",
165
    "is_cancel"
166
}
167
print_to_client("select_sys_task_status")
168
select_sys_task_status(para)
169

170
para = {}
171
para["limit"] = {}
172
para["dump"] = true
173
para["select"] = {
174
    "tenant_id",
175
    "compat_mode",
176
    "unit_min_cpu",
177
    "unit_max_cpu",
178
    "slice",
179
    "remain_slice",
180
    "token_cnt",
181
    "ass_token_cnt",
182
    "lq_tokens",
183
    "used_lq_tokens",
184
    "stopped",
185
    "idle_us",
186
    "recv_hp_rpc_cnt",
187
    "recv_np_rpc_cnt",
188
    "recv_lp_rpc_cnt",
189
    "recv_mysql_cnt",
190
    "recv_task_cnt",
191
    "recv_large_req_cnt",
192
    "recv_large_queries",
193
    "actives",
194
    "workers",
195
    "lq_warting_workers",
196
    "req_queue_total_size",
197
    "queue_0",
198
    "queue_1",
199
    "queue_2",
200
    "queue_3",
201
    "queue_4",
202
    "queue_5",
203
    "large_queued"
204
}
205
print_to_client("select_dump_tenant_info")
206
select_dump_tenant_info(para)
207

208
para = {}
209
para["limit"] = {}
210
para["dump"] = true
211
para["select"] = {
212
    "total_size",
213
    "used_size",
214
    "free_size",
215
    "is_disk_valid",
216
    "disk_error_begin_ts"
217
}
218
print_to_client("select_disk_stat")
219
select_disk_stat(para)
220

221
para = {}
222
para["limit"] = {}
223
para["dump"] = true
224
para["select"] = {
225
    "tenant_id",
226
    "hold",
227
    "limit"
228
}
229
print_to_client("select_tenant_memory_info")
230
select_tenant_memory_info(para)
231

232
print_to_client("show_log_probe")
233
print_to_client(show_log_probe())
234

235
para = {}
236
para["limit"] = {}
237
para["dump"] = true
238
para["select"] = {
239
    "mod_name",
240
    "mod_type",
241
    "alloc_count",
242
    "alloc_size",
243
    "back_trace"
244
}
245
print_to_client("select_mem_leak_checker_info")
246
select_mem_leak_checker_info(para)
247

248
para = {}
249
para["limit"] = {}
250
para["dump"] = true
251
para["select"] = {
252
    "tenant_id",
253
    "merge_type",
254
    "ls_id",
255
    "tablet_id",
256
    "status",
257
    "create_time",
258
    "diagnose_info"
259
}
260
print_to_client("select_compaction_diagnose_info")
261
select_compaction_diagnose_info(para)
262

263
para = {}
264
para["limit"] = {}
265
para["dump"] = true
266
para["select"] = {
267
    "tenant_id",
268
    "task_id",
269
    "module",
270
    "type",
271
    "ret",
272
    "status",
273
    "gmt_create",
274
    "gmt_modified",
275
    "retry_cnt",
276
    "warning_info"
277
}
278
print_to_client("select_dag_warning_history")
279
select_dag_warning_history(para)
280

281
para = {}
282
para["limit"] = {}
283
para["dump"] = true
284
para["select"] = {
285
    "tenant_id",
286
    "refreshed_schema_version",
287
    "received_schema_version",
288
    "schema_count",
289
    "schema_size",
290
    "min_sstable_schema_version"
291
}
292
print_to_client("select_server_schema_info")
293
select_server_schema_info(para)
294

295
para = {}
296
para["limit"] = {10}
297
para["dump"] = true
298
para["select"] = {
299
    "tenant_id",
300
    "slot_id",
301
    "schema_version",
302
    "schema_count",
303
    "total_ref_cnt",
304
    "ref_info"
305
}
306
print_to_client("select_schema_slot")
307
select_schema_slot(para)
308

309
para = {}
310
para["limit"] = {}
311
para["dump"] = true
312
para["select"] = {
313
    "tname",
314
    "tid",
315
    "thread_base",
316
    "loop_ts",
317
    "latch_hold",
318
    "latch_wait",
319
    "trace_id",
320
    "status",
321
    "wait_event"
322
}
323
print_to_client("dump_thread_info")
324
dump_thread_info(para)
325

326
para = {}
327
para["limit"] = {0, 3}
328
para["dump"] = true
329
para["select"] = {
330
    "tenant_id",
331
    "ctx_id",
332
    "mod_name",
333
    "back_trace",
334
    "ctx_name",
335
    "alloc_count",
336
    "alloc_bytes"
337
}
338
print_to_client("select_malloc_sample_info")
339
select_malloc_sample_info(para)
340

341
set_system_tenant_limit_mode(1)
342