cat > /data/opentenbase/install/opentenbase_bin_v2.0/pgxc_ctl.conf << 'EOF'
#!/usr/bin/env bash

#---- OVERALL -----------------------------------------------------------------------------
pgxcOwner=opentenbase
pgxcUser=$pgxcOwner
tmpDir=/tmp
localTmpDir=$tmpDir
configBackup=y
configBackupHost=localhost
configBackupDir=$HOME/pgxc
configBackupFile=pgxc_ctl.bak

#---- GTM --------------------------------------------------------------------------------
gtmName=gtm
gtmMasterServer=localhost
gtmMasterPort=6666
gtmMasterDir=/data/opentenbase/data/gtm
gtmExtraConfig=none
gtmMasterSpecificExtraConfig=none

# GTM Slave - disabled
gtmSlave=n
gtmSlaveName=gtmSlave
gtmSlaveServer=none
gtmSlavePort=20001
gtmSlaveDir=none
gtmSlaveSpecificExtraConfig=none

# GTM Proxy - disabled  
gtmProxy=n
gtmProxyNames=()
gtmProxyServers=()
gtmProxyPorts=()
gtmProxyDirs=()
gtmPxyExtraConfig=none
gtmPxySpecificExtraConfig=()

#---- Coordinators --------------------------------------------------------------------
coordMasterDir=/data/opentenbase/data/coord_master
coordSlaveDir=/data/opentenbase/data/coord_slave
coordArchLogDir=/data/opentenbase/data/coord_archlog

# 协调器配置数组 - 所有数组必须有相同数量的元素
coordNames=(cn001)
coordPorts=(30004)
poolerPorts=(30014)
coordForwardPorts=(30024)
coordPgHbaEntries=(0.0.0.0/0)

# Master Coordinators
coordMasterServers=(localhost)  
coordMasterDirs=(/data/opentenbase/data/coord_master/cn001)
coordMaxWALsender=5
coordMaxWALSenders=(5)

# Coordinator Slave - disabled
coordSlave=n
coordSlaveSync=n
coordSlaveServers=(none)
coordSlavePorts=(30005)
coordSlavePoolerPorts=(30015)
coordSlaveForwardPorts=(30025)
coordSlaveDirs=(none)
coordArchLogDirs=(none)

# Configuration files
coordExtraConfig=none
coordSpecificExtraConfig=(none)
coordSpecificExtraPgHba=(none)

#---- Datanodes -----------------------------------------------------------------------  
datanodeMasterDir=/data/opentenbase/data/dn_master
datanodeSlaveDir=/data/opentenbase/data/dn_slave
datanodeArchLogDir=/data/opentenbase/data/datanode_archlog

# 数据节点配置数组 - 所有数组必须有相同数量的元素
primaryDatanode=dn001
datanodeNames=(dn001)
datanodePorts=(20008)
datanodePoolerPorts=(20018)
datanodeForwardPorts=(20028)
datanodePgHbaEntries=(0.0.0.0/0)

# Master Datanodes
datanodeMasterServers=(localhost)
datanodeMasterDirs=(/data/opentenbase/data/dn_master/dn001)
datanodeMaxWalSender=5
datanodeMaxWALSenders=(5)

# Datanode Slave - disabled
datanodeSlave=n
datanodeSlaveServers=(none)
datanodeSlavePorts=(20009)
datanodeSlavePoolerPorts=(20019)
datanodeSlaveForwardPorts=(20029)
datanodeSlaveDirs=(none)
datanodeArchLogDirs=(none)

# Configuration files
datanodeExtraConfig=none  
datanodeSpecificExtraConfig=(none)
datanodeSpecificExtraPgHba=(none)

# WAL Archive - disabled
walArchive=n
EOF

# 删除不完整的配置文件
rm /data/opentenbase/install/opentenbase_bin_v2.0/pgxc_ctl.conf

# 重新创建完整配置文件
cat > /data/opentenbase/install/opentenbase_bin_v2.0/pgxc_ctl.conf << 'EOF'
#!/usr/bin/env bash

#---- OVERALL -----------------------------------------------------------------------------
pgxcOwner=opentenbase
pgxcUser=$pgxcOwner
tmpDir=/tmp
localTmpDir=$tmpDir
configBackup=y
configBackupHost=localhost
configBackupDir=$HOME/pgxc
configBackupFile=pgxc_ctl.bak

#---- GTM --------------------------------------------------------------------------------
gtmName=gtm
gtmMasterServer=localhost
gtmMasterPort=6666
gtmMasterDir=/data/opentenbase/data/gtm
gtmExtraConfig=none
gtmMasterSpecificExtraConfig=none

