Function Test_CDC_SingleNode_PostLoadBoot

system_test/cdc_test.go:173–248

Test_CDC_SingleNode_PostLoadBoot verifies that CDC continues to operate after a node is loaded or booted.

(t *testing.T)

// Test_CDC_SingleNode_PostLoadBoot verifies that CDC continues to operate
// after a node is loaded or booted.
func Test_CDC_SingleNode_PostLoadBoot(t *testing.T) {
	node := mustNewLeaderNode("node1")
	defer node.Deprovision()

	testEndpoint := cdctest.NewHTTPTestServer()

	// Configure CDC before opening the store.
	cdcCluster := cdc.NewCDCCluster(node.Store, node.Cluster, node.Client)
	cdcService, err := cdc.NewService(node.ID, node.Dir, cdcCluster, mustCDCConfig(testEndpoint.URL()))
	if err != nil {
		t.Fatalf("failed to create CDC service: %s", err.Error())
	}
	node.CDC = cdcService
	node.CDC.Start()
	node.CDC.SetLeader(true)

	node.Store.EnableCDC(node.CDC.C(), nil, false)

	_, err = node.Execute(`CREATE TABLE foo (id integer not null primary key, name text)`)
	if err != nil {
		t.Fatalf("failed to create table: %v", err)
	}
	_, err = node.Execute(`INSERT INTO foo (id, name) VALUES (1, 'Alice')`)
	if err != nil {
		t.Fatalf("failed to insert data: %v", err)
	}
	_, err = node.Execute(`UPDATE foo SET name = 'Alice Updated' WHERE id = 1`)
	if err != nil {
		t.Fatalf("failed to update data: %v", err)
	}
	_, err = node.Execute(`DELETE FROM foo WHERE id = 1`)
	if err != nil {
		t.Fatalf("failed to delete data: %v", err)
	}

	testEndpoint.Start()
	defer testEndpoint.Close()

	testPoll(t, func() (bool, error) {
		// 1 insert, 1 update, 1 delete
		return testEndpoint.GetMessageCount() == 3, nil
	}, 100*time.Millisecond, 5*time.Second)

	// Load the node, and ensure CDC continues to work.
	if _, err := node.Load(filepath.Join("testdata", "auto-restore.sqlite")); err != nil {
		t.Fatalf("failed to boot node: %s", err.Error())
	}
	_, err = node.Execute(`CREATE TABLE qux1 (id integer not null primary key, name text)`)
	if err != nil {
		t.Fatalf("failed to create table: %v", err)
	}
	_, err = node.Execute(`INSERT INTO qux1 (id, name) VALUES (100, 'Declan')`)
	if err != nil {
		t.Fatalf("failed to insert data: %v", err)
	}
	testPoll(t, func() (bool, error) {
		return testEndpoint.GetMessageCount() == 4, nil
	}, 100*time.Millisecond, 5*time.Second)