db

type ChangeSqlReader func(r *SqlReader)

type Column struct {
	DatabaseName string `json:"databaseName,omitempty"`
	SchemaName   string `json:"schemaName,omitempty"`
	TableName    string `json:"tableName,omitempty"`

	Name      string `json:"name,omitempty"`
	Comment   string `json:"comment,omitempty"`
	Type      string `json:"type,omitempty"`
	DataType  string `json:"dataType,omitempty"`
	Default   string `json:"default,omitempty"`
	Length    int    `json:"length,omitempty"`
	Precision int    `json:"precision,omitempty"`
	Scale     int    `json:"scale,omitempty"`

	Key bool `json:"key,omitempty"`

	AutoIncrement       bool   `json:"autoIncrement,omitempty"`
	AutoIncrementStart  int64  `json:"autoIncrementStart,omitempty"`
	AutoIncrementName   string `json:"autoIncrementName,omitempty"`
	AutoIncrementCreate bool   `json:"autoIncrementCreate,omitempty"`

	NotNull bool `json:"notNull,omitempty"`

	// 扩展属性
	Extend map[string]any `json:"extend,omitempty"`
}

type Condition struct {
	WhereSql string
	Args     []any
	Field    string
	Op       Op
	Value    any
	// 用于嵌套的子条件（AND/OR 组）
	Children *Conditions
	IsOr     bool // true 表示 OR 组，false 表示 AND 组（仅在有Children时有效）
}

type Conditions []*Condition

type Config struct {
	// Disabled 禁用 上层 初始化服务时候 可以判断该属性 如果为 配置 true 则不去初始化服务
	Disabled bool `json:"disabled,omitempty" yaml:"disabled,omitempty"`

	Type        string `json:"type,omitempty" yaml:"type,omitempty"`
	DialectType string `json:"dialectType,omitempty" yaml:"dialectType,omitempty"`

	Host     string `json:"host,omitempty" yaml:"host,omitempty"`
	Port     int    `json:"port,omitempty" yaml:"port,omitempty"`
	Address  string `json:"address,omitempty" yaml:"address,omitempty"`
	Username string `json:"username,omitempty" yaml:"username,omitempty"`
	Password string `json:"password,omitempty" yaml:"password,omitempty"`
	Database string `json:"database,omitempty" yaml:"database,omitempty"`
	Schema   string `json:"schema,omitempty" yaml:"schema,omitempty"`

	DatabasePath string `json:"databasePath,omitempty" yaml:"databasePath,omitempty"`

	ServerName string `json:"serverName,omitempty" yaml:"serverName,omitempty"`

	Dsn       string `json:"dsn,omitempty" yaml:"dsn,omitempty"`
	DsnAppend string `json:"dsnAppend,omitempty" yaml:"dsnAppend,omitempty"`

	MaxIdleConn int `json:"maxIdleConn,omitempty" yaml:"maxIdleConn,omitempty"`
	MaxOpenConn int `json:"maxOpenConn,omitempty" yaml:"maxOpenConn,omitempty"`

	TlsConfig     string `json:"tlsConfig,omitempty" yaml:"tlsConfig,omitempty"`
	TlsRootCert   string `json:"tlsRootCert,omitempty" yaml:"tlsRootCert,omitempty"`
	TlsClientCert string `json:"tlsClientCert,omitempty" yaml:"tlsClientCert,omitempty"`
	TlsClientKey  string `json:"tlsClientKey,omitempty" yaml:"tlsClientKey,omitempty"`
	// contains filtered or unexported fields
}

type ConnProxy interface {
	Dial(n string, addr string) (net.Conn, error)
}

type Constraint struct {
	DatabaseName string `json:"databaseName,omitempty"`
	SchemaName   string `json:"schemaName,omitempty"`
	TableName    string `json:"tableName,omitempty"`

	Name        string   `json:"name,omitempty"`
	Comment     string   `json:"comment,omitempty"`
	Type        string   `json:"type,omitempty"`
	ColumnNames []string `json:"columnNames,omitempty"`

	// 引用表所在库
	ReferencedDatabaseName string `json:"referencedDatabaseName,omitempty"`
	// 引用表
	ReferencedTableName string `json:"referencedTableName,omitempty"`
	// 引用字段
	ReferencedColumnNames []string `json:"referencedColumnNames,omitempty"`

	IsPrimary bool `json:"isPrimary,omitempty"`
	IsUnique  bool `json:"isUnique,omitempty"`
	IsForeign bool `json:"isForeign,omitempty"`

	// 扩展属性
	Extend map[string]any `json:"extend,omitempty"`
	// contains filtered or unexported fields
}

