# 安裝Flask框架
pip install flask
# 安裝KingbaseES數(shù)據庫驅動（兼容PostgreSQL）
pip install psycopg2-binary

kingbase_web_manager/  # 項目根目錄
├── app.py             # 后端核心邏輯（包含F(xiàn)lask服務、數(shù)據庫操作、路由定義）
└── templates/         # 前端HTML模板文件夾（用繼承式設計，減少重復代碼）
    ├── base.html      # 基礎模板（放公共頭部、樣式、消息提示這些）
    ├── index.html     # 首頁（用來展示用戶列表）
    ├── init_schema.html  # 表結構初始化頁面
    ├── create_user.html  # 新增用戶頁面
    ├── user_detail.html  # 用戶詳情頁面
    └── update_balance.html  # 余額修改頁面

from flask import Flask, jsonify, request, render_template, redirect, url_for, flash
import psycopg2  # KingbaseES數(shù)據庫驅動
import psycopg2.extras as extras  # 擴展功能（如DictCursor，讓查詢結果為字典格式）

# 初始化Flask應用
app = Flask(__name__)
# 配置secret_key（用于flash消息提示，防止跨站請求偽造）
app.secret_key = 'kingbase_web_manager_2024'

# --------------------------
# KingbaseES數(shù)據庫連接配置
# --------------------------
DB_CFG = dict(
    host="127.0.0.1",    # 數(shù)據庫IP（本地為127.0.0.1，遠程需填實際IP）
    port=54321,          # KingbaseES默認常見端口（不同環(huán)境可能為5432，需確認）
    dbname="TEST",       # 數(shù)據庫名稱（提前創(chuàng)建好）
    user="system",       # 數(shù)據庫賬號（管理員賬號）
    password="jcsjk520.",# 數(shù)據庫密碼（替換為你的實際密碼）
    connect_timeout=5,   # 連接超時時間（5秒）
)

# --------------------------
# 數(shù)據庫連接工具函數(shù)
# --------------------------
def get_conn():
    """獲取KingbaseES數(shù)據庫連接"""
    try:
        # 使用psycopg2.connect連接數(shù)據庫，**DB_CFG表示解包配置字典
        conn = psycopg2.connect(**DB_CFG)
        return conn
    except Exception as e:
        # 連接失敗時拋出異常（后續(xù)路由會捕獲處理）
        raise Exception(f"數(shù)據庫連接失敗: {str(e)}")

@app.route('/init-schema', methods=['GET', 'POST'])
def init_schema():
    """初始化用戶表結構（GET請求顯示頁面，POST請求執(zhí)行建表）"""
    # 1. POST請求：用戶點擊"初始化"按鈕，執(zhí)行建表SQL
    if request.method == 'POST':
        # 定義建表SQL（if not exists確保表不存在時才創(chuàng)建，避免重復執(zhí)行報錯）
        create_table_sql = """
        create table if not exists t_user(
            id          serial primary key,  # 自增主鍵（用戶ID）
            name        varchar(64) not null, # 用戶名（非空）
            balance     numeric(12,2) default 0, # 余額（默認0，支持兩位小數(shù)）
            created_at  timestamp default current_timestamp # 創(chuàng)建時間（默認當前時間）
        );
        """
        try:
            # 使用with語句自動管理連接和游標（無需手動關閉）
            with get_conn() as conn, conn.cursor() as cur:
                cur.execute(create_table_sql)  # 執(zhí)行建表SQL
            # 建表成功，通過flash傳遞成功消息（前端會顯示）
            flash('表結構初始化成功！', 'success')
        except Exception as e:
            # 建表失敗，傳遞錯誤消息
            flash(f'初始化失敗: {str(e)}', 'danger')
        # 無論成功與否，跳轉回首頁
        return redirect(url_for('index'))
    
    # 2. GET請求：顯示初始化表結構的頁面
    return render_template('init_schema.html')

@app.route('/')
def index():
    """首頁：展示所有用戶列表"""
    try:
        # 查詢所有用戶數(shù)據（按ID升序，可選）
        query_sql = "select id, name, balance, created_at from t_user order by id;"
        # 使用DictCursor，讓查詢結果為字典（便于前端通過鍵名獲取值）
        with get_conn() as conn, conn.cursor(cursor_factory=extras.DictCursor) as cur:
            cur.execute(query_sql)
            # fetchall()獲取所有結果，轉換為列表（每個元素是字典）
            users = [dict(row) for row in cur.fetchall()]
        # 渲染首頁模板，傳遞用戶列表數(shù)據
        return render_template('index.html', users=users)
    except Exception as e:
        # 查詢失敗，顯示錯誤消息，傳遞空列表
        flash(f'數(shù)據庫查詢錯誤: {str(e)}', 'danger')
        return render_template('index.html', users=[])

