PostgreSQL функция: связь не существует ошибка - PullRequest
1 голос
/ 20 июня 2020

Я получаю ошибку ниже при вызове функции Postgresql с аргументом, содержащим оператор точка (.).

SQL Error [42P01]: ERROR: relation "es.article_data" does not exist Where: PL/pgSQL function es.getrowcount(text) line 6 at EXECUTE....

Запрос: выберите es.getrowcount (schemawithtable: = 'es.article_data');

Функция:

CREATE FUNCTION es.getrowcount (schemawithtable text)
RETURNS VARCHAR(50) AS $msg$
declare
    msg VARCHAR(50);
    total integer;
begin
  execute format('select count(*) from %I where until_ts is null', schemawithtable) into total;
   msg := CONCAT(total, ' records are there in ',schemawithtable);
   RETURN msg;
END;
$msg$ LANGUAGE plpgsql;

Следы ошибок от DBeaver:

org.jkiss.dbeaver.model.sql.DBSQLException: SQL Error [42P01]: ERROR: relation "es.article_data" does not exist
  Where: PL/pgSQL function es.getrowcount(text) line 6 at EXECUTE

    at org.jkiss.dbeaver.model.impl.jdbc.exec.JDBCStatementImpl.executeStatement(JDBCStatementImpl.java:134)

    at org.jkiss.dbeaver.ui.editors.sql.execute.SQLQueryJob.executeStatement(SQLQueryJob.java:487)

    at org.jkiss.dbeaver.ui.editors.sql.execute.SQLQueryJob.lambda$0(SQLQueryJob.java:424)

    at org.jkiss.dbeaver.model.exec.DBExecUtils.tryExecuteRecover(DBExecUtils.java:164)

    at org.jkiss.dbeaver.ui.editors.sql.execute.SQLQueryJob.executeSingleQuery(SQLQueryJob.java:416)

    at org.jkiss.dbeaver.ui.editors.sql.execute.SQLQueryJob.extractData(SQLQueryJob.java:774)

    at org.jkiss.dbeaver.ui.editors.sql.SQLEditor$QueryResultsContainer.readData(SQLEditor.java:2914)

    at org.jkiss.dbeaver.ui.controls.resultset.ResultSetJobDataRead.lambda$0(ResultSetJobDataRead.java:110)

    at org.jkiss.dbeaver.model.exec.DBExecUtils.tryExecuteRecover(DBExecUtils.java:164)

    at org.jkiss.dbeaver.ui.controls.resultset.ResultSetJobDataRead.run(ResultSetJobDataRead.java:108)

    at org.jkiss.dbeaver.ui.controls.resultset.ResultSetViewer$17.run(ResultSetViewer.java:3421)

    at org.jkiss.dbeaver.model.runtime.AbstractJob.run(AbstractJob.java:103)

    at org.eclipse.core.internal.jobs.Worker.run(Worker.java:63)

Caused by: org.postgresql.util.PSQLException: ERROR: relation "es.article_data" does not exist
  Where: PL/pgSQL function es.getrowcount(text) line 6 at EXECUTE

    at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2440)

    at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2183)

    at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:308)

    at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:441)

    at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:365)

    at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:307)

    at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:293)

    at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:270)

    at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:266)

    at org.jkiss.dbeaver.model.impl.jdbc.exec.JDBCStatementImpl.execute(JDBCStatementImpl.java:338)

    at org.jkiss.dbeaver.model.impl.jdbc.exec.JDBCStatementImpl.executeStatement(JDBCStatementImpl.java:131)

    ... 12 more

Я нашел обходной путь, передав имя схемы отдельно.

Рабочий запрос: выберите es.getrowcount (schemaname: = 'es', tablename: = 'article_data');

CREATE FUNCTION es.getrowcount (schemaname text, tablename text)
...
begin
  execute format('select count(*) from %I.%I where until_ts is null',schemaname, tablename) into total;
...
$msg$ LANGUAGE plpgsql;

Версии: PostgreSQL - 10.12 DBeaver (client) - 6.3.5

Но я хочу знать, почему он выдает ошибку для аргумента, содержащего точку (. ) оператор?

1 Ответ

1 голос
/ 20 июня 2020

При создании запроса с помощью format и %I. Он создает ваш запрос, как показано ниже

с одним параметром:

select count(*) from "es.article_data" where until_ts is null

с двойным параметром:

select count(*) from "es"."article_data" where until_ts is null

В первом случае он покажет ошибку, потому что вы не можете используйте имя таблицы с такой схемой. Но во втором случае это сработало отлично, так как это правильный способ использования соглашения об именах.

Если вы хотите использовать только первый метод. вы должны использовать %s вместо %I, как показано ниже

CREATE FUNCTION es.getrowcount (schemawithtable text)
RETURNS VARCHAR(50) AS $msg$
declare
    msg VARCHAR(50);
    total integer;
begin
  execute format('select count(*) from %s where until_ts is null', schemawithtable) into total;
   msg := CONCAT(total, ' records are there in ',tablename);
   RETURN msg;
END;
$msg$ LANGUAGE plpgsql;

ПРИМЕЧАНИЕ. Это будет работать правильно, если имена ваших таблиц и схемы указаны только в нижнем регистре

...