session

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

type DBInfo struct {
	Name string
	// 是否已删除
	IsDeleted bool
	// 是否为新增
	IsNew bool
}

type ErrExprLoc struct {
	Offset int
	Loc    string
}

type ErrorCode int

type ExplainInfo struct {
	SelectType   string  `gorm:"Column:select_type"`
	Table        string  `gorm:"Column:table"`
	Partitions   string  `gorm:"Column:partitions"`
	Type         string  `gorm:"Column:type"`
	PossibleKeys string  `gorm:"Column:possible_keys"`
	Key          string  `gorm:"Column:key"`
	KeyLen       string  `gorm:"Column:key_len"`
	Ref          string  `gorm:"Column:ref"`
	Rows         int     `gorm:"Column:rows"`
	Filtered     float32 `gorm:"Column:filtered"`
	Extra        string  `gorm:"Column:Extra"`

	// TiDB的Explain预估行数存储在Count中
	Count float32 `gorm:"Column:count"`
}

type FieldInfo struct {
	Field      string  `gorm:"Column:Field"`
	Type       string  `gorm:"Column:Type"`
	Collation  string  `gorm:"Column:Collation"`
	Null       string  `gorm:"Column:Null"`
	Key        string  `gorm:"Column:Key"`
	Default    *string `gorm:"Column:Default"`
	Extra      string  `gorm:"Column:Extra"`
	Privileges string  `gorm:"Column:Privileges"`
	Comment    string  `gorm:"Column:Comment"`

	IsDeleted bool `gorm:"-"`
	IsNew     bool `gorm:"-"`

	Tp *types.FieldType `gorm:"-"`
}

type IndexInfo struct {
	gorm.Model

	Table      string `gorm:"Column:Table"`
	NonUnique  int    `gorm:"Column:Non_unique"`
	IndexName  string `gorm:"Column:Key_name"`
	Seq        int    `gorm:"Column:Seq_in_index"`
	ColumnName string `gorm:"Column:Column_name"`
	IndexType  string `gorm:"Column:Index_type"`

	IsDeleted bool `gorm:"-"`
}

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

type MasterStatus struct {
	gorm.Model
	File            string `gorm:"Column:File"`
	Position        int    `gorm:"Column:Position"`
	BinlogDoDB      string `gorm:"Column:Binlog_Do_DB"`
	BinlogIgnoreDB  string `gorm:"Column:Binlog_Ignore_DB"`
	ExecutedGtidSet string `gorm:"Column:Executed_Gtid_Set"`
}

type MyRecordSets struct {
	MaxLevel uint8

	SeqNo int
	// contains filtered or unexported fields
}

type PrintRecord struct {
	ID  int
	SQL string
	// 审核级别,0为成功,1为警告,2为错误
	ErrLevel uint8
	// 错误/警告信息
	ErrorMessage string
	// 语法树
	QueryTree string
}

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

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

type Record struct {
	// 阶段   RERUN EXECUTED CHECKED
	Stage byte
	// 阶段说明 Execute Successfully / 审核完成 / 失败...
	// Audit completed
	// Execute failed
	// Execute Successfully
	// Execute Successfully,Backup successfully
	// Execute Successfully,Backup failed
	StageStatus byte

	// 审核级别,0为成功,1为警告,2为错误
	ErrLevel uint8
	// 错误/警告信息
	ErrorMessage string

	Sql string

	// 受影响行
	AffectedRows int

	// 备份库的库名
	BackupDBName string

	// 执行用时
	ExecTime string

	// 备份用时
	BackupCostTime string

	// sql的hash值,osc使用
	Sqlsha1 string

	Buf *bytes.Buffer

	Type ast.StmtNode

	// 备份相关
	ExecTimestamp int64
	StartFile     string
	StartPosition int
	EndFile       string
	EndPosition   int
	ThreadId      uint32
	SeqNo         int

	DBName    string
	TableName string
	TableInfo *TableInfo

	// ddl回滚
	DDLRollback string
	OPID        string

	ExecComplete bool

	// 是否开启OSC
	UseOsc bool

	// update多表时,记录多余的表
	// update多表时,默认set第一列的表为主表,其余表才会记录到该处
	// 仅在发现多表操作时,初始化该参数
	MultiTables map[string]*TableInfo
}

