Function TestBuildInsert

internal/persistence/sql/query_test.go:54–109

(t *testing.T)

}

func TestBuildInsert(t *testing.T) {
	t.Parallel()
	nid := uuidx.NewV4()

	q, args, err := buildInsert(time.Now(), nid, nil)
	assert.Error(t, err)
	assert.Empty(t, q)
	assert.Empty(t, args)

	obj1, obj2, sub1, obj3 := uuidx.NewV4(), uuidx.NewV4(), uuidx.NewV4(), uuidx.NewV4()

	now := time.Now()

	q, args, err = buildInsert(now, nid, []*relationtuple.RelationTuple{
		{
			Namespace: "ns1",
			Object:    obj1,
			Relation:  "rel1",
			Subject: &relationtuple.SubjectID{
				ID: sub1,
			},
		},
		{
			Namespace: "ns2",
			Object:    obj2,
			Relation:  "rel2",
			Subject: &relationtuple.SubjectSet{
				Namespace: "ns3",
				Object:    obj3,
				Relation:  "rel3",
			},
		},
	})
	require.NoError(t, err)

	assert.Equal(t, q, "INSERT INTO keto_relation_tuples (shard_id, nid, namespace, object, relation, subject_id, subject_set_namespace, subject_set_object, subject_set_relation, commit_time) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?), (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
	assert.Equal(t, []any{
		args[0], // this is kind of cheating but we generate the shard id in the buildInsert function
		nid,
		"ns1",
		obj1,
		"rel1",
		uuid.NullUUID{UUID: sub1, Valid: true},
		sql.NullString{}, uuid.NullUUID{}, sql.NullString{},
		now,

		args[10], // again, cheating
		nid,
		"ns2",
		obj2,
		"rel2",
		uuid.NullUUID{},
		sql.NullString{String: "ns3", Valid: true}, uuid.NullUUID{UUID: obj3, Valid: true}, sql.NullString{String: "rel3", Valid: true},
		now,
	}, args)
}

func TestBuildInsertUUIDs(t *testing.T) {