feat: align JS exports to PascalCase and flatten default instance (by AI)

refactor: use jsmod.Get for context configuration (by AI)
feat: add SetConfig for dynamic configuration (by AI)
2026-06-10 12:12:36 +08:00 · 2026-06-10 09:52:55 +08:00 · 2026-06-08 20:47:51 +08:00 · 2026-06-05 11:28:53 +08:00 · 2026-06-05 08:39:33 +08:00 · 2026-06-04 20:48:57 +08:00
7 changed files with 427 additions and 204 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@ -1,5 +1,20 @@
 # 变更记录 - @go/db

+## [1.5.3] - 2026-06-08
+- **新增**: `SetConfig(name, setting string)` 方法，支持动态配置数据库连接（不依赖配置文件），方便通过别名获取连接。
+- **优化**: 重构配置加载逻辑，支持动态配置与 `config/db.yaml` 配置文件配置共存。
+
+## [1.5.2] - 2026-06-05
+- **架构重构: 两阶段 (Two-Pass) 索引命名生成**:
+  - 重构了 `CheckTable` 中的 Schema 同步逻辑，从“边解析边生成”改为两阶段处理。现在多列联合索引（无论是 Unique, Index 还是 Fulltext）的名字会根据包含的**字段名称自动拼接生成**（如 `uk_user_name_phone`），替代了以前难以溯源的分组号（如 `uk_user_1`），极大提升了 DBA 在数据库维护时的可读性与直观性。
+  - **超长防断机制**: 当生成的索引名称超过 60 个字符时，自动进行截断，并在末尾追加原完整名称的 6 位 MD5 Hash，完美规避了各种 RDBMS 对标识符 64 字符长度限制引发的建表错误。
+- **稳定性修复: 幂等性增强**:
+  - 为所有支持的数据库（特别是 SQLite 和 PostgreSQL）的 `CREATE INDEX` 及 `CREATE UNIQUE INDEX` 语句增加了 `IF NOT EXISTS` 容错保护。
+  - **SQLite 特效探测**: 修复了对 SQLite 多列索引结构探测的 Bug，现在它能准确匹配基于列组隐式创建的索引（如 `sqlite_autoindex`），并将其视作等效的已存在约束跳过重建。彻底根除了在系统重启及结构同步期间偶现的 `UNIQUE constraint failed` 致命崩溃。
+
+## [1.5.0] - 2026-05-10
+- **基础设施对齐**: 全局对齐至 v1.5.0。
+
 ## [1.3.5] - 2026-05-30
 - **新增**: 注册到 `jsmod`。
 - **安全性**: 引入基于 Context 的细粒度权限控制。在 `SafeMode` 下，仅允许读取操作（Query），所有写操作（Exec/Insert/Update/Delete/Replace）将被拦截并返回错误。严禁通过 JS 动态创建连接或同步 Schema。
--- a/DB.go
+++ b/DB.go
@ -412,6 +412,59 @@ func Begin() *Tx {
 	return d.Begin()
 }

