handle

Documentation

Index

• Constants
• Variables
• func CheckDbChangeFileById(id *string, fileSum *string) bool
• func CreateMetaTable() error
• func Handle(yamlConfig string) error
• func InsertDbChangeSet(session *xorm.Session, changeSetId *string, author *string, ...)
• func InsertDbChangeSetForMarkRun(changeSetId *string, author *string, changeSetFile *string, executedOrder *int, ...)
• func InsertOrUpdateDbChangeSet(session *xorm.Session, dbChangeSet *DbChangeSet, changeSetId *string, ...)
• func SelectMaxExecutedOrder() int
• func UpdateDbChangeFileById(id *string, fileSum *string, filePath *string, entryFile *string)
• func UpdateDbChangeSet(session *xorm.Session, changeSetId *string, executedStatus *string, ...)
• type DbChangeFile
  • func SelectDbChangeFileById(id *string) (*DbChangeFile, error)
• type DbChangeSet
  • func CheckDbChangeSet(changeSetId *string, runOnChange *string, changeSetSum *string) (string, *DbChangeSet, error)
  • func SelectDbChangeSetById(changeSetId *string) (*DbChangeSet, error)

Constants

const META_CHANGE_SET = `` /* 1958-byte string literal not displayed */

Variables

var DbConfig *config.DB

app.yml配置中的一个db配置

var SqlOutPutFile *os.File

空转时导出sql语句的保存文件

Functions

func CheckDbChangeFileById

func CheckDbChangeFileById(id *string, fileSum *string) bool

根据id(changeLogXml文件名称)查询db_change_file表中对应的记录以确定是否需要运行 如果不存在或者签名值变更，则返回true，需要运行 dbConn *sql.DB 该数据库连接实例 id *string 指定的id，即changeLogXml文件名称的指针 fileSum *string 该文件的签名值(sha256摘要值) return bool 是否需要运行

func CreateMetaTable

func CreateMetaTable() error

创建元数据表[db_change_file,db_change_set]，如果不存在的话 dbConn *sql.DB 该数据库连接实例

func Handle

func Handle(yamlConfig string) error

处理入口 yamlConfig string app.yml

func InsertDbChangeSet

func InsertDbChangeSet(session *xorm.Session, changeSetId *string, author *string, changeSetFile *string,
	executedStatus *string, executedOrder *int, changeSetSum *string, changeSet *etree.Element)

新增插入DbChangeSet记录

func InsertDbChangeSetForMarkRun

func InsertDbChangeSetForMarkRun(changeSetId *string,
	author *string, changeSetFile *string, executedOrder *int, changeSet *etree.Element)

新增插入指定changeSetId的DbChangeSet记录，仅用于前置条件判断异常时标记为MARK_RAN 如果已经存在该记录，则不作处理

func InsertOrUpdateDbChangeSet

func InsertOrUpdateDbChangeSet(session *xorm.Session, dbChangeSet *DbChangeSet, changeSetId *string,
	author *string, changeSetFile *string, executedOrder *int, changeSetSum *string, changeSet *etree.Element)

新增插入DbChangeSet记录或更新指定changeSetId的DbChangeSet记录

func SelectMaxExecutedOrder

func SelectMaxExecutedOrder() int

查询当前最大值执行排序值executed_order

func UpdateDbChangeFileById

func UpdateDbChangeFileById(id *string, fileSum *string,
	filePath *string, entryFile *string)

根据id(changeLogXml文件名称)插入或更新db_change_file表 dbConn *sql.DB 该数据库连接实例 id *string 指定的id，即changeLogXml文件名称的指针 fileSum *string 该文件的签名值(sha256摘要值) filePath *string 文件路径的指针 entryFile *string 入口文件的指针

func UpdateDbChangeSet

func UpdateDbChangeSet(session *xorm.Session, changeSetId *string, executedStatus *string, changeSetSum *string, changeSet *etree.Element)

更新指定changeSetId的DbChangeSet记录

Types

type DbChangeFile

type DbChangeFile struct {
	Id             string `xorm:"pk"`
	CreatedTime    string
	FileSign       string
	FilePath       string
	FileType       string
	ExecutedTime   string
	ExecutedStatus string
	EntryFile      string
}

func SelectDbChangeFileById

func SelectDbChangeFileById(id *string) (*DbChangeFile, error)

根据id(changeLogXml文件名称)查询db_change_file表中对应的记录并返回 dbConn *sql.DB 该数据库连接实例 fileName *string 指定的changeLogXml文件名称指针

type DbChangeSet

type DbChangeSet struct {
	Id               string `xorm:"pk"`
	Author           string
	FileName         string
	CreatedTime      string
	ExecutedTime     string
	ExecutedStatus   string
	ExecutedOrder    int
	ExecType         string
	ChangesetComment string
	ChangesetSign    string
	LiquigoVersion   string
}

func CheckDbChangeSet

func CheckDbChangeSet(changeSetId *string, runOnChange *string, changeSetSum *string) (string, *DbChangeSet, error)

检查元数据库表db_change_set的记录

func SelectDbChangeSetById

func SelectDbChangeSetById(changeSetId *string) (*DbChangeSet, error)

根据changeSetId查询db_change_set表中对应的记录并返回 dbConn *sql.DB 该数据库连接实例 changeSetId *string 指定的changeSetId指针