type ConstraintColumn struct {
	DatabaseName string `json:"databaseName,omitempty"`
	SchemaName   string `json:"schemaName,omitempty"`
	TableName    string `json:"tableName,omitempty"`

	Name        string `json:"name,omitempty"`
	Comment     string `json:"comment,omitempty"`
	Type        string `json:"type,omitempty"`
	ColumnName  string `json:"columnName,omitempty"`
	ColumnOrder int    `json:"columnOrder,omitempty"`

	// 引用表所在库
	ReferencedDatabaseName string `json:"referencedDatabaseName,omitempty"`
	// 引用表
	ReferencedTableName string `json:"referencedTableName,omitempty"`
	// 引用字段
	ReferencedColumnName string `json:"referencedColumnName,omitempty"`

	// 扩展属性
	Extend map[string]any `json:"extend,omitempty"`
}

type DDLHandler interface {
	WrapUserName(userName string) (res string)
	IsAppendDatabaseName() (res bool)
	WrapDatabaseName(databaseName string) (res string)
	IsAppendSchemaName() (res bool)
	WrapSchemaName(schemaName string) (res string)
	WrapTableName(tableName string) (res string)
	WrapColumnName(columnName string) (res string)
	WrapConstraintName(constraintName string) (res string)
	WrapIndexName(indexName string) (res string)
	WrapSequenceName(sequenceName string) (res string)
	WrapName(name string) (res string)
	WrapString(str string) (res string)
}

type DDLOption struct {
	WrapOption
	// 是否 包装 用户名称 该配置 > NameWrap
	WrapUserNameOpen *bool `json:"wrapUserNameOpen,omitempty"`
	// 是否 包装 数据库名称 该配置 > NameWrap
	WrapDatabaseNameOpen *bool `json:"wrapDatabaseNameOpen,omitempty"`
	// 是否 包装 模式名称 该配置 > NameWrap
	WrapSchemaNameOpen *bool `json:"wrapSchemaNameOpen,omitempty"`
	// 是否 包装 约束名称 该配置 > NameWrap
	WrapConstraintNameOpen *bool `json:"wrapConstraintNameOpen,omitempty"`
	// 是否 包装 索引名称 该配置 > NameWrap
	WrapIndexNameOpen *bool `json:"wrapIndexNameOpen,omitempty"`
	// 是否 包装 序列名称 该配置 > NameWrap
	WrapSequenceNameOpen *bool `json:"wrapSequenceNameOpen,omitempty"`

	// 是否 追加 库名
	AppendDatabaseName *bool `json:"appendDatabaseName,omitempty"`
	// 是否 追加 模式名
	AppendSchemaName *bool `json:"appendSchemaName,omitempty"`
}

type Database struct {
	Name string `json:"name,omitempty"`

	IsSystem bool `json:"isSystem,omitempty"`

	IfNotExists bool `json:"ifNotExists,omitempty"`
	// 多数用于删除时候 串联删除相关内容
	Cascade bool `json:"cascade,omitempty"`
	// 扩展属性
	Extend map[string]any `json:"param,omitempty"`
}

