Add GaussDB distributed load balancing demo with screenshots, logical replication example, and minor README/test fixes

Author: chenyunliang520

example/GaussDB_distributed_readme.md

@@ -11,7 +11,7 @@
   ```
 
 - **GaussDB数据库已经购买**：具体步骤可参考华为云官网购买GaussDB。
-- 
+
 - **GaussDB驱动 pq 已安装**：具体步骤可参考readme中libpq的安装说明。
 
 - **gaussdb 库已安装**：Python 的虚拟环境中需安装 `gaussdb` 库，用于连接 openGauss 数据库。
@@ -52,13 +52,22 @@ python ssl_demo.py
 
 ## 逻辑复制
 
+运行示例代码，查看非ssl模式下逻辑复制的输出结果。
+
+```bash
+# 配置环境变量
+export GAUSSDB_TEST_DSN="dbname=test01 user=root password=*** host=*** port=8000"
+
+# 运行示例代码
+python logical_replication_demo.py
+```
 
 
 ## 主备模式负载均衡
 
-请查看 [GaussDB_master_standby_readme.md](GaussDB_master_standby_readme.md)。
+请参考 [GaussDB_master_standby_readme.md](GaussDB_master_standby_readme.md)。
 
 
 ## 分布式模式负载均衡
 
-请查看 [GaussDB_master_standby_readme.md](GaussDB_master_standby_readme.md)。
+请参考 [GaussDB_distributed_readme.md](GaussDB_distributed_readme.md)。

example/README.md

@@ -11,7 +11,7 @@
 def main():
     dsn = os.environ.get("GAUSSDB_TEST_DSN")
     if not dsn:
-        print("❌ Please set the GAUSSDB_TEST_DSN environment variable, for example:")
+        print("Please set the GAUSSDB_TEST_DSN environment variable, for example:")
         print(
             '   export GAUSSDB_TEST_DSN="dbname=test01 user=root password=***'
             'host=** port=8000"'
@@ -30,7 +30,7 @@ def main():
 
         with conn.cursor() as cur:
             server_version = conn.execute("select version()").fetchall()[0][0]
-            print(f"✅ Connected. Server version: {server_version}")
+            print(f"Connected. Server version: {server_version}")
             print(f"Vendor: {conn.info.vendor}, Version: {conn.info.server_version}")
 
             cur.execute(drop_table_sql)
@@ -39,11 +39,11 @@ def main():
             cur.execute(insert_data_sql, (2, "world"))
 
             cur.execute(select_sql)
-            print("📄origin: ", cur.fetchall())
+            print("origin: ", cur.fetchall())
 
             cur.execute(update_data_sql)
             cur.execute(select_sql)
-            print("📄update: ", cur.fetchall())
+            print("update: ", cur.fetchall())
 
 
 if __name__ == "__main__":