+func SetConfig(name, setting string) {
+	loadConfigs(nil)
+	conf := new(Config)
+	conf.ConfigureBy(setting)
+	dbConfigsLock.Lock()
+	dbConfigs[name] = conf
+	dbConfigsLock.Unlock()
+}
+
+func loadConfigs(logger *log.Logger) {
+	once.Do(func() {
+		if logger == nil {
+			logger = log.DefaultLogger
+		}
+		dbConfigs1 := make(map[string]*Config)
+		if err := config.Load(&dbConfigs1, "db"); err == nil {
+			for k, v := range dbConfigs1 {
+				if v.Host != "" {
+					dbConfigsLock.Lock()
+					dbConfigs[k] = v
+					dbConfigsLock.Unlock()
+				}
+			}
+		} else {
+			logger.Error(err.Error())
+		}
+		dbConfigs2 := make(map[string]string)
+		if err := config.Load(&dbConfigs2, "db"); err == nil {
+			for k, v := range dbConfigs2 {
+				if strings.Contains(v, "://") {
+					v2 := new(Config)
+					v2.ConfigureBy(v)
+					if v2.Host != "" {
+						v2.logger = logger
+						dbConfigsLock.Lock()
+						dbConfigs[k] = v2
+						dbConfigsLock.Unlock()
+					}
+				} else {
+					dbConfigsLock.Lock()
+					v2 := dbConfigs[v]
+					if v2 != nil && v2.Host != "" {
+						dbConfigs[k] = v2
+					}
+					dbConfigsLock.Unlock()
+				}
+			}
+		} else {
+			logger.Error(err.Error())
+		}
+	})
+}
+
 func getDB(name string, logger *log.Logger, useCache bool) *DB {
 	if logger == nil {
 		logger = log.DefaultLogger
@ -432,49 +485,7 @@ func getDB(name string, logger *log.Logger, useCache bool) *DB {
 		conf.logger = logger
 		conf.ConfigureBy(name)
 	} else {
-		dbConfigsLock.RLock()
-		n := len(dbConfigs)
-		dbConfigsLock.RUnlock()
-		if n == 0 {
-			once.Do(func() {
-				dbConfigs1 := make(map[string]*Config)
-				if err := config.Load(&dbConfigs1, "db"); err == nil {
-					for k, v := range dbConfigs1 {
-						if v.Host != "" {
-							dbConfigsLock.Lock()
-							dbConfigs[k] = v
-							dbConfigsLock.Unlock()
-						}
-					}
-				} else {
-					logger.Error(err.Error())
-				}
-				dbConfigs2 := make(map[string]string)
-				if err := config.Load(&dbConfigs2, "db"); err == nil {
-					for k, v := range dbConfigs2 {
-						if strings.Contains(v, "://") {
-							v2 := new(Config)
-							v2.ConfigureBy(v)
-							if v2.Host != "" {
-								v2.logger = logger
-								dbConfigsLock.Lock()
-								dbConfigs[k] = v2
-								dbConfigsLock.Unlock()
-							}
-						} else {
-							dbConfigsLock.Lock()
-							v2 := dbConfigs[v]
-							if v2 != nil && v2.Host != "" {
-								dbConfigs[k] = v2
-							}
-							dbConfigsLock.Unlock()
-						}
-					}
-				} else {
-					logger.Error(err.Error())
-				}
-			})
-		}
+		loadConfigs(logger)
 		dbConfigsLock.RLock()
 		conf = dbConfigs[name]
 		dbConfigsLock.RUnlock()
--- a/README.md
+++ b/README.md
@ -22,8 +22,10 @@ go get apigo.cc/go/db
 ## 🛠 API 指南

 ### 1. 核心方法
+- **`SetConfig(name, setting string)`**
+  - 动态设置数据库配置（不依赖配置文件），可通过别名获取连接。
 - **`GetDB(name string, logger *log.Logger) *DB`**
-  - 获取数据库连接实例。`name` 可以是 `db.json` 中的配置名，也可以是标准 DSN（如 `mysql://user:pwd@host:port/db` 或 `sqlite://test.db`）。
+  - 获取数据库连接实例。`name` 可以是别名、`db.json` 中的配置名，也可以是标准 DSN（如 `mysql://user:pwd@host:port/db` 或 `sqlite://test.db`）。
 - **`Sync(schema string) error`**
  - 解析 DSL 并同步数据库表结构。用于创建表（包括 `_deleted` 表）和索引。详见 [架构 DSL 指南](./DSL.md)。

--- a/Schema.go
+++ b/Schema.go
@ -1,6 +1,8 @@
 package db

 import (
+	"crypto/md5"
+	"encoding/hex"
 	"fmt"
 	"regexp"
 	"strings"
@ -321,84 +323,106 @@ func (db *DB) CheckTable(table *TableStruct) error {
 	isPostgres := db.Config.Type == "pg" || db.Config.Type == "pgsql" || db.Config.Type == "postgres"

 	table.Columns = make([]string, 0, len(table.Fields))
+
+	// 阶段一：收集所有属于同一索引组的字段
+	type indexGroupDef struct {
+		Type   string
+		Fields []string
+	}
+	indexGroups := make(map[string]*indexGroupDef)
+
 	for i, field := range table.Fields {
 		field.Parse(db.Config.Type)
 		table.Fields[i] = field
 		table.Columns = append(table.Columns, field.Name)

-		switch strings.ToLower(field.Index) {
-		case "pk", "primary key":
+		idxType := strings.ToLower(field.Index)
+		if idxType == "pk" || idxType == "primary key" {
 			pks = append(pks, field.Name)
-		case "unique":
-			keyName := fmt.Sprint("uk_", table.Name, "_", field.Name)
-			if field.IndexGroup != "" {
-				keyName = fmt.Sprint("uk_", table.Name, "_", field.IndexGroup)
+		} else if idxType == "unique" || idxType == "index" || idxType == "fulltext" {
+			group := field.IndexGroup
+			if group == "" {
+				group = field.Name
 			}
-			if keySetBy[keyName] != "" {
-				keySetFields[keyName] += " " + field.Name
-				if strings.HasPrefix(db.Config.Type, "sqlite") || db.Config.Type == "chai" {
-					keySetBy[keyName] = strings.Replace(keySetBy[keyName], ")", ", "+db.Quote(field.Name)+")", 1)
-				} else if isPostgres {
-					keySetBy[keyName] = strings.Replace(keySetBy[keyName], ")", ", "+db.Quote(field.Name)+")", 1)
-				} else {
-					keySetBy[keyName] = strings.Replace(keySetBy[keyName], ") COMMENT", ", "+db.Quote(field.Name)+") COMMENT", 1)
+			groupKey := idxType + "_" + group
+			if _, exists := indexGroups[groupKey]; !exists {
+				indexGroups[groupKey] = &indexGroupDef{Type: idxType, Fields: []string{}}
+			}
+			indexGroups[groupKey].Fields = append(indexGroups[groupKey].Fields, field.Name)
+		}
+	}
+
+	// 阶段二：生成字段定义与索引定义
+	processedGroups := make(map[string]bool)
+
+	for _, field := range table.Fields {
+		idxType := strings.ToLower(field.Index)
+		if idxType == "unique" || idxType == "index" || idxType == "fulltext" {
+			group := field.IndexGroup
+			if group == "" {
+				group = field.Name
+			}
+			groupKey := idxType + "_" + group
+
+			if !processedGroups[groupKey] {
+				processedGroups[groupKey] = true
+				groupDef := indexGroups[groupKey]
+
+				// 根据组合的字段名拼接生成长索引名
+				joinedFields := strings.Join(groupDef.Fields, "_")
+				prefix := "ik"
+				if idxType == "unique" {
+					prefix = "uk"
+				} else if idxType == "fulltext" {
+					prefix = "tk"
 				}
-			} else {
-				keySetFields[keyName] = field.Name
-				keySet := ""
-				if strings.HasPrefix(db.Config.Type, "sqlite") || db.Config.Type == "chai" {
-					keySet = fmt.Sprintf("CREATE UNIQUE INDEX \"%s\" ON \"%s\" (\"%s\")", keyName, table.Name, field.Name)
-				} else if isPostgres {
-					keySet = fmt.Sprintf("CREATE UNIQUE INDEX \"%s\" ON \"%s\" (\"%s\")", keyName, table.Name, field.Name)
-				} else {
-					keySet = fmt.Sprintf("UNIQUE KEY "+db.Quote("%s")+" ("+db.Quote("%s")+") COMMENT '%s'", keyName, field.Name, field.Comment)
+				keyName := fmt.Sprintf("%s_%s_%s", prefix, table.Name, joinedFields)
+
+				// 防超长截断处理 (最大 64，留 4 个给安全余量，设为 60)
+				if len(keyName) > 60 {
+					hash := md5.Sum([]byte(keyName))
+					hashStr := hex.EncodeToString(hash[:])[:6]
+					keyName = keyName[:53] + "_" + hashStr
 				}
-				keySets = append(keySets, keySet)
-				keySetBy[keyName] = keySet
-			}
-		case "fulltext":
-			ftsFields = append(ftsFields, field.Name)
-			keyName := fmt.Sprint("tk_", table.Name, "_", field.Name)
-			keySet := ""
-			if isPostgres {
-				// 使用 simple 分词器，配合应用层的分词结果
-				keySet = fmt.Sprintf("CREATE INDEX \"%s\" ON \"%s\" USING GIN (to_tsvector('simple', \"%s\"))", keyName, table.Name, field.Name)
-			} else if !strings.HasPrefix(db.Config.Type, "sqlite") && db.Config.Type != "chai" {
-				keySet = fmt.Sprintf("FULLTEXT KEY "+db.Quote("%s")+" ("+db.Quote("%s")+") COMMENT '%s'", keyName, field.Name, field.Comment)
-			} else {
-				// SQLite 使用 FTS5，这里不生成普通索引
-				keySet = ""
-			}
-			if keySet != "" {
-				keySets = append(keySets, keySet)
-				keySetBy[keyName] = keySet
-			}
-		case "index":
-			keyName := fmt.Sprint("ik_", table.Name, "_", field.Name)
-			if field.IndexGroup != "" {
-				keyName = fmt.Sprint("ik_", table.Name, "_", field.IndexGroup)
-			}
-			if keySetBy[keyName] != "" {
-				keySetFields[keyName] += " " + field.Name
-				if strings.HasPrefix(db.Config.Type, "sqlite") || db.Config.Type == "chai" {
-					keySetBy[keyName] = strings.Replace(keySetBy[keyName], ")", ", \""+field.Name+"\")", 1)
-				} else if isPostgres {
-					keySetBy[keyName] = strings.Replace(keySetBy[keyName], ")", ", \""+field.Name+"\")", 1)
-				} else {
-					keySetBy[keyName] = strings.Replace(keySetBy[keyName], ") COMMENT", ", `"+field.Name+"`) COMMENT", 1)
+
+				keySetFields[keyName] = strings.Join(groupDef.Fields, " ")
+
+				if idxType == "fulltext" {
+					ftsFields = append(ftsFields, groupDef.Fields...)
+					keySet := ""
+					if isPostgres {
+						// PostgreSQL 使用 simple 分词器
+						keySet = fmt.Sprintf("CREATE INDEX IF NOT EXISTS \"%s\" ON \"%s\" USING GIN (to_tsvector('simple', \"%s\"))", keyName, table.Name, groupDef.Fields[0])
+					} else if !strings.HasPrefix(db.Config.Type, "sqlite") && db.Config.Type != "chai" {
+						keySet = fmt.Sprintf("FULLTEXT KEY "+db.Quote("%s")+" ("+db.Quotes(groupDef.Fields)+") COMMENT '%s'", keyName, field.Comment)
+					}
+					if keySet != "" {
+						keySets = append(keySets, keySet)
+						keySetBy[keyName] = keySet
+					}
+				} else if idxType == "unique" {
+					keySet := ""
+					if strings.HasPrefix(db.Config.Type, "sqlite") || db.Config.Type == "chai" {
+						keySet = fmt.Sprintf("CREATE UNIQUE INDEX IF NOT EXISTS \"%s\" ON \"%s\" (%s)", keyName, table.Name, db.Quotes(groupDef.Fields))
+					} else if isPostgres {
+						keySet = fmt.Sprintf("CREATE UNIQUE INDEX IF NOT EXISTS \"%s\" ON \"%s\" (%s)", keyName, table.Name, db.Quotes(groupDef.Fields))
+					} else {
+						keySet = fmt.Sprintf("UNIQUE KEY "+db.Quote("%s")+" ("+db.Quotes(groupDef.Fields)+") COMMENT '%s'", keyName, field.Comment)
+					}
+					keySets = append(keySets, keySet)
+					keySetBy[keyName] = keySet
+				} else { // index
+					keySet := ""
+					if strings.HasPrefix(db.Config.Type, "sqlite") || db.Config.Type == "chai" {
+						keySet = fmt.Sprintf("CREATE INDEX IF NOT EXISTS \"%s\" ON \"%s\" (%s)", keyName, table.Name, db.Quotes(groupDef.Fields))
+					} else if isPostgres {
+						keySet = fmt.Sprintf("CREATE INDEX IF NOT EXISTS \"%s\" ON \"%s\" (%s)", keyName, table.Name, db.Quotes(groupDef.Fields))
+					} else {
+						keySet = fmt.Sprintf("KEY "+db.Quote("%s")+" ("+db.Quotes(groupDef.Fields)+") COMMENT '%s'", keyName, field.Comment)
+					}
+					keySets = append(keySets, keySet)
+					keySetBy[keyName] = keySet
 				}
-			} else {
-				keySetFields[keyName] = field.Name
-				keySet := ""
-				if strings.HasPrefix(db.Config.Type, "sqlite") || db.Config.Type == "chai" {
-					keySet = fmt.Sprintf("CREATE INDEX \"%s\" ON \"%s\" (\"%s\")", keyName, table.Name, field.Name)
-				} else if isPostgres {
-					keySet = fmt.Sprintf("CREATE INDEX \"%s\" ON \"%s\" (\"%s\")", keyName, table.Name, field.Name)
-				} else {
-					keySet = fmt.Sprintf("KEY "+db.Quote("%s")+" ("+db.Quote("%s")+") COMMENT '%s'", keyName, field.Name, field.Comment)
-				}
-				keySets = append(keySets, keySet)
-				keySetBy[keyName] = keySet
 			}
 		}
 		fieldSets = append(fieldSets, field.Desc)
@ -419,6 +443,7 @@ func (db *DB) CheckTable(table *TableStruct) error {
 		oldFieldList := make([]*tableFieldDesc, 0)
 		oldFields := make(map[string]*tableFieldDesc)
 		oldIndexes := make(map[string]string)
+		oldUniqueMap := make(map[string]bool)
 		oldIndexInfos := make([]*tableKeyDesc, 0)
 		oldComments := map[string]string{}

@ -452,6 +477,7 @@ func (db *DB) CheckTable(table *TableStruct) error {
 				return err
 			}
 			for _, i := range tmpIndexes {
+				oldUniqueMap[i.Name] = i.Unique == 1
 				tmpIndexInfo := []struct {
 					Name  string
 					Seqno int
@ -460,10 +486,10 @@ func (db *DB) CheckTable(table *TableStruct) error {
 				if err := db.Query("PRAGMA index_info(" + db.Quote(i.Name) + ")").To(&tmpIndexInfo); err != nil {
 					return err
 				}
-				if len(tmpIndexInfo) > 0 {
+				for _, ii := range tmpIndexInfo {
 					oldIndexInfos = append(oldIndexInfos, &tableKeyDesc{
 						Key_name:    i.Name,
-						Column_name: tmpIndexInfo[0].Name,
+						Column_name: ii.Name,
 					})
 				}
 			}
@ -602,7 +628,22 @@ func (db *DB) CheckTable(table *TableStruct) error {

 		for keyId, keySet := range keySetBy {
 			if oldIndexes[keyId] == "" || (!isPostgres && strings.ToLower(oldIndexes[keyId]) != strings.ToLower(keySetFields[keyId])) {
-				if strings.HasPrefix(db.Config.Type, "sqlite") || isPostgres {
+				if strings.HasPrefix(db.Config.Type, "sqlite") {
+					// 针对 SQLite 优化：如果索引名不匹配，但存在一个相同列组的唯一索引（如 sqlite_autoindex），则跳过
+					if strings.Contains(keySet, "UNIQUE") {
+						foundUnique := false
+						for oldName, oldCols := range oldIndexes {
+							if oldUniqueMap[oldName] && strings.ToLower(oldCols) == strings.ToLower(keySetFields[keyId]) {
+								foundUnique = true
+								break
+							}
+						}
+						if foundUnique {
+							continue
+						}
+					}
+					actions = append(actions, keySet)
+				} else if isPostgres {
 					actions = append(actions, keySet)
 				} else {
 					actions = append(actions, "ADD "+keySet)
--- a/go.mod
+++ b/go.mod
@ -3,25 +3,25 @@ module apigo.cc/go/db
 go 1.25.0

 require (
-	apigo.cc/go/cast v1.3.3
-	apigo.cc/go/config v1.3.1
-	apigo.cc/go/crypto v1.3.1
-	apigo.cc/go/file v1.3.2
-	apigo.cc/go/id v1.3.1
-	apigo.cc/go/jsmod v1.0.1
-	apigo.cc/go/log v1.3.4
-	apigo.cc/go/redis v1.3.2
-	apigo.cc/go/safe v1.3.1
-	apigo.cc/go/shell v1.3.1
+	apigo.cc/go/cast v1.5.0
+	apigo.cc/go/config v1.5.1
+	apigo.cc/go/crypto v1.5.0
+	apigo.cc/go/file v1.5.0
+	apigo.cc/go/id v1.5.0
+	apigo.cc/go/jsmod v1.5.0
+	apigo.cc/go/log v1.5.4
+	apigo.cc/go/redis v1.5.0
+	apigo.cc/go/safe v1.5.0
+	apigo.cc/go/shell v1.5.0
 	github.com/go-sql-driver/mysql v1.10.0
 	github.com/jackc/pgx/v5 v5.9.2
 	github.com/mitchellh/mapstructure v1.5.0
-	modernc.org/sqlite v1.50.0
+	modernc.org/sqlite v1.51.0
 )

 require (
-	apigo.cc/go/encoding v1.3.1 // indirect
-	apigo.cc/go/rand v1.3.1 // indirect
+	apigo.cc/go/encoding v1.5.0 // indirect
+	apigo.cc/go/rand v1.5.0 // indirect
 	filippo.io/edwards25519 v1.2.0 // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
 	github.com/gomodule/redigo v2.0.0+incompatible // indirect
@ -29,15 +29,15 @@ require (
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
 	github.com/jackc/puddle/v2 v2.2.2 // indirect
-	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mattn/go-isatty v0.0.22 // indirect
 	github.com/ncruces/go-strftime v1.0.0 // indirect
 	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
-	golang.org/x/crypto v0.51.0 // indirect
+	golang.org/x/crypto v0.52.0 // indirect
 	golang.org/x/sync v0.20.0 // indirect
-	golang.org/x/sys v0.44.0 // indirect
+	golang.org/x/sys v0.45.0 // indirect
 	golang.org/x/text v0.37.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
-	modernc.org/libc v1.72.0 // indirect
+	modernc.org/libc v1.72.5 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
 	modernc.org/memory v1.11.0 // indirect
 )
--- a/go.sum
+++ b/go.sum
@ -1,27 +1,27 @@
-apigo.cc/go/cast v1.3.3 h1:aln5eDR5DZVWVzZ/y5SJh1gQNgWv2sT82I25NaO9g34=
-apigo.cc/go/cast v1.3.3/go.mod h1:lGlwImiOvHxG7buyMWhFzcdvQzmSaoKbmr7bcDfUpHk=
-apigo.cc/go/config v1.3.1 h1:wZzUh4oL+fGD6SayVgX6prLPMsniM25etWFcEH8XzIE=
-apigo.cc/go/config v1.3.1/go.mod h1:7KHz/1WmtBLM762Lln/TaXh2dmlMvJTLhnlk33zbS3U=
-apigo.cc/go/crypto v1.3.1 h1:ulQ2zX9bUWirk0sEacx1Srsjs2Jow7HlZq7ED7msNcg=
-apigo.cc/go/crypto v1.3.1/go.mod h1:SwHlBFDPddttWgFFtzsEMla8CM/rcFy9nvdsJjW4CIs=
-apigo.cc/go/encoding v1.3.1 h1:y8O58KYAyulkThg1O2ji2BqjnFoSvk42sit9I3z+K7Y=
-apigo.cc/go/encoding v1.3.1/go.mod h1:xAJk5b83VZ31mXMTnyp0dfMoBKfT/AHDn0u+cQfojgY=
-apigo.cc/go/file v1.3.2 h1:pu4oiDyiqgj3/eykfnJf+/6+A9v/Z0b3ClP5XK+lwG4=
-apigo.cc/go/file v1.3.2/go.mod h1:vci4h0Pz94mV6dkniQkuyBYERVYeq7/LX4jJVuCg9hs=
-apigo.cc/go/id v1.3.1 h1:pkqi6VeWyQoHuIu0Zbx/RRxIAdM61Js0j6cY1M9XVCk=
-apigo.cc/go/id v1.3.1/go.mod h1:P2/vl3tyW3US+ayOFSMoPIOCulNLBngNYPhXJC/Z7J4=
-apigo.cc/go/jsmod v1.0.1 h1:vaz3cMQi75UVoALLfyV/Trs8iP/Nh28yN57IvBFpPGk=
-apigo.cc/go/jsmod v1.0.1/go.mod h1:bmyeZtOAP/j5am+YRnaiM89smysK24K7ebk0koFtsSw=
-apigo.cc/go/log v1.3.4 h1:UT8Neb9r4QjjbCFbTzw+ZeTxd+DmdmR5gNExeR4Cj+g=
-apigo.cc/go/log v1.3.4/go.mod h1:/Q/2r51xWSsrS4QN5U9jLiTw8n6qNC8kG9nuVHweY20=
-apigo.cc/go/rand v1.3.1 h1:7FvsI6PtQ5XrWER0dTiLVo0p7GIxRidT/TBKhVy93j8=
-apigo.cc/go/rand v1.3.1/go.mod h1:mZ/4Soa3bk+XvDaqPWJuUe1bfEi4eThBj1XmEAuYxsk=
-apigo.cc/go/redis v1.3.2 h1:iUWL/CHHnfonz0dJq6/V4IG3QuXBoHA2L1xnoGEbNEQ=
-apigo.cc/go/redis v1.3.2/go.mod h1:/k5wcfAzB9jrfd9otabio9CPUxEsLPgEs4oggBG5sbs=
-apigo.cc/go/safe v1.3.1 h1:irTCqPAC97gGsX/Lw5AzLelDt1xXLEZIAaVhLELWe9Q=
-apigo.cc/go/safe v1.3.1/go.mod h1:XdOpBhN2vkImalaykYXXmEpczqWa1y3ah6/Q72cdRqE=
-apigo.cc/go/shell v1.3.1 h1:M8oD0b2HcJuCC6frQFx11b3UTcTx3lATX8XK+YXSVm8=
-apigo.cc/go/shell v1.3.1/go.mod h1:ZMdJjpCpWdvsHKUXlelh/AxsV/nWdkH/k3lISfzMdUw=
+apigo.cc/go/cast v1.5.0 h1:UBGJtFQ8eJPMQXs37cUgqd7YQo1zI9opuSDBDmn2/pE=
+apigo.cc/go/cast v1.5.0/go.mod h1:z2GW5p5WCZGEqVVIJUdhl232vRbLf2Qu4EDlEakX/D8=
+apigo.cc/go/config v1.5.1 h1:rpj7oCzlsDV3f2/YK3Pb+CHbfr2DL5Vyyv6VNkobJP4=
+apigo.cc/go/config v1.5.1/go.mod h1:jdMiDLPa9gzB8/FFZvm9jOopUqdxb7XSX+0OeWcZZUM=
+apigo.cc/go/crypto v1.5.0 h1:Nxz7a6VKCdvaF258IU0NkjQyureOLxfR308Sy2iftUI=
+apigo.cc/go/crypto v1.5.0/go.mod h1:F9M6nXv+5328r1ZwbTvI6fcr8VdgqHVzALOcsdv6ntE=
+apigo.cc/go/encoding v1.5.0 h1:EJNdRVDOMoI2DAvZwQNQTbYuqB/6zsEzvg7lS5pQI+I=
+apigo.cc/go/encoding v1.5.0/go.mod h1:8++NfZj3hWig0qh2g7GQRw/4LpSvCYMWUZ+8J+x58cA=
+apigo.cc/go/file v1.5.0 h1:Fh1NSDBqaxjuXYJ71yPHPXVJ8BFEv/AGS3l+jkLi5uw=
+apigo.cc/go/file v1.5.0/go.mod h1:4YhOGgBINTpmmmgws3H8LAyXQQBGzBp44hYUoCS+kr0=
+apigo.cc/go/id v1.5.0 h1:MjNWPhBhDsoXaLeJDv/0wfJmVMU9EvOs8pWYfsTQ6e8=
+apigo.cc/go/id v1.5.0/go.mod h1:qhu4a1/KLc/XcBpcsRu+mXZt7U7Wvd9zMcPs4VspuPA=
+apigo.cc/go/jsmod v1.5.0 h1:JgQtJNiJWy1NOP9AzE8NX5VXJkpO/x3GqLsCCSny5Ec=
+apigo.cc/go/jsmod v1.5.0/go.mod h1:bmyeZtOAP/j5am+YRnaiM89smysK24K7ebk0koFtsSw=
+apigo.cc/go/log v1.5.4 h1:LNyU4v09gfcnZOY53ctnXoKzo45FHoEcPR33lk6PBaY=
+apigo.cc/go/log v1.5.4/go.mod h1:Djy+I5aLhGB/EjwRz4KHqkVEz584IAD55FAFiIfInuo=
+apigo.cc/go/rand v1.5.0 h1:1o8hh8fhdBuk1/h02IvugvamuT3dkWbVJrqEJVQKB2E=
+apigo.cc/go/rand v1.5.0/go.mod h1:Lh98S2dm9UY0X+M+kNQQEKyXHG5pcCKSFPyXN0QCGdk=
+apigo.cc/go/redis v1.5.0 h1:VXNDqzKj87BchF7ubDEH+T6lp8NrjeK0izU4ooo7u1A=
+apigo.cc/go/redis v1.5.0/go.mod h1:/olsrHndkUNezUX1KbBBt8b4Got7SX7E8EJzcb1PknM=
+apigo.cc/go/safe v1.5.0 h1:W1NblmcU8cex1f9Y5z8mNLUJOzZTE1s6fszb3FbhGnk=
+apigo.cc/go/safe v1.5.0/go.mod h1:OfQ5d6COePSGEuPvMeOk6KagX2sezw7nvKh7exj9SeM=
+apigo.cc/go/shell v1.5.0 h1:WLDMMqUU0INeaBDmQsTPr0h/NfB2RknAtiJ5NL467+Q=
+apigo.cc/go/shell v1.5.0/go.mod h1:rYHA77d5hEsQHcJrbAWf1pHy0sxayeJ0gU55LA/JWQk=
 filippo.io/edwards25519 v1.2.0 h1:crnVqOiS4jqYleHd9vaKZ+HKtHfllngJIiOpNpoJsjo=
 filippo.io/edwards25519 v1.2.0/go.mod h1:xzAOLCNug/yB62zG1bQ8uziwrIqIuxhctzJT18Q77mc=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@ -51,8 +51,7 @@ github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
 github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
-github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
-github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+github.com/mattn/go-isatty v0.0.22 h1:j8l17JJ9i6VGPUFUYoTUKPSgKe/83EYU2zBC7YNKMw4=
 github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
 github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
 github.com/ncruces/go-strftime v1.0.0 h1:HMFp8mLCTPp341M/ZnA4qaf7ZlsbTc+miZjCLOFAw7w=
@ -68,15 +67,14 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
-golang.org/x/crypto v0.51.0 h1:IBPXwPfKxY7cWQZ38ZCIRPI50YLeevDLlLnyC5wRGTI=
-golang.org/x/crypto v0.51.0/go.mod h1:8AdwkbraGNABw2kOX6YFPs3WM22XqI4EXEd8g+x7Oc8=
+golang.org/x/crypto v0.52.0 h1:RMs7fP2rXdep0CftQlK8Uf+kibLm7qkCcradZWYz988=
+golang.org/x/crypto v0.52.0/go.mod h1:1QgfPxDqh0T2M/elOJtp9RvuR95kVjir0e6/BvEmGbc=
 golang.org/x/mod v0.35.0 h1:Ww1D637e6Pg+Zb2KrWfHQUnH2dQRLBQyAtpr/haaJeM=
 golang.org/x/mod v0.35.0/go.mod h1:+GwiRhIInF8wPm+4AoT6L0FA1QWAad3OMdTRx4tFYlU=
 golang.org/x/sync v0.20.0 h1:e0PTpb7pjO8GAtTs2dQ6jYa5BWYlMuX047Dco/pItO4=
 golang.org/x/sync v0.20.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
-golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.44.0 h1:ildZl3J4uzeKP07r2F++Op7E9B29JRUy+a27EibtBTQ=
-golang.org/x/sys v0.44.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
+golang.org/x/sys v0.45.0 h1:dO4czNzziLiiXplLQgBCEpCvXQ3dnkn0SdaZSYdQ+FY=
+golang.org/x/sys v0.45.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
 golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
 golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
 golang.org/x/tools v0.44.0 h1:UP4ajHPIcuMjT1GqzDWRlalUEoY+uzoZKnhOjbIPD2c=
@ -87,30 +85,24 @@ gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EV
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-modernc.org/cc/v4 v4.27.3 h1:uNCgn37E5U09mTv1XgskEVUJ8ADKpmFMPxzGJ0TSo+U=
-modernc.org/cc/v4 v4.27.3/go.mod h1:3YjcbCqhoTTHPycJDRl2WZKKFj0nwcOIPBfEZK0Hdk8=
-modernc.org/ccgo/v4 v4.32.4 h1:L5OB8rpEX4ZsXEQwGozRfJyJSFHbbNVOoQ59DU9/KuU=
-modernc.org/ccgo/v4 v4.32.4/go.mod h1:lY7f+fiTDHfcv6YlRgSkxYfhs+UvOEEzj49jAn2TOx0=
+modernc.org/cc/v4 v4.28.2 h1:3tQ0lf2ADtoby2EtSP+J7IE2SHwEJdP8ioR59wx7XpY=
+modernc.org/ccgo/v4 v4.34.2 h1:mxsy2FdrB6+qG3NfXefz1AmWv0ehOSDO4jxgxd7h9yo=
 modernc.org/fileutil v1.4.0 h1:j6ZzNTftVS054gi281TyLjHPp6CPHr2KCxEXjEbD6SM=
 modernc.org/fileutil v1.4.0/go.mod h1:EqdKFDxiByqxLk8ozOxObDSfcVOv/54xDs/DUHdvCUU=
 modernc.org/gc/v2 v2.6.5 h1:nyqdV8q46KvTpZlsw66kWqwXRHdjIlJOhG6kxiV/9xI=
 modernc.org/gc/v2 v2.6.5/go.mod h1:YgIahr1ypgfe7chRuJi2gD7DBQiKSLMPgBQe9oIiito=
-modernc.org/gc/v3 v3.1.2 h1:ZtDCnhonXSZexk/AYsegNRV1lJGgaNZJuKjJSWKyEqo=
-modernc.org/gc/v3 v3.1.2/go.mod h1:HFK/6AGESC7Ex+EZJhJ2Gni6cTaYpSMmU/cT9RmlfYY=
+modernc.org/gc/v3 v3.1.3 h1:6QAplYyVO+KdPW3pGnqmJDUxtkec8ooEWvks/hhU3lc=
 modernc.org/goabi0 v0.2.0 h1:HvEowk7LxcPd0eq6mVOAEMai46V+i7Jrj13t4AzuNks=
 modernc.org/goabi0 v0.2.0/go.mod h1:CEFRnnJhKvWT1c1JTI3Avm+tgOWbkOu5oPA8eH8LnMI=
-modernc.org/libc v1.72.0 h1:IEu559v9a0XWjw0DPoVKtXpO2qt5NVLAnFaBbjq+n8c=
-modernc.org/libc v1.72.0/go.mod h1:tTU8DL8A+XLVkEY3x5E/tO7s2Q/q42EtnNWda/L5QhQ=
+modernc.org/libc v1.72.5 h1:m2OGx9Ser1VvTS4Z9ZJlWs+CBMxutLaTiAWkNz+NB9U=
 modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
 modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
 modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=
 modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
-modernc.org/opt v0.1.4 h1:2kNGMRiUjrp4LcaPuLY2PzUfqM/w9N23quVwhKt5Qm8=
-modernc.org/opt v0.1.4/go.mod h1:03fq9lsNfvkYSfxrfUhZCWPk1lm4cq4N+Bh//bEtgns=
+modernc.org/opt v0.2.0 h1:tGyef5ApycA7FSEOMraay9SaTk5zmbx7Tu+cJs4QKZg=
 modernc.org/sortutil v1.2.1 h1:+xyoGf15mM3NMlPDnFqrteY07klSFxLElE2PVuWIJ7w=
 modernc.org/sortutil v1.2.1/go.mod h1:7ZI3a3REbai7gzCLcotuw9AC4VZVpYMjDzETGsSMqJE=
-modernc.org/sqlite v1.50.0 h1:eMowQSWLK0MeiQTdmz3lqoF5dqclujdlIKeJA11+7oM=
-modernc.org/sqlite v1.50.0/go.mod h1:m0w8xhwYUVY3H6pSDwc3gkJ/irZT/0YEXwBlhaxQEew=
+modernc.org/sqlite v1.51.0 h1:aH/MMSoayAIhozZ7uJbVTT9QO/VhzBf0J9tymmmuC/U=
 modernc.org/strutil v1.2.1 h1:UneZBkQA+DX2Rp35KcM69cSsNES9ly8mQWD71HKlOA0=
 modernc.org/strutil v1.2.1/go.mod h1:EHkiggD70koQxjVdSBM3JKM7k6L0FbGE5eymy9i3B9A=
 modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=
--- a/js_export.go
+++ b/js_export.go
@ -3,82 +3,244 @@ package db
 import (
 	"context"
 	"errors"
+	"strings"

+	"apigo.cc/go/cast"
+	"apigo.cc/go/file"
 	"apigo.cc/go/jsmod"
 )

 func init() {
 	jsmod.Register("db", map[string]any{
-		"get": func(ctx context.Context, name string) (*jsDB, error) {
-			d := GetDB(name, nil)
-			if d.Error != nil {
-				return nil, d.Error
+		// 入口：支持别名获取，不传则默认 "default"
+		"Get": func(ctx context.Context, name *string) (*jsDB, error) {
+			target := "default"
+			if name != nil {
+				target = *name
 			}
-			return &jsDB{db: d, ctx: ctx}, nil
+			return getJSDB(ctx, target)
+		},
+
+		// 默认快捷调用 (面向 "default" 实例)
+		"Query": func(ctx context.Context, query string, args ...any) (*QueryResult, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Query(query, args...), nil
+		},
+		"Exec": func(ctx context.Context, query string, args ...any) (*ExecResult, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Exec(query, args...), nil
+		},
+		"Insert": func(ctx context.Context, table string, data any) (*ExecResult, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Insert(table, data), nil
+		},
+		"Update": func(ctx context.Context, table string, data any, conditions string, args ...any) (*ExecResult, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Update(table, data, conditions, args...), nil
+		},
+		"Delete": func(ctx context.Context, table string, conditions string, args ...any) (*ExecResult, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Delete(table, conditions, args...), nil
+		},
+		"Replace": func(ctx context.Context, table string, data any) (*ExecResult, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Replace(table, data), nil
+		},
+		"Begin": func(ctx context.Context) (*jsTx, error) {
+			jd, err := getJSDB(ctx, "default")
+			if err != nil {
+				return nil, err
+			}
+			return jd.Begin()
 		},
 	})
 }

-type jsDB struct {
-	db  *DB
-	ctx context.Context
+func getJSDB(ctx context.Context, name string) (*jsDB, error) {
+	isReadOnly := false
+
+	// 安全模式下的动态判定
+	if jsmod.IsSafeMode(ctx) {
+		if strings.HasPrefix(name, "sqlite://") {
+			// 1. SQLite 路径校验
+			path := strings.TrimPrefix(name, "sqlite://")
+			if idx := strings.Index(path, "?"); idx != -1 {
+				path = path[:idx]
+			}
+			_, err := file.VerifyPathForSafeMode(ctx, path)
+			if err != nil {
+				return nil, err
+			}
+			isReadOnly = false
+		} else {
+			// 2. 远程数据库前缀校验
+			var allowedDSNs []string
+			cast.Convert(&allowedDSNs, jsmod.Get(ctx, "AllowedDSNs"))
+			matched := false
+			for _, prefix := range allowedDSNs {
+				if strings.HasPrefix(name, prefix) {
+					matched = true
+					break
+				}
+			}
+			if !matched {
+				isReadOnly = true
+			}
+		}
+	}
+
+	d := GetDB(name, nil)
+	if d.Error != nil {
+		return nil, d.Error
+	}
+	return &jsDB{db: d, ctx: ctx, isReadOnly: isReadOnly}, nil
 }

-var errSafeMode = errors.New("database write operation is restricted in safe mode")
+type jsDB struct {
+	db         *DB
+	ctx        context.Context
+	isReadOnly bool
+}

-func (jd *jsDB) checkSafe() error {
-	if jsmod.IsSafeMode(jd.ctx) {
-		return errSafeMode
+var errReadOnly = errors.New("database is in read-only mode for this context")
+
+func (jd *jsDB) checkWrite() error {
+	if jd.isReadOnly {
+		return errReadOnly
 	}
 	return nil
 }

-// Read Operations (Always allowed)
+// Read Operations
 func (jd *jsDB) Query(query string, args ...any) *QueryResult {
 	return jd.db.Query(query, args...)
 }

-// Write Operations (Restricted in SafeMode)
+// Write Operations
 func (jd *jsDB) Exec(query string, args ...any) *ExecResult {
-	if jd.checkSafe() != nil {
-		return &ExecResult{Error: errSafeMode}
+	if err := jd.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
 	}
 	return jd.db.Exec(query, args...)
 }

 func (jd *jsDB) Insert(table string, data any) *ExecResult {
-	if jd.checkSafe() != nil {
-		return &ExecResult{Error: errSafeMode}
+	if err := jd.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
 	}
 	return jd.db.Insert(table, data)
 }

 func (jd *jsDB) Update(table string, data any, conditions string, args ...any) *ExecResult {
-	if jd.checkSafe() != nil {
-		return &ExecResult{Error: errSafeMode}
+	if err := jd.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
 	}
 	return jd.db.Update(table, data, conditions, args...)
 }

 func (jd *jsDB) Delete(table string, conditions string, args ...any) *ExecResult {
-	if jd.checkSafe() != nil {
-		return &ExecResult{Error: errSafeMode}
+	if err := jd.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
 	}
 	return jd.db.Delete(table, conditions, args...)
 }

 func (jd *jsDB) Replace(table string, data any) *ExecResult {
-	if jd.checkSafe() != nil {
-		return &ExecResult{Error: errSafeMode}
+	if err := jd.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
 	}
 	return jd.db.Replace(table, data)
 }

-// Metadata
-func (jd *jsDB) InKeys(numArgs int) string {
-	return jd.db.InKeys(numArgs)
+// Transaction Support
+func (jd *jsDB) Begin() (*jsTx, error) {
+	tx := jd.db.Begin()
+	if tx.Error != nil {
+		return nil, tx.Error
+	}
+	return &jsTx{tx: tx, ctx: jd.ctx, isReadOnly: jd.isReadOnly}, nil
 }

-func (jd *jsDB) Quote(text string) string {
-	return jd.db.Quote(text)
+// Metadata
+func (jd *jsDB) InKeys(numArgs int) string { return jd.db.InKeys(numArgs) }
+func (jd *jsDB) Quote(text string) string  { return jd.db.Quote(text) }
+
+// jsTx wraps *Tx for JS environment
+type jsTx struct {
+	tx         *Tx
+	ctx        context.Context
+	isReadOnly bool
 }
+
+func (jt *jsTx) checkWrite() error {
+	if jt.isReadOnly {
+		return errReadOnly
+	}
+	return nil
+}
+
+func (jt *jsTx) Query(query string, args ...any) *QueryResult {
+	return jt.tx.Query(query, args...)
+}
+
+func (jt *jsTx) Exec(query string, args ...any) *ExecResult {
+	if err := jt.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
+	}
+	return jt.tx.Exec(query, args...)
+}
+
+func (jt *jsTx) Insert(table string, data any) *ExecResult {
+	if err := jt.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
+	}
+	return jt.tx.Insert(table, data)
+}
+
+func (jt *jsTx) Update(table string, data any, conditions string, args ...any) *ExecResult {
+	if err := jt.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
+	}
+	return jt.tx.Update(table, data, conditions, args...)
+}
+
+func (jt *jsTx) Delete(table string, conditions string, args ...any) *ExecResult {
+	if err := jt.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
+	}
+	return jt.tx.Delete(table, conditions, args...)
+}
+
+func (jt *jsTx) Replace(table string, data any) *ExecResult {
+	if err := jt.checkWrite(); err != nil {
+		return &ExecResult{Error: err}
+	}
+	return jt.tx.Replace(table, data)
+}
+
+func (jt *jsTx) Commit() error {
+	if err := jt.checkWrite(); err != nil {
+		return err
+	}
+	return jt.tx.Commit()
+}
+
+func (jt *jsTx) Rollback() error { return jt.tx.Rollback() }
Author	SHA1	Message	Date
AI Engineer	1312095ce7	feat: align JS exports to PascalCase and flatten default instance (by AI)	2026-06-10 12:12:36 +08:00
AI Engineer	63cd9d392a	refactor: use jsmod.Get for context configuration (by AI)	2026-06-10 09:52:55 +08:00
AI Engineer	38e520c300	feat: add SetConfig for dynamic configuration (by AI)	2026-06-08 20:47:51 +08:00
AI Engineer	39eb72c450	remove debug files	2026-06-05 11:28:53 +08:00
AI Engineer	41e2bac5e2	publish v1.5.2	2026-06-05 08:39:33 +08:00
AI Engineer	74b9bfe511	publish v1.5.1	2026-06-04 20:48:57 +08:00
AI Engineer	aad6d3a217	对齐 Tag v1.5.0 （By AI）	2026-06-03 20:11:36 +08:00
AI Engineer	615b2b5338	feat(jsmod): dynamic sandboxing for db access v1.3.7	2026-05-31 20:36:21 +08:00
AI Engineer	2c22ce193b	feat: add transaction support and refine db jsmod registration	2026-05-30 19:44:32 +08:00