Function TestDbUnknownTableColumns

driver/registry_sql_test.go:158–195

(t *testing.T)

}

func TestDbUnknownTableColumns(t *testing.T) {
	t.Parallel()

	dsn := dbal.NewSQLiteTestDatabase(t)
	reg, err := New(t.Context(), WithConfigOptions(configx.WithValue("dsn", dsn)), WithAutoMigrate())
	require.NoError(t, err)

	statement := `ALTER TABLE "hydra_client" ADD COLUMN "temp_column" VARCHAR(128) NOT NULL DEFAULT '';`
	require.NoError(t, reg.Persister().Connection(t.Context()).RawQuery(statement).Exec())

	cl := &client.Client{
		ID: strconv.Itoa(rand.Int()),
	}
	require.NoError(t, reg.Persister().CreateClient(t.Context(), cl))
	getClients := func(ctx context.Context, reg *RegistrySQL) ([]client.Client, error) {
		readClients := make([]client.Client, 0)
		conn := reg.Persister().Connection(ctx)
		cols := popx.DBColumns[client.Client](conn.Dialect)
		return readClients, conn.RawQuery(fmt.Sprintf(`SELECT %s, temp_column FROM "hydra_client"`, cols)).All(&readClients)
	}

	t.Run("with ignore disabled (default behavior)", func(t *testing.T) {
		_, err := getClients(t.Context(), reg)
		assert.ErrorContains(t, err, "missing destination name temp_column")
	})

	t.Run("with ignore enabled", func(t *testing.T) {
		reg, err := New(t.Context(), WithConfigOptions(
			configx.WithValue("dsn", dsn),
			configx.WithValue(config.KeyDBIgnoreUnknownTableColumns, true),
		))
		require.NoError(t, err)

		actual, err := getClients(t.Context(), reg)
		require.NoError(t, err)
		assert.Len(t, actual, 1)
	})
}

func failedPing(err error) func(context.Context, *logrusx.Logger, *sql.BasePersister) error {
	return func(context.Context, *logrusx.Logger, *sql.BasePersister) error {