type Dialect interface {
	Type() string
	Match() []string

	WrapNameChar() string
	WrapStringChar() string
	EscapeStringChar() string
	ArgChar() string

	FormatSqlArgChar(sqlInfo string) (res string)
	FormatPageSql(sqlInfo string, pageSize int64, pageNo int64) (res string)

	GetDriverName() string
	GetDriverDSN(dbCfg *Config, params map[string]string) string

	Open(dbCfg *Config, params map[string]string) (sqlDb *sql.DB, err error)

	Info() (info *Info)

	UserChange(sqlConn SqlConn, userName string, password string) (ok bool, err error)
	UserSelectSql(userName string) (sqlInfo string, sqlArgs []any)
	UserList(sqlConn SqlConn) (userList []*User, err error)
	User(sqlConn SqlConn, userName string) (user *User, err error)
	UserCreateFieldList() (sqlList []*Field)
	UserCreateSql(handler DDLHandler, user *User) (sqlList []string, sqlArgsList [][]any)
	UserCreate(sqlConn SqlConn, handler DDLHandler, user *User) (err error)
	UserDeleteSql(handler DDLHandler, userName string) (sqlList []string, sqlArgsList [][]any)
	UserDelete(sqlConn SqlConn, handler DDLHandler, userName string) (err error)

	DatabaseChange(sqlConn SqlConn, databaseName string) (ok bool, err error)
	DatabaseSelectSql(databaseName string) (sqlInfo string, sqlArgs []any)
	DatabaseList(sqlConn SqlConn) (databaseList []*Database, err error)
	Database(sqlConn SqlConn, databaseName string) (database *Database, err error)
	DatabaseCreateFieldList() (sqlList []*Field)
	DatabaseCreateSql(handler DDLHandler, database *Database) (sqlList []string, sqlArgsList [][]any)
	DatabaseCreate(sqlConn SqlConn, handler DDLHandler, database *Database) (err error)
	DatabaseDeleteSql(handler DDLHandler, databaseName string, cascade bool) (sqlList []string, sqlArgsList [][]any)
	DatabaseDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, cascade bool) (err error)

	SchemaChange(sqlConn SqlConn, schemaName string) (ok bool, err error)
	SchemaSelectSql(databaseName string, schemaName string) (sqlInfo string, sqlArgs []any)
	SchemaList(sqlConn SqlConn, databaseName string) (schemaList []*Schema, err error)
	Schema(sqlConn SqlConn, databaseName string, schemaName string) (schema *Schema, err error)
	SchemaCreateFieldList() (sqlList []*Field)
	SchemaCreateSql(handler DDLHandler, databaseName string, schema *Schema) (sqlList []string, sqlArgsList [][]any)
	SchemaCreate(sqlConn SqlConn, handler DDLHandler, databaseName string, schema *Schema) (err error)
	SchemaDeleteSql(handler DDLHandler, databaseName string, schemaName string, cascade bool) (sqlList []string, sqlArgsList [][]any)
	SchemaDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, cascade bool) (err error)

	SequenceSelectSql(databaseName string, schemaName string, sequenceName string) (sqlInfo string, sqlArgs []any)
	SequenceList(sqlConn SqlConn, databaseName string, schemaName string) (sequenceList []*Sequence, err error)
	Sequence(sqlConn SqlConn, databaseName string, schemaName string, sequenceName string) (sequence *Sequence, err error)
	SequenceCreateFieldList() (sqlList []*Field)
	SequenceCreateSql(handler DDLHandler, databaseName string, schemaName string, sequence *Sequence) (sqlList []string, sqlArgsList [][]any)
	SequenceCreate(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, sequence *Sequence) (err error)
	SequenceDeleteSql(handler DDLHandler, databaseName string, schemaName string, sequenceName string) (sqlList []string, sqlArgsList [][]any)
	SequenceDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, sequenceName string) (err error)

	TableCheckExists(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (exists bool)
	TableSelectSql(databaseName string, schemaName string, tableName string) (sqlInfo string, sqlArgs []any)
	TableList(sqlConn SqlConn, databaseName string, schemaName string) (tableList []*Table, err error)
	Table(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (table *Table, err error)
	TableDetail(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (table *Table, err error)
	TableCreateFieldList() (sqlList []*Field)
	TableCreateSql(handler DDLHandler, databaseName string, schemaName string, table *Table) (sqlList []string, sqlArgsList [][]any)
	TableCreate(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, table *Table) (err error)
	TableDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string) (sqlList []string, sqlArgsList [][]any)
	TableDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string) (err error)

	ColumnCheckExists(sqlConn SqlConn, databaseName string, schemaName string, tableName string, columnName string) (exists bool)
	ColumnSelectSql(databaseName string, schemaName string, tableName string, columnName string) (sqlInfo string, sqlArgs []any)
	ColumnList(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (columnList []*Column, err error)
	Column(sqlConn SqlConn, databaseName string, schemaName string, tableName string, columnName string) (column *Column, err error)
	ColumnAddSql(handler DDLHandler, databaseName string, schemaName string, tableName string, column *Column) (sqlList []string, sqlArgsList [][]any)
	ColumnAdd(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, column *Column) (err error)
	ColumnUpdateSql(handler DDLHandler, databaseName string, schemaName string, tableName string, oldColumn *Column, column *Column) (sqlList []string, sqlArgsList [][]any)
	ColumnUpdate(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, oldColumn *Column, column *Column) (err error)
	ColumnDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string, columnName string) (sqlList []string, sqlArgsList [][]any)
	ColumnDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, columnName string) (err error)

	ConstraintSelectSql(databaseName string, schemaName string, tableName string, constraintName string) (sqlInfo string, sqlArgs []any)
	ConstraintList(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (constraintList []*Constraint, err error)
	Constraint(sqlConn SqlConn, databaseName string, schemaName string, tableName string, constraintName string) (constraint *Constraint, err error)
	ConstraintAddSql(handler DDLHandler, databaseName string, schemaName string, tableName string, constraint *Constraint) (sqlList []string, sqlArgsList [][]any)
	ConstraintAdd(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, constraint *Constraint) (err error)
	ConstraintDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string, constraintName string) (sqlList []string, sqlArgsList [][]any)
	ConstraintDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, constraintName string) (err error)

	IndexCheckExists(sqlConn SqlConn, databaseName string, schemaName string, tableName string, checkIndex *Index) (exists bool)
	IndexSelectSql(databaseName string, schemaName string, tableName string, indexName string) (sqlInfo string, sqlArgs []any)
	IndexList(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (indexList []*Index, err error)
	Index(sqlConn SqlConn, databaseName string, schemaName string, tableName string, indexName string) (index *Index, err error)
	IndexAddSql(handler DDLHandler, databaseName string, schemaName string, tableName string, index *Index) (sqlList []string, sqlArgsList [][]any)
	IndexAdd(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, index *Index) (err error)
	IndexDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string, indexName string) (sqlList []string, sqlArgsList [][]any)
	IndexDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, tableName string, indexName string) (err error)

	SqlConcat(args ...string) (res string)
}

