func()

in state/manager.go [171:324]
132 lines of code
9 McCabe index (conditional complexity)

func (m *Mgr) create() bool {
	log.Debugf("Creating state DB (if not exist)")
	err := util.ExecSQL(m.nodbconn, "CREATE DATABASE IF NOT EXISTS "+types.MyDBName+" DEFAULT CHARACTER SET latin1")
	if err != nil {
		log.Errorf("State DB create failed: " + err.Error())
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.state (
		id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY,

		service    VARCHAR(128) NOT NULL,
		cluster    VARCHAR(128) NOT NULL,
		db         VARCHAR(128) NOT NULL,
		table_name VARCHAR(128) NOT NULL,
		input      VARCHAR(128) NOT NULL,
		output     VARCHAR(128) NOT NULL,
		version    INT NOT NULL DEFAULT 0,

		output_format VARCHAR(128) NOT NULL,

		created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
		updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
		deleted_at TIMESTAMP NULL,

		snapshotted_at TIMESTAMP NULL,
		need_snapshot  BOOLEAN DEFAULT FALSE,

		params JSON,

		reg_id BIGINT NOT NULL, /* references registrations.id */

		locked_at TIMESTAMP NULL,
		worker_id VARCHAR(128),

		UNIQUE KEY(service, db, table_name, input, output, version, cluster),
		KEY(cluster),
		KEY(locked_at),
		KEY(input),
		KEY(snapshotted_at)
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("state table create failed %v. db: %v ", err, types.MyDBName)
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.cluster_state (
		cluster VARCHAR(128) NOT NULL PRIMARY KEY,
		gtid    TEXT NOT NULL,
		seqno   BIGINT NOT NULL DEFAULT 0,

		locked_at TIMESTAMP NULL,
		worker_id VARCHAR(128),

		updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,

		KEY(locked_at)
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("cluster_state table create failed: " + err.Error())
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.raw_schema (
		state_id    BIGINT NOT NULL PRIMARY KEY,
		schema_gtid TEXT NOT NULL,
		raw_schema  TEXT NOT NULL,

		updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("raw_schema table create failed: " + err.Error())
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.columns (
		state_id BIGINT NOT NULL,

		column_name              VARCHAR(64) NOT NULL DEFAULT '',
		ordinal_position         BIGINT(21) unsigned NOT NULL DEFAULT '0',
		is_nullable              VARCHAR(3) NOT NULL DEFAULT '',
		data_type                VARCHAR(64) NOT NULL DEFAULT '',
		character_maximum_length BIGINT(21) unsigned DEFAULT NULL,
		numeric_precision        BIGINT(21) unsigned DEFAULT NULL,
		numeric_scale            BIGINT(21) unsigned DEFAULT NULL,
		column_type              LONGTEXt NOT NULL,
		column_key               VARCHAR(3) NOT NULL DEFAULT '',

		PRIMARY KEY(state_id, column_name)
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("columns table create failed: " + err.Error())
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.clusters (
		name     VARCHAR(128) NOT NULL,
		host     VARCHAR(128) NOT NULL,
		port     INT NOT NULL DEFAULT 3306,
		user     VARCHAR(64) NOT NULL,
		password VARCHAR(64) NOT NULL,
		type     VARCHAR(32) NOT NULL DEFAULT 'slave',
		PRIMARY KEY(name, type)
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("clusters table create failed: " + err.Error())
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.output_schema (
		name        VARCHAR(128) NOT NULL,
		type        VARCHAR(64) NOT NULL,
		schema_body TEXT NOT NULL,

		PRIMARY KEY(name, type)
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("outputSchema table create failed: " + err.Error())
		return false
	}
	err = util.ExecSQL(m.nodbconn, `
	CREATE TABLE IF NOT EXISTS `+types.MyDBName+`.registrations (
		id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY,

		service    VARCHAR(128) NOT NULL,
		cluster    VARCHAR(128) NOT NULL,
		db         VARCHAR(128) NOT NULL,
		table_name VARCHAR(128) NOT NULL,
		input      VARCHAR(128) NOT NULL,
		output     VARCHAR(128) NOT NULL,
		version    INT NOT NULL DEFAULT 0,

		output_format VARCHAR(128) NOT NULL,

		created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
		updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
		deleted_at TIMESTAMP NULL,

		snapshotted_at TIMESTAMP NULL,
		need_snapshot  INT DEFAULT 0, /* or pending_snapshot? */

		params         TEXT,

		sync_state TINYINT NOT NULL DEFAULT 0,

		UNIQUE KEY(service, cluster, db, table_name, input, output, version)
	) ENGINE=INNODB`)
	if err != nil {
		log.Errorf("registrations table create failed: " + err.Error())
		return false
	}
	log.Debugf("State DB initialized")
	return true
}