Function TestStorage

storage/storage_test.go:111–378

(t *testing.T)

}

func TestStorage(t *testing.T) {
	fl, err := ioutil.TempFile("", "sqlite3-")

	if err != nil {
		t.Fatalf("error occurred: %v", err)
	}

	st, err := New(fmt.Sprintf("file:%s", fl.Name()))
	defer st.Close()

	if err != nil {
		t.Fatalf("error occurred: %v", err)
	}

	el1 := &ExecLog{
		ConnectionID: 1,
		SeqNo:        1,
		Timestamp:    time.Now().UnixNano(),
		Queries: []Query{
			newQuery("CREATE TABLE IF NOT EXISTS `kv` (`key` TEXT PRIMARY KEY, `value` BLOB)"),
			newQuery("INSERT OR IGNORE INTO `kv` VALUES ('k0', NULL)"),
			newQuery("INSERT OR IGNORE INTO `kv` VALUES ('k1', 'v1')"),
			newQuery("INSERT OR IGNORE INTO `kv` VALUES ('k2', 'v2')"),
			newQuery("INSERT OR IGNORE INTO `kv` VALUES ('k3', 'v3')"),
			newQuery("INSERT OR REPLACE INTO `kv` VALUES ('k3', 'v3-2')"),
			newQuery("DELETE FROM `kv` WHERE `key`='k2'"),
		},
	}

	el2 := &ExecLog{
		ConnectionID: 1,
		SeqNo:        2,
		Timestamp:    time.Now().UnixNano(),
		Queries: []Query{
			newQuery("INSERT OR REPLACE INTO `kv` VALUES ('k1', 'v1-2')"),
		},
	}

	if err = st.Prepare(context.Background(), el1); err != nil {
		t.Fatalf("error occurred: %v", err)
	}

	if err = st.Prepare(context.Background(), el1); err != nil {
		t.Fatalf("error occurred: %v", err)
	}

	if err = st.Prepare(context.Background(), el2); err == nil {
		t.Fatal("unexpected result: returned nil while expecting an error")
	} else {
		t.Logf("Error occurred as expected: %v", err)
	}

	if _, err = st.Commit(context.Background(), el2); err == nil {
		t.Fatal("unexpected result: returned nil while expecting an error")
	} else {
		t.Logf("Error occurred as expected: %v", err)
	}