Function currentDatabase

plugins/destination/postgresql/client/client.go:166–173

(ctx context.Context, conn DBPool)

}

func currentDatabase(ctx context.Context, conn DBPool) (string, error) {
	var db string
	err := conn.QueryRow(ctx, "select current_database()").Scan(&db)
	if err != nil {
		return "", err
	}
	return db, nil
}

func currentSchema(ctx context.Context, conn DBPool) (string, error) {
	var schema string