gtmSlave=n
gtmSlaveName=gtmSlave
gtmSlaveServer=none
gtmSlavePort=20001
gtmSlaveDir=none
gtmSlaveSpecificExtraConfig=none

gtmProxy=n
gtmProxyNames=()
gtmProxyServers=()
gtmProxyPorts=()
gtmProxyDirs=()
gtmPxyExtraConfig=none
gtmPxySpecificExtraConfig=()

#---- Coordinators --------------------------------------------------------------------
coordMasterDir=/data/opentenbase/data/coord_master
coordSlaveDir=/data/opentenbase/data/coord_slave
coordArchLogDir=/data/opentenbase/data/coord_archlog

coordNames=(cn001)
coordPorts=(30004)
poolerPorts=(30014)
coordForwardPorts=(30024)
coordPgHbaEntries=(0.0.0.0/0)

coordMasterServers=(localhost)
coordMasterDirs=(/data/opentenbase/data/coord_master/cn001)
coordMaxWALsender=5
coordMaxWALSenders=(5)

coordSlave=n
coordSlaveSync=n
coordSlaveServers=(none)
coordSlavePorts=(30005)
coordSlavePoolerPorts=(30015)
coordSlaveForwardPorts=(30025)
coordSlaveDirs=(none)
coordArchLogDirs=(none)

coordExtraConfig=none
coordSpecificExtraConfig=(none)
coordSpecificExtraPgHba=(none)

#---- Datanodes -----------------------------------------------------------------------
datanodeMasterDir=/data/opentenbase/data/dn_master
datanodeSlaveDir=/data/opentenbase/data/dn_slave
datanodeArchLogDir=/data/opentenbase/data/datanode_archlog

primaryDatanode=dn001
datanodeNames=(dn001)
datanodePorts=(20008)
datanodePoolerPorts=(20018)
datanodeForwardPorts=(20028)
datanodePgHbaEntries=(0.0.0.0/0)

datanodeMasterServers=(localhost)
datanodeMasterDirs=(/data/opentenbase/data/dn_master/dn001)
datanodeMaxWalSender=5
datanodeMaxWALSenders=(5)

datanodeSlave=n
datanodeSlaveServers=(none)
datanodeSlavePorts=(20009)
datanodeSlavePoolerPorts=(20019)
datanodeSlaveForwardPorts=(20029)
datanodeSlaveDirs=(none)
datanodeArchLogDirs=(none)

datanodeExtraConfig=none
datanodeSpecificExtraConfig=(none)
datanodeSpecificExtraPgHba=(none)

walArchive=n
EOF

# Python客户端连接示例
import psycopg2
from concurrent.futures import ThreadPoolExecutor
import time

