// 版权归GoFrame作者(https://goframe.org)所有。保留所有权利。
//
// 本源代码形式受MIT许可证条款约束。
// 如果未随本文件一同分发MIT许可证副本，
// 您可以在https://github.com/gogf/gf处获取。
// md5:a9832f33b234e3f3

package db类

import (
	"context"
	"database/sql"
	"fmt"

	gjson "gitee.com/go_888/goframe/encoding/gjson"
	gcode "gitee.com/go_888/goframe/errors/gcode"
	gerror "gitee.com/go_888/goframe/errors/gerror"
	"gitee.com/go_888/goframe/internal/intlog"
	gstr "gitee.com/go_888/goframe/text/gstr"
	gutil "gitee.com/go_888/goframe/util/gutil"
)

// X结构_DriverWrapperDB是一个DB包装器，用于通过嵌入式DB扩展功能。 md5:a926644143c69c76
type X结构_DriverWrapperDB struct {
	DB
}

// X底层Open 创建并返回一个用于pgsql的底层sql.DB对象。
// 参考链接：https://pkg.go.dev/github.com/lib/pq
// md5:9889bcb899248a2b
func (d *X结构_DriverWrapperDB) X底层Open(node *X结构_配置) (db *sql.DB, err error) {
	var ctx = d.X取上下文对象()
	intlog.PrintFunc(ctx, func() string {
		return fmt.Sprintf(`打开新连接: %s`, gjson.X变量到json字节集PANI(node))
	})
	return d.DB.X底层Open(node)
}

// X取表名称数组 获取并返回当前模式下的表格列表。
// 主要用于命令行工具链，用于自动生成模型。
// md5:bce161ba95454bf5
func (d *X结构_DriverWrapperDB) X取表名称数组(上下文 context.Context, schema ...string) (表名称数组 []string, 错误 error) {
	上下文 = context.WithValue(上下文, ctxKeyInternalProducedSQL, struct{}{})
	return d.DB.X取表名称数组(上下文, schema...)
}

// X取表字段信息Map 获取并返回当前模式指定表的字段信息。
//
// 参数 `link` 是可选的，如果为 nil，则自动获取一个原始 SQL 连接，用于执行必要的 SQL 查询。
//
// 它返回一个包含字段名及其对应字段的映射。由于映射是无序的，TableField 结构体有一个 "Index" 字段，标记其在字段中的顺序。
//
// 该方法使用缓存功能来提高性能，直到进程重启，缓存永不过期。
// md5:c844572d5210b35e
func (d *X结构_DriverWrapperDB) X取表字段信息Map(
	ctx context.Context, table string, schema ...string,
) (fields map[string]*X结构_TableField, err error) {
	if table == "" {
		return nil, nil
	}
	charL, charR := d.X底层取数据库安全字符()
	table = gstr.X删首尾空与字符(table, charL+charR)
	if gstr.X是否包含(table, " ") {
		return nil, gerror.X创建错误码(
			gcode.X变量_CodeInvalidParameter,
			"函数 TableFields 仅支持单表操作",
		)
	}
	var (
		// 前缀:组@模式#表. md5:b22e67d9da02a91b
		cacheKey = fmt.Sprintf(
			`%s%s@%s#%s`,
			cachePrefixTableFields,
			d.X取配置组名称(),
			gutil.X取文本值或取默认值(d.X取默认数据库名称(), schema...),
			table,
		)
		value = tableFieldsMap.X取值或设置值_函数锁(cacheKey, func() interface{} {
			ctx = context.WithValue(ctx, ctxKeyInternalProducedSQL, struct{}{})
			fields, err = d.DB.X取表字段信息Map(ctx, table, schema...)
			if err != nil {
				return nil
			}
			return fields
		})
	)
	if value != nil {
		fields = value.(map[string]*X结构_TableField)
	}
	return
}

// X底层插入 用于插入或更新给定表的数据。
// 此函数通常用于自定义接口定义，您无需手动调用。
// 参数 `data` 可以为 map/gmap/struct/*struct/[]map/[]struct 等类型。
// 例如：
// Data(g.Map{"uid": 10000, "name":"john"})
// Data(g.Slice{g.Map{"uid": 10000, "name":"john"}, g.Map{"uid": 20000, "name":"smith"})
//
// 参数 `option` 的值如下：
// InsertOptionDefault：仅插入，如果数据中包含唯一键或主键，则返回错误；
// InsertOptionReplace：如果数据中包含唯一键或主键，先从表中删除原有记录，再插入新记录；
// InsertOptionSave：如果数据中包含唯一键或主键，进行更新，否则插入新记录；
// InsertOptionIgnore：如果数据中包含唯一键或主键，忽略插入操作。
// md5:9fab32fdc41df179
func (d *X结构_DriverWrapperDB) X底层插入(上下文 context.Context, 链接 Link, 表名称 string, list X类型_Map数组, option X结构_DoInsertOption) (result sql.Result, err error) {
	// 在将数据类型提交给底层数据库驱动程序之前进行转换。 md5:58b56ae1ed22196f
	for i, item := range list {
		list[i], err = d.X取Core对象().X底层ConvertDataForRecord(上下文, item, 表名称)
		if err != nil {
			return nil, err
		}
	}
	return d.DB.X底层插入(上下文, 链接, 表名称, list, option)
}