Parametrized queries permitted?

[ashi1702]

Hey! I was migrating to this plugin but fell short at running parametrized SQL queries.

Example:
awsClient.query('SELECT * FROM table where uuid = $1', [ 'MY_UUID' ]);

I believe this is an out of the box functionality when using the pg package.

error stack:

Error during database operations: error: there is no parameter $1
    at MY_PROJECT_PATH/api-db-pkg-v2/node_modules/pg/lib/client.js:545:17
    at process.processTicksAndRejections (node:internal/process/task_queues:105:5)
    at async file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/plugins/default_plugin.js:57:53
    at async NullTelemetryContext.start (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/utils/telemetry/null_telemetry_context.js:22:12)
    at async DefaultPlugin.execute (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/plugins/default_plugin.js:57:12)
    at async NullTelemetryContext.start (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/utils/telemetry/null_telemetry_context.js:22:12)
    at async HostMonitoringConnectionPlugin.execute (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/plugins/efm/host_monitoring_connection_plugin.js:69:16)
    at async NullTelemetryContext.start (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/utils/telemetry/null_telemetry_context.js:22:12)
    at async FailoverPlugin.execute (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/plugins/failover/failover_plugin.js:176:14)
    at async NullTelemetryContext.start (file://MY_PROJECT_PATH/api-db-pkg-v2/node_modules/aws-advanced-nodejs-wrapper/dist/common/lib/utils/telemetry/null_telemetry_context.js:22:12) {
  length: 94,
  severity: 'ERROR',
  code: '42P02',
  detail: undefined,
  hint: undefined,
  position: '33',
  internalPosition: undefined,
  internalQuery: undefined,
  where: undefined,
  schema: undefined,
  table: undefined,
  column: undefined,
  dataType: undefined,
  constraint: undefined,
  file: 'parse_expr.c',
  line: '893',
  routine: 'transformParamRef'
}

i've setup the awsClient using the docs at Aws Driver Examples

With the same setup i am able to successfully execute:
awsClient.query(SELECT * FROM table where uuid = 'MY_ID')

I'm using AwsPGClient with pooling.

const poolConfig = new AwsPoolConfig({
  idleTimeoutMillis: 10000,
  allowExitOnIdle: true
})

const provider = new InternalPooledConnectionProvider(poolConfig)

const params = {
  plugins: 'readWriteSplitting,efm',
  connectionProvider: provider
}

AWS_CLIENT = new AwsPGClient({
  user: postgres.pguser,
  host: postgres.pghost,
  database: postgres.pgdatabase,
  password: postgres.pgpassword,
  port: postgres.pgport,
  ssl: { rejectUnauthorized: false },
  ...params
})

[karenc-bq]

Hi @ashi1702 , thank you for raising this issue, we will investigate this and get back to you!

[ashi1702]

Thanks @karenc-bq. Looking for a quick TAT for your initial findings. We had planned to move about 4-5 Aurora Databases behind this package but our repos heavily use parametrized SQL statements. It's a blocker for us and potentially prevents us from advocating for the package in our org.

[karenc-bq]

Hi @ashi1702, just wanted to give you an update and let you know that we are working on a fix for this issue.

[karenc-bq]

Hi @ashi1702, we have released version 2.0.0 of the Wrapper with parameterized query support, see our docs for examples.

Could you please give it a try and let us know if you run into issues.