type Rewrite struct {
	SQL  string
	Stmt sqlparser.Statement
}

type SQLError struct {
	Code    ErrorCode
	Message string
}

type Session interface {
	sessionctx.Context
	AffectedRows() uint64 // Affected rows by latest executed stmt.
	// Execute(context.Context, string) ([]sqlexec.RecordSet, error)    // Execute a sql statement.
	Execute(context.Context, string) ([]Record, error)               // Execute a sql statement.
	ExecuteInc(context.Context, string) ([]sqlexec.RecordSet, error) // Execute a sql statement.

	SetConnectionID(uint64)
	SetProcessInfo(string, time.Time, byte)

	SetCollation(coID int) error
	SetSessionManager(util.SessionManager)

	Auth(user *auth.UserIdentity, auth []byte, salt []byte) bool
	ShowProcess() util.ProcessInfo

	// 用以测试
	GetAlterTablePostPart(sql string, isPtOSC bool) string

	// LoadOptions 加载配置
	LoadOptions(opt SourceOptions) error
	// Audit 审核
	Audit(ctx context.Context, sql string) ([]Record, error)
	// RunExecute 执行
	RunExecute(ctx context.Context, sql string) ([]Record, error)

	// 特殊SQL审核
	CheckStmt(ctx context.Context, stmtNode ast.StmtNode,
		currentSQL string) ([]sqlexec.RecordSet, error)

	// 拆分
	Split(ctx context.Context, sql string) ([]SplitRecord, error)
	// 打印语法树
	Print(ctx context.Context, sql string) ([]PrintRecord, error)
	// 打印语法树
	QueryTree(ctx context.Context, sql string) ([]PrintRecord, error)
}

type SourceOptions struct {
	Host           string
	Port           int
	User           string
	Password       string
	Check          bool
	Execute        bool
	Backup         bool
	IgnoreWarnings bool

	// 每次执行后休眠多少毫秒. 用以降低对线上数据库的影响，特别是针对大量写入的操作.
	// 单位为毫秒，最小值为0, 最大值为100秒，也就是100000毫秒
	Sleep int
	// 执行多条后休眠, 最小值1,默认值1
	SleepRows int

	// 仅供第三方扩展使用! 设置该字符串会跳过binlog解析!
	MiddlewareExtend string
	MiddlewareDB     string
	// 原始主机和端口,用以解析binlog
	ParseHost string
	ParsePort int

	// sql指纹功能,可在调用参数中设置,也可全局设置,值取并集
	Fingerprint bool

	// 打印语法树功能
	Print bool

	// DDL/DML分隔功能
	Split bool

	// 使用count(*)计算受影响行数
	RealRowCount bool

	// 连接的数据库,默认为mysql
	DB string

	Ssl     string // 连接加密
	SslCA   string // 证书颁发机构（CA）证书
	SslCert string // 客户端公共密钥证书
	SslKey  string // 客户端私钥文件

	// 事务支持,一次执行多少条
	TranBatch int
}

type SplitRecord struct {
	ID  int
	SQL string
	// 审核级别,0为成功,1为警告,2为错误
	ErrLevel uint8
	// 错误/警告信息
	ErrorMessage string
	// ddl标志位
	IsDDL bool
}

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

type TableInfo struct {
	Schema string
	Name   string
	// 表别名,仅用于update,delete多表
	AsName string
	Fields []FieldInfo

	// 索引
	Indexes []*IndexInfo

	// 是否已删除
	IsDeleted bool
	// 备份库是否已创建
	IsCreated bool

	// 表是否为新增
	IsNew bool
	// 列是否为新增
	IsNewColumns bool

	AlterCount int

	// 是否已清除已删除的列[解析binlog时会自动清除已删除的列]
	IsClear bool

	// 表大小.单位MB
	TableSize uint

	// 字符集&排序规则
	Collation string
	// contains filtered or unexported fields
}

type TxnState struct {
	// States of a TxnState should be one of the followings:
	// Invalid: kv.Transaction == nil && txnFuture == nil
	// Pending: kv.Transaction == nil && txnFuture != nil
	// Valid:	kv.Transaction != nil && txnFuture == nil
	kv.Transaction
	// contains filtered or unexported fields
}

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