add gms_debug

contrib/gms_debug/sql/gms_debugger_client6.sql

@@ -0,0 +1,99 @@
+-- wait for server establishment
+
+CREATE OR REPLACE FUNCTION wait_for_gms_debug_extension()
+RETURNS BOOLEAN AS $$
+DECLARE
+    extension_exists BOOLEAN;
+BEGIN
+    -- 初始化变量
+    extension_exists := FALSE;
+
+    -- 循环查询扩展是否存在
+    WHILE NOT extension_exists LOOP
+        -- 查询扩展是否存在
+        PERFORM 1 FROM pg_extension WHERE extname = 'gms_debug';
+        IF FOUND THEN
+            -- 如果扩展存在，则退出循环
+            extension_exists := TRUE;
+        ELSE
+            -- 如果扩展不存在，则等待一段时间再重试
+            PERFORM pg_sleep(1); -- 等待1秒
+        END IF;
+    END LOOP;
+
+    -- 返回扩展存在的标志
+    RETURN extension_exists;
+END;
+$$ LANGUAGE plpgsql;
+
+DO $$
+BEGIN
+    IF wait_for_gms_debug_extension() THEN
+        -- 扩展存在，执行下一步操作
+    END IF;
+END $$;
+
+set search_path = gms_debugger_test6;
+
+CREATE or REPLACE FUNCTION gms_continue()
+returns void as $$
+declare
+    run_info  gms_debug.runtime_info;
+    ret     binary_integer;
+begin
+    ret := gms_debug.continue(run_info, 0, 2);
+    RAISE NOTICE 'breakpoint= %', run_info.breakpoint;
+    RAISE NOTICE 'stackdepth= %', run_info.stackdepth;
+    RAISE NOTICE 'line= %', run_info.line#;
+    RAISE NOTICE 'reason= %', run_info.reason;
+    RAISE NOTICE 'ret= %',ret;
+end;
+$$ LANGUAGE plpgsql;
+
+CREATE or REPLACE FUNCTION gms_breakpoint(funcname text, lineno int)
+returns void as $$
+declare 
+    pro_info  gms_debug.program_info;
+    bkline     binary_integer;
+    ret     binary_integer;
+begin
+    pro_info.name := funcname;
+    ret := gms_debug.set_breakpoint(pro_info, lineno, bkline,1,1);
+    RAISE NOTICE 'ret= %', ret;
+    RAISE NOTICE 'ret= %', bkline;
+end;
+$$ LANGUAGE plpgsql;
+
+CREATE or REPLACE FUNCTION gms_finish()
+returns void as $$
+declare
+    run_info  gms_debug.runtime_info;
+    ret     binary_integer;
+begin
+    ret := gms_debug.continue(run_info, 8, 2);
+    RAISE NOTICE 'breakpoint= %', run_info.breakpoint;
+    RAISE NOTICE 'stackdepth= %', run_info.stackdepth;
+    RAISE NOTICE 'line= %', run_info.line#;
+    RAISE NOTICE 'reason= %', run_info.reason;
+    RAISE NOTICE 'ret= %',ret;
+end;
+$$ LANGUAGE plpgsql;
+
+
+-- attach debug server
+select * from gms_debug.attach_session('datanode1-0');
+
+select pg_sleep(3);
+
+select gms_breakpoint('test_debug', 31); 
+select gms_breakpoint('test_debug', 44);
+
+select gms_finish();
+
+select gms_finish();
+
+select gms_finish();
+
+select gms_continue();
+
+select gms_debug.detach_session();