@app.route('/user/create', methods=['GET', 'POST'])
def create_user():
    """新增用戶（GET顯示表單，POST提交數(shù)據）"""
    if request.method == 'POST':
        # 1. 獲取前端表單提交的數(shù)據（request.form用于獲取POST表單數(shù)據）
        name = request.form.get('name')  # 用戶名（必填）
        balance = request.form.get('balance', 0.0)  # 初始余額（可選，默認0）
        
        # 2. 數(shù)據校驗：用戶名不能為空
        if not name:
            flash('用戶名不能為空！', 'danger')
            return render_template('create_user.html')  # 校驗失敗，返回表單頁面
        
        try:
            # 3. 數(shù)據格式轉換：余額轉為浮點數(shù)（防止非數(shù)字輸入）
            balance = float(balance) if balance else 0.0
            # 4. 執(zhí)行插入SQL（returning id返回新增用戶的ID）
            insert_sql = "insert into t_user(name, balance) values (%s, %s) returning id;"
            with get_conn() as conn, conn.cursor() as cur:
                cur.execute(insert_sql, (name, balance))  # %s為參數(shù)占位符（防止SQL注入）
                user_id = cur.fetchone()[0]  # 獲取返回的用戶ID
            
            # 5. 新增成功，跳轉回首頁
            flash(f'用戶創(chuàng)建成功！用戶ID: {user_id}', 'success')
            return redirect(url_for('index'))
        except ValueError:
            # 余額非數(shù)字時捕獲異常
            flash('初始余額必須為數(shù)字！', 'danger')
        except Exception as e:
            # 其他錯誤（如數(shù)據庫異常）
            flash(f'用戶創(chuàng)建失敗: {str(e)}', 'danger')
    
    # GET請求：顯示新增用戶表單
    return render_template('create_user.html')

@app.route('/user/<int:user_id>')
def get_user(user_id):
    """查看單個用戶詳情（通過URL路徑傳遞user_id）"""
    try:
        # 查詢指定ID的用戶數(shù)據
        query_sql = "select id, name, balance, created_at from t_user where id=%s;"
        with get_conn() as conn, conn.cursor(cursor_factory=extras.DictCursor) as cur:
            cur.execute(query_sql, (user_id,))  # 傳遞user_id參數(shù)
            user = dict(cur.fetchone()) if cur.rowcount > 0 else None  # 轉換為字典
        
        # 校驗用戶是否存在
        if not user:
            flash('該用戶不存在！', 'danger')
            return redirect(url_for('index'))  # 不存在則跳轉回首頁
        
        # 渲染詳情頁面，傳遞用戶數(shù)據
        return render_template('user_detail.html', user=user)
    except Exception as e:
        flash(f'查詢用戶失敗: {str(e)}', 'danger')
        return redirect(url_for('index'))

@app.route('/user/<int:user_id>/balance', methods=['GET', 'POST'])
def update_balance(user_id):
    """修改用戶余額（GET顯示表單，POST提交修改）"""
    if request.method == 'POST':
        try:
            # 1. 獲取余額變動值（delta：正數(shù)增加，負數(shù)減少）
            delta = float(request.form.get('delta', 0))
            # 2. 執(zhí)行更新SQL（balance = balance + %s 實現(xiàn)增量更新）
            update_sql = "update t_user set balance = balance + %s where id=%s;"
            with get_conn() as conn, conn.cursor() as cur:
                cur.execute(update_sql, (delta, user_id))
                # 校驗用戶是否存在（rowcount為受影響行數(shù)，0表示無此用戶）
                if cur.rowcount == 0:
                    flash('該用戶不存在！', 'danger')
                    return redirect(url_for('index'))
            
            # 3. 更新成功，跳轉回用戶詳情頁
            flash('余額更新成功！', 'success')
            return redirect(url_for('get_user', user_id=user_id))
        except ValueError:
            # 變動值非數(shù)字時捕獲異常
            flash('余額變動值必須為數(shù)字！', 'danger')
        except Exception as e:
            flash(f'余額更新失敗: {str(e)}', 'danger')
    
    # GET請求：顯示余額修改表單（先查詢當前用戶信息）
    try:
        query_sql = "select id, name, balance from t_user where id=%s;"
        with get_conn() as conn, conn.cursor(cursor_factory=extras.DictCursor) as cur:
            cur.execute(query_sql, (user_id,))
            user = dict(cur.fetchone()) if cur.rowcount > 0 else None
        
        if not user:
            flash('該用戶不存在！', 'danger')
            return redirect(url_for('index'))
        
        # 渲染修改余額表單，傳遞當前用戶信息
        return render_template('update_balance.html', user=user)
    except Exception as e:
        flash(f'查詢用戶信息失敗: {str(e)}', 'danger')
        return redirect(url_for('index'))

