Method TestWriteCheckpoint

go/logic/applier_test.go:779–865

()

}

func (suite *ApplierTestSuite) TestWriteCheckpoint() {
	ctx := context.Background()

	var err error

	_, err = suite.db.ExecContext(ctx, fmt.Sprintf("CREATE TABLE %s (id int not null, id2 char(4) CHARACTER SET utf8mb4, primary key(id, id2))", getTestTableName()))
	suite.Require().NoError(err)

	_, err = suite.db.ExecContext(ctx, fmt.Sprintf("CREATE TABLE %s (id INT, id2 char(4) CHARACTER SET utf8mb4, name varchar(20), primary key(id, id2));", getTestGhostTableName()))
	suite.Require().NoError(err)

	_, err = suite.db.ExecContext(ctx, fmt.Sprintf("INSERT INTO %s (id, id2) VALUES (?,?), (?,?), (?,?)", getTestTableName()), 411, "君子懷德", 411, "小人懷土", 212, "君子不器")
	suite.Require().NoError(err)

	connectionConfig, err := getTestConnectionConfig(ctx, suite.mysqlContainer)
	suite.Require().NoError(err)

	migrationContext := newTestMigrationContext()
	migrationContext.ApplierConnectionConfig = connectionConfig
	migrationContext.InspectorConnectionConfig = connectionConfig
	migrationContext.SetConnectionConfig("innodb")

	migrationContext.AlterStatementOptions = "add column name varchar(20)"
	migrationContext.OriginalTableColumns = sql.NewColumnList([]string{"id", "id2"})
	migrationContext.SharedColumns = sql.NewColumnList([]string{"id", "id2"})
	migrationContext.MappedSharedColumns = sql.NewColumnList([]string{"id", "id2"})
	migrationContext.Checkpoint = true
	migrationContext.UniqueKey = &sql.UniqueKey{
		Name:             "PRIMARY",
		NameInGhostTable: "PRIMARY",
		Columns:          *sql.NewColumnList([]string{"id", "id2"}),
	}

	inspector := NewInspector(migrationContext)
	suite.Require().NoError(inspector.InitDBConnections())

	err = inspector.applyColumnTypes(testMysqlDatabase, testMysqlTableName, &migrationContext.UniqueKey.Columns)
	suite.Require().NoError(err)

	applier := NewApplier(migrationContext)

	err = applier.InitDBConnections()
	suite.Require().NoError(err)

	err = applier.CreateChangelogTable()
	suite.Require().NoError(err)

	err = applier.CreateCheckpointTable()
	suite.Require().NoError(err)

	err = applier.prepareQueries()
	suite.Require().NoError(err)

	err = applier.ReadMigrationRangeValues()
	suite.Require().NoError(err)

	// checkpoint table is empty
	_, err = applier.ReadLastCheckpoint()