type DialectColumnConfig struct {
	// 查询 SQL 字段：databaseName、schemaName、tableName；参数：databaseName、schemaName、tableName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、schemaName、tableName、加上表单字段
	Add           string `yaml:"add,omitempty"`
	Comment       string `yaml:"comment,omitempty"`
	Update        string `yaml:"update,omitempty"`
	UpdateRename  string `yaml:"updateRename,omitempty"`
	UpdateType    string `yaml:"updateType,omitempty"`
	UpdateNotNull string `yaml:"updateNotNull,omitempty"`
	UpdateDefault string `yaml:"updateDefault,omitempty"`
	// 删除 SQL 参数：databaseName、schemaName、tableName
	Delete string `yaml:"delete,omitempty"`
}

type DialectConfig struct {

	// 方言类型
	Type string `yaml:"type,omitempty"`
	// 查找方言 传入的类型 匹配 type 或 以下配置的字符 则使用该方言
	Match []string `yaml:"match,omitempty"`
	// 使用 其它方言作为基础数据，可以配置覆盖
	Extend string `yaml:"extend,omitempty"`
	// 驱动
	Driver *DialectDriverConfig `yaml:"driver,omitempty"`
	// 名称包裹字符 如：`name_1`、"name_1"
	NameWrapChar string `yaml:"nameWrapChar,omitempty"`
	// 名称 没有包装 则自动转大写
	NameNoWrapIsUpper bool `yaml:"nameNoWrapIsUpper,omitempty"`
	// 字符串包裹字符 如：'string_1'
	StringWrapChar string `yaml:"stringWrapChar,omitempty"`
	/// 字符串转义字符 如：'xx\'x'
	StringEscapeChar string `yaml:"stringEscapeChar,omitempty"`
	// 变量占位符 如：?、$num、:name、?num
	ArgChar string `yaml:"argChar,omitempty"`
	// 结构关系 如：database = schema
	Relation string `yaml:"relation,omitempty"`
	// 表单
	FormList []*Form `yaml:"formList,omitempty"`

	// 树形配置
	Tree []*DialectNodeConfig `yaml:"tree,omitempty"`

	// 用户
	User *DialectUserConfig `yaml:"user,omitempty"`
	// 库
	Database *DialectDatabaseConfig `yaml:"database,omitempty"`
	// 模式
	Schema *DialectSchemaConfig `yaml:"schema,omitempty"`
	// 序列
	Sequence *DialectSequenceConfig `yaml:"sequence,omitempty"`
	// 表
	Table *DialectTableConfig `yaml:"table,omitempty"`
	// 字段
	Column *DialectColumnConfig `yaml:"column,omitempty"`
	// 约束
	Constraint *DialectConstraintConfig `yaml:"constraint,omitempty"`
	// 索引
	Index *DialectIndexConfig `yaml:"index,omitempty"`

	TypeExtend bool                 `yaml:"typeExtend,omitempty"`
	TypeList   []*DialectTypeConfig `yaml:"typeList,omitempty"`

	FuncExtend bool                      `yaml:"funcExtend,omitempty"`
	FuncList   map[string]map[string]any `yaml:"funcList,omitempty"`
	// contains filtered or unexported fields
}