@app.route('/user/<int:user_id>/delete', methods=['POST'])
def delete_user(user_id):
    """刪除用戶（僅支持POST請求，避免GET請求誤觸發(fā)）"""
    try:
        # 執(zhí)行刪除SQL
        delete_sql = "delete from t_user where id=%s;"
        with get_conn() as conn, conn.cursor() as cur:
            cur.execute(delete_sql, (user_id,))
            if cur.rowcount == 0:
                flash('該用戶不存在！', 'danger')
            else:
                flash('用戶刪除成功！', 'success')
    except Exception as e:
        flash(f'用戶刪除失敗: {str(e)}', 'danger')
    
    # 刪除后跳轉回首頁
    return redirect(url_for('index'))

# --------------------------
# 啟動Flask服務
# --------------------------
if __name__ == '__main__':
    # debug=True：開發(fā)模式（代碼修改后自動重啟，錯誤信息顯示在網頁上）
    app.run(debug=True)

<!DOCTYPE html>
<html lang="zh-CN">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Kingbase用戶管理系統(tǒng)</title>
    <!-- 公共CSS樣式（統(tǒng)一頁面風格） -->
    <style>
        .container { max-width: 1200px; margin: 0 auto; padding: 20px; }
        .flash { padding: 12px; margin: 15px 0; border-radius: 4px; font-size: 14px; }
        .success { background-color: #d4edda; color: #155724; border: 1px solid #c3e6cb; }
        .danger { background-color: #f8d7da; color: #721c24; border: 1px solid #f5c6cb; }
        table { width: 100%; border-collapse: collapse; margin: 20px 0; }
        th, td { padding: 12px 15px; border: 1px solid #ddd; text-align: left; }
        th { background-color: #f8f9fa; font-weight: bold; }
        tr:hover { background-color: #f8f9fa; }
        .btn { display: inline-block; padding: 8px 16px; margin: 0 5px; text-decoration: none; 
               color: #fff; border-radius: 4px; border: none; cursor: pointer; font-size: 14px; }
        .btn-primary { background-color: #007bff; }
        .btn-success { background-color: #28a745; }
        .btn-danger { background-color: #dc3545; }
        .form-group { margin-bottom: 20px; }
        label { display: block; margin-bottom: 8px; font-weight: bold; }
        input { padding: 10px; width: 350px; border: 1px solid #ddd; border-radius: 4px; 
                font-size: 14px; box-sizing: border-box; }
        h1, h2 { color: #333; margin-bottom: 20px; }
        .operate-btn-group { margin: 20px 0; }
    </style>
</head>
<body>
    <div class="container">
        <!-- 頁面標題（點擊可返回首頁） -->
        <h1><a href="/" rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  style="text-decoration: none; color: #333;">Kingbase用戶管理系統(tǒng)</a></h1>
        
        <!-- 消息提示區(qū)域（顯示success/danger消息） -->
        <div>
            {% with messages = get_flashed_messages(with_categories=true) %}
                {% if messages %}
                    {% for category, message in messages %}
                        <div class="flash {{ category }}">{{ message }}</div>
                    {% endfor %}
                {% endif %}
            {% endwith %}
        </div>
        
        <!-- 子模板內容區(qū)域（由其他頁面填充） -->
        {% block content %}{% endblock %}
    </div>
</body>
</html>

{% extends "base.html" %}  <!-- 繼承基礎模板 -->

{% block content %}  <!-- 填充content區(qū)域 -->
    <!-- 操作按鈕組（初始化表結構、新增用戶） -->
    <div class="operate-btn-group">
        <a href="/init-schema" rel="external nofollow"  class="btn btn-primary">初始化表結構</a>
        <a href="/user/create" rel="external nofollow"  class="btn btn-success">添加新用戶</a>
    </div>
    
    <!-- 用戶列表標題 -->
    <h2>用戶列表</h2>
    
    <!-- 若有用戶數(shù)據，展示表格；否則提示無數(shù)據 -->
    {% if users %}
        <table>
            <tr>
                <th>用戶ID</th>
                <th>用戶名</th>
                <th>賬戶余額（元）</th>
                <th>創(chuàng)建時間</th>
                <th>操作</th>
            </tr>
            {% for user in users %}  <!-- 循環(huán)遍歷用戶列表 -->
            <tr>
                <td>{{ user.id }}</td>
                <td>{{ user.name }}</td>
                <td>{{ user.balance }}</td>
                <td>{{ user.created_at }}</td>
                <td>
                    <!-- 查看詳情按鈕 -->
                    <a href="/user/{{ user.id }}" rel="external nofollow"  rel="external nofollow"  class="btn btn-primary">查看</a>
                    <!-- 調整余額按鈕 -->
                    <a href="/user/{{ user.id }}/balance" rel="external nofollow"  rel="external nofollow"  class="btn btn-success">調整余額</a>
                    <!-- 刪除按鈕（POST請求，需用表單包裹） -->
                    <form action="/user/{{ user.id }}/delete" method="post" style="display: inline;">
                        <button type="submit" class="btn btn-danger" 
                                onclick="return confirm('確定要刪除該用戶嗎？刪除后不可恢復！')">
                            刪除
                        </button>
                    </form>
                </td>
            </tr>
            {% endfor %}
        </table>
    {% else %}
        <p style="color: #666; font-size: 16px;">暫無用戶數(shù)據，請先初始化表結構并添加用戶。</p>
    {% endif %}
{% endblock %}

{% extends "base.html" %}

{% block content %}
    <h2>初始化用戶表結構</h2>
    <p style="font-size: 16px; margin: 20px 0;">
        點擊下方按鈕創(chuàng)建用戶表（t_user），若表已存在則不會重復創(chuàng)建。
    </p>
    <!-- 提交表單（POST請求觸發(fā)建表） -->
    <form method="post">
        <button type="submit" class="btn btn-success">確認初始化表結構</button>
        <a href="/" rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  class="btn btn-primary">返回首頁</a>
    </form>
{% endblock %}

{% extends "base.html" %}

{% block content %}
    <h2>添加新用戶</h2>
    <form method="post">
        <!-- 用戶名輸入框（必填） -->
        <div class="form-group">
            <label for="name">用戶名 <span style="color: red;">*</span></label>
            <input type="text" id="name" name="name" required 
                   placeholder="請輸入用戶名（如：張三）">
        </div>
        <!-- 初始余額輸入框（可選） -->
        <div class="form-group">
            <label for="balance">初始余額（元）</label>
            <input type="number" id="balance" name="balance" step="0.01" min="0"
                   placeholder="請輸入數(shù)字（默認0，如：100.50）">
        </div>
        <!-- 提交與返回按鈕 -->
        <button type="submit" class="btn btn-success">創(chuàng)建用戶</button>
        <a href="/" rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  class="btn btn-primary">返回首頁</a>
    </form>
{% endblock %}

{% extends "base.html" %}

{% block content %}
    <h2>用戶詳情</h2>
    {% if user %}
        <table>
            <tr>
                <th style="width: 150px;">用戶ID</th>
                <td>{{ user.id }}</td>
            </tr>
            <tr>
                <th>用戶名</th>
                <td>{{ user.name }}</td>
            </tr>
            <tr>
                <th>賬戶余額（元）</th>
                <td>{{ user.balance }}</td>
            </tr>
            <tr>
                <th>創(chuàng)建時間</th>
                <td>{{ user.created_at }}</td>
            </tr>
        </table>
        <!-- 操作按鈕 -->
        <div class="operate-btn-group">
            <a href="/user/{{ user.id }}/balance" rel="external nofollow"  rel="external nofollow"  class="btn btn-success">調整余額</a>
            <a href="/" rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  rel="external nofollow"  class="btn btn-primary">返回用戶列表</a>
        </div>
    {% endif %}
{% endblock %}

{% extends "base.html" %}

{% block content %}
    <h2>調整用戶余額</h2>
    {% if user %}
        <!-- 顯示當前用戶信息 -->
        <p style="font-size: 16px; margin: 10px 0;">
            當前用戶：<strong>{{ user.name }}</strong>（ID：{{ user.id }}）
        </p>
        <p style="font-size: 16px; margin: 10px 0;">
            當前余額：<strong>{{ user.balance }} 元</strong>
        </p>
        
        <!-- 余額變動表單 -->
        <form method="post">
            <div class="form-group">
                <label for="delta">余額變動值（元）</label>
                <input type="number" id="delta" name="delta" step="0.01" required
                       placeholder="正數(shù)增加，負數(shù)減少（如：50.00 或 -20.50）">
                <small style="color: #666; display: block; margin-top: 5px;">
                    提示：輸入正數(shù)表示增加余額，輸入負數(shù)表示減少余額（如輸入-10表示減少10元）
                </small>
            </div>
            <!-- 提交與返回按鈕 -->
            <button type="submit" class="btn btn-success">確認更新</button>
            <a href="/user/{{ user.id }}" rel="external nofollow"  rel="external nofollow"  class="btn btn-primary">返回詳情</a>
        </form>
    {% endif %}
{% endblock %}

python app.py

* Serving Flask app 'app'
* Debug mode: on
WARNING: This is a development server. Do not use it in a production deployment.
* Running on http://127.0.0.1:5000
Press CTRL+C to quit

grant create on schema public to system;