class HTAPClient:
    def __init__(self, connection_config):
        self.config = connection_config
        self.oltp_pool = self._create_connection_pool(pool_size=20)
        self.olap_pool = self._create_connection_pool(pool_size=5)
    
    def execute_transaction(self, user_id, amount):
        """执行OLTP事务：用户转账"""
        with self.oltp_pool.getconn() as conn:
            try:
                with conn.cursor() as cur:
                    # 开启事务
                    cur.execute("BEGIN;")
                    
                    # 检查账户余额
                    cur.execute("""
                        SELECT balance FROM accounts 
                        WHERE user_id = %s FOR UPDATE;
                    """, (user_id,))
                    
                    balance = cur.fetchone()[0]
                    if balance >= amount:
                        # 执行转账操作
                        cur.execute("""
                            UPDATE accounts SET balance = balance - %s 
                            WHERE user_id = %s;
                        """, (amount, user_id))
                        
                        # 记录交易日志
                        cur.execute("""
                            INSERT INTO transactions (user_id, amount, tx_time)
                            VALUES (%s, %s, NOW());
                        """, (user_id, -amount))
                        
                        cur.execute("COMMIT;")
                        return {"status": "success", "new_balance": balance - amount}
                    else:
                        cur.execute("ROLLBACK;")
                        return {"status": "insufficient_funds"}
                        
            except Exception as e:
                cur.execute("ROLLBACK;")
                return {"status": "error", "message": str(e)}
    
    def generate_analytics_report(self, date_range):
        """执行OLAP查询：生成业务分析报告"""
        with self.olap_pool.getconn() as conn:
            with conn.cursor() as cur:
                # 设置查询超时和并行参数
                cur.execute("SET statement_timeout = '300s';")
                cur.execute("SET max_parallel_workers_per_gather = 8;")
                
                # 复杂的分析查询
                query = """
                WITH daily_metrics AS (
                    SELECT 
                        DATE(tx_time) as tx_date,
                        COUNT(*) as transaction_count,
                        SUM(CASE WHEN amount > 0 THEN amount ELSE 0 END) as total_deposits,
                        SUM(CASE WHEN amount < 0 THEN -amount ELSE 0 END) as total_withdrawals,
                        COUNT(DISTINCT user_id) as active_users
                    FROM transactions
                    WHERE tx_time >= %s AND tx_time < %s
                    GROUP BY DATE(tx_time)
                ),
                user_behavior AS (
                    SELECT 
                        user_id,
                        COUNT(*) as tx_frequency,
                        AVG(ABS(amount)) as avg_amount,
                        STDDEV(ABS(amount)) as amount_volatility
                    FROM transactions
                    WHERE tx_time >= %s AND tx_time < %s
                    GROUP BY user_id
                    HAVING COUNT(*) >= 5
                )
                SELECT 
                    dm.tx_date,
                    dm.transaction_count,
                    dm.total_deposits,
                    dm.total_withdrawals,
                    dm.active_users,
                    AVG(ub.avg_amount) as avg_user_amount,
                    PERCENTILE_CONT(0.95) WITHIN GROUP (ORDER BY ub.tx_frequency) as p95_frequency
                FROM daily_metrics dm
                LEFT JOIN user_behavior ub ON TRUE
                GROUP BY dm.tx_date, dm.transaction_count, dm.total_deposits, 
                         dm.total_withdrawals, dm.active_users
                ORDER BY dm.tx_date;
                """
                
                start_time = time.time()
                cur.execute(query, (date_range['start'], date_range['end'], 
                                  date_range['start'], date_range['end']))
                results = cur.fetchall()
                execution_time = time.time() - start_time
                
                return {
                    "data": results,
                    "execution_time": execution_time,
                    "query_type": "OLAP"
                }

# 使用示例
if __name__ == "__main__":
    config = {
        'host': 'opentenbase-cluster.example.com',
        'port': 5432,
        'database': 'finance_db',
        'user': 'app_user',
        'password': 'secure_password'
    }
    
    client = HTAPClient(config)
    
    # 并发执行OLTP和OLAP任务
    with ThreadPoolExecutor(max_workers=10) as executor:
        # 提交OLTP任务
        oltp_futures = [
            executor.submit(client.execute_transaction, user_id, 100)
            for user_id in range(1001, 1021)
        ]
        
        # 提交OLAP任务
        olap_future = executor.submit(
            client.generate_analytics_report, 
            {'start': '2024-08-01', 'end': '2024-08-31'}
        )
        
        # 收集结果
        oltp_results = [future.result() for future in oltp_futures]
        olap_result = olap_future.result()
        
    print(f"OLTP事务完成数量: {len([r for r in oltp_results if r['status'] == 'success'])}")
    print(f"OLAP查询执行时间: {olap_result['execution_time']:.2f}秒")

# OpenTenBase Kubernetes部署配置示例
apiVersion: v1
kind: ConfigMap
metadata:
  name: opentenbase-config
data:
  postgresql.conf: |
    # GTM配置
    gtm_host = 'opentenbase-gtm-service'
    gtm_port = 6666
    
    # 分布式配置
    enable_distributed = on
    coordinator_node_id = 1
    max_coordinators = 3
    max_datanodes = 8
    
    # HTAP优化配置
    enable_column_store = on
    enable_parallel_agg = on
    max_parallel_workers_per_gather = 8

---
apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: opentenbase-datanode
spec:
  serviceName: opentenbase-datanode
  replicas: 4
  selector:
    matchLabels:
      app: opentenbase-datanode
  template:
    metadata:
      labels:
        app: opentenbase-datanode
    spec:
      containers:
      - name: datanode
        image: opentenbase/opentenbase:latest
        ports:
        - containerPort: 5432
        env:
        - name: NODE_TYPE
          value: "datanode"
        - name: NODE_ID  
          valueFrom:
            fieldRef:
              fieldPath: metadata.annotations['datanode.id']
        volumeMounts:
        - name: data
          mountPath: /data
        - name: config
          mountPath: /etc/postgresql
  volumeClaimTemplates:
  - metadata:
      name: data
    spec:
      accessModes: ["ReadWriteOnce"]
      resources:
        requests:
          storage: 100Gi