art

type Arg struct {
	Line string // 开始和结束行，全闭区间
	Head int    // 首行
	Type string // 参数类型 Cmnd*
	Para string // 变量名
	Hold string // 占位符
}

type Col struct {
	Name string
	Seq  int
	Deft sql.NullString
	Null bool
	Type string
	Key  string
	Cmnt string
	Extr string
}

type Config struct {
	Preference Preference
	DataSource map[string]DataSource
	StartupEnv map[string]string
}

type Conn interface {
	// 打开链接
	Open(p *Preference, d *DataSource) (err error)
	// 获得链接
	DbConn() (db *sql.DB)
	// 数据库名
	DbName() string

	// 执行脚本
	Exec(qr string, args ...interface{}) (cnt int64, err error)
	// 执行查询
	Query(fn func(*sql.Rows) error, qr string, args ...interface{}) (err error)

	// 获得所有表名
	Tables() (tbls []string, err error)
	// 获得表的所有字段
	Columns(table string) (cls map[string]Col, err error)
	// 获得表的所有索引
	Indexes(table string) (ixs map[string]Idx, err error)
	// 获得表的所有触发器
	Triggers(table string) (tgs map[string]Trg, err error)

	// 生产建表SQL（含索引），包含结束符
	DdlTable(table string) (ddl string, err error)
	// 生产建触发器SQL，包含结束符
	DdlTrigger(trigger string) (ddl string, err error)

	// 转成SQL字面量，set x=val的 val部分字面量，是否需要引号扩上
	// databaseTypeName sql.ColumnType.DatabaseTypeName
	Literal(val interface{}, databaseTypeName string) (string, bool)
	// 数值<=0|布尔false|NULL|字符串""|其他字面量为""
	Nothing(val interface{}) bool
	// 转义的字符串
	Quotesc(str, qto string) string
}

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

type DataSource struct {
	Code string
	Conn string
}

type DiffItem struct {
	Columns  map[string]Col
	Indexes  map[string]Idx
	Triggers map[string]Trg
}

type Exe struct {
	Seg Sql // 对应的SQL片段

	// 产出
	Defs map[string]string // REF|STR的提取，key=HOLD,val=PARA
	// 行为
	Acts []*Arg // 源库RUN & OUT

	// 依赖，顺序重要
	Deps []*Hld // 依赖

	// 运行，深度优先L
	Sons []*Exe // 分叉
}

type FileEntity struct {
	Path string
	Text string
}

type Hld struct {
	Off int    // 开始位置，包含
	End int    // 结束位置，包括
	Ptn string // PARA的模式
	Str string // HOLD字符串
	Dyn bool   // true：动态替换；false：静态替换
}

type Idx struct {
	Name string
	Uniq bool
	Cols string
	Type string
}

type MyConn struct {
	Pref *Preference
	Conn *sql.DB
	Name string
}

type Preference struct {
	DatabaseType string
	DelimiterRaw string
	DelimiterCmd string
	LineComment  string
	MultComment  []string
	FmtDateTime  string
	ControlPort  int
	ConnMaxOpen  int
	ConnMaxIdel  int
}

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

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

type Sql struct {
	Line string // 开始和结束行，全闭区间
	Head int    // 首行
	Exeb bool   // 语句，注释
	File string // 文件名或名字
	Text string // 正文部分
}

type SqlExe struct {
	Envs map[string]string // HOLD对应的环境变量
	Exes []*Exe            // 数据树
}

type Sqls []Sql

type Trg struct {
	Name      string
	Timing    string
	Event     string
	Statement string
}