type DialectConstraintConfig struct {
	// 查询 SQL 字段：databaseName、schemaName、tableName；参数：databaseName、schemaName、tableName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、schemaName、tableName、加上表单字段
	Add     string `yaml:"add,omitempty"`
	Comment string `yaml:"comment,omitempty"`
	// 删除 SQL 参数：databaseName、schemaName、tableName
	Delete string `yaml:"delete,omitempty"`
}

type DialectDatabaseConfig struct {
	Change string `yaml:"change,omitempty"`
	// 查询 SQL 字段：databaseName；参数：databaseName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、加上表单字段
	Create string `yaml:"create,omitempty"`
	// 创建 SQL 附件 字段
	CreateFieldList []*Field `yaml:"createFieldList,omitempty"`
	// 删除 SQL 参数：databaseName
	Delete string `yaml:"delete,omitempty"`

	// 需要切换用户
	ShouldChangeUser bool `yaml:"shouldChangeUser,omitempty"`
	// 需要切换数据库
	ShouldChangeDatabase bool `yaml:"shouldChangeDatabase,omitempty"`
	// 需要切换模式
	ShouldChangeSchema bool `yaml:"shouldChangeSchema,omitempty"`

	Systems []string `yaml:"systems,omitempty"`
}

type DialectDriverConfig struct {
	Name  string `yaml:"name,omitempty"`
	Dsn   string `yaml:"dsn,omitempty"`
	IsUrl bool   `yaml:"isUrl,omitempty"`

	// 驱动连接中 是否可以包含 数据库
	HasDatabase bool `yaml:"hasDatabase,omitempty"`
	// 驱动连接中 是否可以包含 模式
	HasSchema bool `yaml:"hasSchema,omitempty"`

	// 值是否可以 编码 用于特殊字符
	CanPathEscape bool `yaml:"canPathEscape,omitempty"`

	// 参数间隔 字符 非 url 使用，默认为 " "
	ParamSpaceChar string `yaml:"paramSpaceChar,omitempty"`

	Params map[string]string `yaml:"params,omitempty"`
}

type DialectIndexConfig struct {
	// 查询 SQL 字段：databaseName、schemaName、tableName；参数：databaseName、schemaName、tableName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、schemaName、tableName、加上表单字段
	Add     string `yaml:"add,omitempty"`
	Comment string `yaml:"comment,omitempty"`
	// 删除 SQL 参数：databaseName、schemaName、tableName
	Delete string `yaml:"delete,omitempty"`
}

type DialectNodeConfig struct {
	Name    string `yaml:"name,omitempty"`
	Comment string `yaml:"comment,omitempty"`
	Rule    string `yaml:"rule,omitempty"`

	// 需要切换用户
	ShouldChangeUser bool `yaml:"shouldChangeUser,omitempty"`
	// 需要切换数据库
	ShouldChangeDatabase bool `yaml:"shouldChangeDatabase,omitempty"`
	// 需要切换模式
	ShouldChangeSchema bool `yaml:"shouldChangeSchema,omitempty"`

	Children []*DialectNodeConfig `yaml:"children,omitempty"`
}

type DialectSchemaConfig struct {
	Change string `yaml:"change,omitempty"`
	// 查询 SQL 字段：databaseName、schemaName；参数：databaseName、schemaName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、schemaName、加上表单字段
	Create string `yaml:"create,omitempty"`
	// 创建 SQL 附件 字段
	CreateFieldList []*Field `yaml:"createFieldList,omitempty"`
	// 删除 SQL 参数：databaseName、schemaName
	Delete string `yaml:"delete,omitempty"`

	// 需要切换用户
	ShouldChangeUser bool `yaml:"shouldChangeUser,omitempty"`
	// 需要切换数据库
	ShouldChangeDatabase bool `yaml:"shouldChangeDatabase,omitempty"`
	// 需要切换模式
	ShouldChangeSchema bool `yaml:"shouldChangeSchema,omitempty"`

	Systems []string `yaml:"systems,omitempty"`
}

type DialectSequenceConfig struct {
	// 查询 SQL 字段：databaseName、schemaName；参数：databaseName、schemaName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、schemaName、加上表单字段
	Create string `yaml:"create,omitempty"`
	// 创建 SQL 附件 字段
	CreateFieldList []*Field `yaml:"createFieldList,omitempty"`
	// 删除 SQL 参数：databaseName、schemaName
	Delete string `yaml:"delete,omitempty"`
}

type DialectService struct {
	// contains filtered or unexported fields
}

type DialectTableConfig struct {
	// 查询 SQL 字段：databaseName、schemaName、tableName；参数：databaseName、schemaName、tableName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：databaseName、schemaName、tableName、加上表单字段
	Create        string `yaml:"create,omitempty"`
	CreateComment string `yaml:"createComment,omitempty"`
	// 创建 SQL 附件 字段
	CreateFieldList []*Field `yaml:"createFieldList,omitempty"`
	// 建表 字段 SQL 参数：columnName、columnType、notNull、
	CreateColumn        string `yaml:"createColumn,omitempty"`
	CreateColumnComment string `yaml:"createColumnComment,omitempty"`
	// 建表 约束 SQL 参数：columnName、columnType、notNull、
	CreateConstraint        string `yaml:"createConstraint,omitempty"`
	CreateConstraintComment string `yaml:"createConstraintComment,omitempty"`

	CreateSequenceTrigger string `yaml:"createSequenceTrigger,omitempty"`

	// 建表 索引 SQL 参数：columnName、columnType、notNull、
	CreateIndex        string `yaml:"createIndex,omitempty"`
	CreateIndexComment string `yaml:"createIndexComment,omitempty"`
	Comment            string `yaml:"comment,omitempty"`
	// 删除 SQL 参数：databaseName、schemaName、tableName
	Delete string `yaml:"delete,omitempty"`

	// 需要切换用户
	ShouldChangeUser bool `yaml:"shouldChangeUser,omitempty"`
	// 需要切换数据库
	ShouldChangeDatabase bool `yaml:"shouldChangeDatabase,omitempty"`
	// 需要切换模式
	ShouldChangeSchema bool `yaml:"shouldChangeSchema,omitempty"`
}

type DialectTypeConfig struct {
	Name   string   `yaml:"name,omitempty"`
	Format string   `yaml:"format,omitempty"`
	Args   []string `yaml:"args,omitempty"`
	Match  []string `yaml:"match,omitempty"`
}

type DialectUserConfig struct {
	// 创建用户 会自动创建 数据库
	AutoCreateDatabase bool `yaml:"autoCreateDatabase,omitempty"`
	// 创建用户 会自动创建 模式
	AutoCreateSchema bool `yaml:"autoCreateSchema,omitempty"`

	Change string `yaml:"change,omitempty"`
	// 查询 SQL 字段：userName；参数：userName
	Select string `yaml:"select,omitempty"`
	// 创建 SQL 参数：userName、password、加上表单指定
	Create string `yaml:"create,omitempty"`
	// 字段
	CreateFieldList []*Field `yaml:"createFieldList,omitempty"`
	// 删除 SQL 参数：userName
	Delete string `yaml:"delete,omitempty"`

	Systems []string `yaml:"systems,omitempty"`
}

type DmBlobType interface {
	Read(dest []byte) (n int, err error)
	ReadAt(pos int, dest []byte) (n int, err error)
	Write(pos int, src []byte) (n int, err error)
	Truncate(length int64) error
	Scan(src interface{}) error
}

type DmClobType interface {
	GetLength() (int64, error)
	ReadString(pos int, length int) (result string, err error)
	WriteString(pos int, s string) (n int, err error)
	Truncate(length int64) error
	Scan(src interface{}) error
}

type Field struct {
	// 字段名称
	Name string `yaml:"name,omitempty"`
	// 标签
	Label string `yaml:"label,omitempty"`
	// 类型 text、password、select、redis、checkbox、json字符串，form
	Type string `yaml:"type,omitempty"`
	// 多个值
	List bool `yaml:"list,omitempty"`
	// 必填
	Required bool `yaml:"required,omitempty"`
	// 子表单
	FormName string `yaml:"formName,omitempty"`
	// 默认值
	Default   string `json:"default,omitempty"`
	IsInteger bool   `json:"isInteger,omitempty"`
}

type FieldSetterType func(model reflect.Value, modelField *ModelField, fieldValue reflect.Value, receiver any) (err error)

type FiledGetColumn func() string

type FiledGetValue func(columnName string, columnValue *util.FieldValue) any

type Form struct {
	// 表单名称
	Name string `yaml:"name,omitempty"`
	// 字段
	FieldList []*Field `yaml:"fieldList,omitempty"`
}

type GetSqlValueType func(columnType *sql.ColumnType, data any) (res any)

type HasStringFuncType interface {
	String() string
}

type IDynamicService interface {
	// RealService 真实服务 根据 表名 和 参数 获取正则
	RealService(param *SqlParam, tableName string) IService
}

type IGetObjectField interface {
	GetObjectField(b *SqlBuilder, object any) (res any)
}

type IGetPrimaryKey interface {
	GetPrimaryKey() []string
}

type IGetSql interface {
	GetSql() (sqlInfo string, args []any, err error)
}

type IGetTableName interface {
	GetTableName() string
}

type IModel interface {
	IGetTableName
	IGetPrimaryKey
}

type IModelSql interface {
	IGetSql
	GetService() (service IService)
}

type IService interface {
	Dialect
	// Close 关闭 db 客户端
	Close()
	// GetConfig 获取 数据库 配置
	GetConfig() Config
	// GetDialect 获取 方言
	GetDialect() Dialect
	// GetSqlConn 获取 sql.DB
	GetSqlConn() SqlConn

	SetDynamicService(dynamicService IDynamicService)

	GetDDLHandler() (handler DDLHandler)
	GetModelOption() (modelOption *ModelOption)

	ShowQuerySql() bool

	ShowExecSql() bool

	SqlHandler
	// IDynamicService 动态数据源服务相关
	IDynamicService

	// Exec 执行 SQL
	Exec(ctx context.Context, sql string, args []any) (result sql.Result, err error)
	// Execs 批量执行 SQL
	Execs(ctx context.Context, sqlList []string, argsList [][]any) (results []sql.Result, err error)
	// QueryCount 统计查询 SQL
	QueryCount(ctx context.Context, sql string, args []any) (count int64, err error)
	// QueryMapOne 查询 单个 map SQL  返回 < map >
	QueryMapOne(ctx context.Context, sql string, args []any) (one map[string]any, err error)
	// QueryMapList 查询 列表 map SQL  返回 list < map >
	QueryMapList(ctx context.Context, sql string, args []any) (list []map[string]any, err error)
	// QueryMapPage 分页查询 列表 map 列表 SQL  返回 list < map >
	QueryMapPage(ctx context.Context, sql string, args []any, pageSize int64, pageNo int64) (list []map[string]any, err error)

	ModelSelect(model any, sets ...ModelSelectSet) (res *ModelSelect)
	SqlSelect(table string, columns ...string) (res *SqlSelect)

	Count(ctx context.Context, model IModel, sets ...ModelCountSet) (res int64, err error)
	ModelCount(model any, sets ...ModelCountSet) (res *ModelCount)
	SqlCount(table string, sets ...SqlCountSet) (res *SqlCount)

	Insert(ctx context.Context, model IModel, sets ...ModelInsertSet) (res sql.Result, err error)
	ModelInsert(model any, sets ...ModelInsertSet) (res *ModelInsert)
	SqlInsert(table string, sets ...SqlInsertSet) (res *SqlInsert)

	Update(ctx context.Context, model IModel, sets ...ModelUpdateSet) (res sql.Result, err error)
	ModelUpdate(model any, sets ...ModelUpdateSet) (res *ModelUpdate)
	SqlUpdate(table string, sets ...SqlUpdateSet) (res *SqlUpdate)

	Delete(ctx context.Context, model IModel, sets ...ModelDeleteSet) (res sql.Result, err error)
	ModelDelete(model any, sets ...ModelDeleteSet) (res *ModelDelete)
	SqlDelete(table string, sets ...SqlDeleteSet) (res *SqlDelete)
}

type IncludedPlace int

type Index struct {
	DatabaseName string `json:"databaseName,omitempty"`
	SchemaName   string `json:"schemaName,omitempty"`
	TableName    string `json:"tableName,omitempty"`

	Name        string   `json:"name,omitempty"`
	Comment     string   `json:"comment,omitempty"`
	Type        string   `json:"type,omitempty"`
	ColumnNames []string `json:"columnNames,omitempty"`

	// 扩展属性
	Extend map[string]any `json:"extend,omitempty"`
	// contains filtered or unexported fields
}

type IndexColumn struct {
	DatabaseName string `json:"databaseName,omitempty"`
	SchemaName   string `json:"schemaName,omitempty"`
	TableName    string `json:"tableName,omitempty"`

	Name        string `json:"name,omitempty"`
	Comment     string `json:"comment,omitempty"`
	Type        string `json:"type,omitempty"`
	ColumnName  string `json:"columnName,omitempty"`
	ColumnOrder int    `json:"columnOrder,omitempty"`

	// 扩展属性
	Extend map[string]any `json:"extend,omitempty"`
}

type Info struct {
	DriverName     string
	Dsn            string
	DsnHasDatabase bool
	DsnHasSchema   bool

	// 名称 没有包装 则自动转大写
	NameNoWrapIsUpper bool `json:"nameNoWrapIsUpper"`

	// SQL 切换用户
	SqlChangeUser bool `json:"canChangeUser"`
	// SQL 切换数据库
	SqlChangeDatabase bool `json:"canChangeDatabase"`
	// SQL 切换模式
	SqlChangeSchema bool `json:"canChangeSchema"`

	// 是否有 用户
	HasUser bool `json:"hasUser"`
	// 是否有 库
	HasDatabase bool `json:"hasDatabase"`
	// 是否有 模式
	HasSchema bool `json:"hasSchema"`
	// 是否有 序列
	HasSequence bool `json:"hasSequence"`

	// 创建用户会自动创建 同名 数据库 则 用户登录 将自动登录到 同名 数据库 中
	CreateUserAutoCreateDatabase bool `json:"createUserAutoCreateDatabase"`
	// 创建用户会自动创建 同名 模式 则 用户登录 将自动登录到 同名 模式 中
	CreateUserAutoCreateSchema bool `json:"createUserAutoCreateSchema"`
}

type InsertOrUpdateValue struct {
	Column string `json:"column,omitempty"`
	Value  any    `json:"value,omitempty"`
}

type ModelCount struct {

	// 模型 设置 如：表名、主键、包含字段、忽略字段、空值设置 等
	*ModelSetting
	// contains filtered or unexported fields
}

type ModelCountSet = func(in *ModelCount)

type ModelDelete struct {

	// 模型 设置 如：表名、主键、包含字段、忽略字段、空值设置 等
	*ModelSetting
	// contains filtered or unexported fields
}

type ModelDeleteSet = func(in *ModelDelete)

type ModelField struct {
	*util.StructField

	// 是否 实现了 sql.Scanner 接口
	ImplementsSqlScanner bool

	ColumnName string
	// contains filtered or unexported fields
}

type ModelInfo struct {
	*util.StructInfo
	// contains filtered or unexported fields
}

type ModelInsert struct {

	// 模型 设置 如：表名、主键、包含字段、忽略字段、空值设置 等
	*ModelSetting
	// contains filtered or unexported fields
}

type ModelInsertSet = func(in *ModelInsert)

type ModelOption struct {

	// 字段 tag 注解，默认 column 如：`column:"xx"`
	ColumnTag string `json:"columnTag,omitempty"`
	// 是否 使用json主键，如果 字段 tag 注解 未找到 使用 json 注解
	ColumnUseJsonTag bool `json:"columnUseJsonTag,omitempty"`
	// 如果 以上都未配置 使用 字段名称
	ColumnUseFieldName bool `json:"columnUseFieldName,omitempty"`

	// 字段名称 严格判断 默认 false `userId 将 匹配 Userid UserId USERID`，
	ColumnStrictCase bool `json:"columnStrictCase,omitempty"`
	// contains filtered or unexported fields
}

type ModelSelect struct {

	// 模型 设置 如：表名、主键、包含字段、忽略字段、空值设置 等
	*ModelSetting
	// contains filtered or unexported fields
}

type ModelSelectSet = func(in *ModelSelect)

type ModelSetting struct {
	// contains filtered or unexported fields
}