From 335b3843ae63c5e80e2e335f9d9518fffee313ae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Turkalp=20Burak=20Kayranc=C4=B1o=C4=9Flu?= Date: Mon, 13 Feb 2023 01:33:29 +0300 Subject: [PATCH] pass connection options to postgresql client MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Turkalp Burak Kayrancıoğlu --- plugins/out_pgsql/pgsql.c | 3 +++ plugins/out_pgsql/pgsql.h | 3 +++ plugins/out_pgsql/pgsql_connections.c | 5 ++++- 3 files changed, 10 insertions(+), 1 deletion(-) diff --git a/plugins/out_pgsql/pgsql.c b/plugins/out_pgsql/pgsql.c index f894769328d..a01090c1ab0 100644 --- a/plugins/out_pgsql/pgsql.c +++ b/plugins/out_pgsql/pgsql.c @@ -92,6 +92,9 @@ static int cb_pgsql_init(struct flb_output_instance *ins, ctx->db_table = flb_sds_create(FLB_PGSQL_TABLE); } + /* connection options */ + ctx->conn_options = flb_output_get_property("connection_options", ins); + if (!ctx->db_table) { flb_errno(); pgsql_conf_destroy(ctx); diff --git a/plugins/out_pgsql/pgsql.h b/plugins/out_pgsql/pgsql.h index 549c90408a7..c0214d0c1b1 100644 --- a/plugins/out_pgsql/pgsql.h +++ b/plugins/out_pgsql/pgsql.h @@ -67,6 +67,9 @@ struct flb_pgsql_config { /* instance reference */ struct flb_output_instance *ins; + /* connections */ + const char *conn_options; + /* connections pool */ struct mk_list conn_queue; struct mk_list _head; diff --git a/plugins/out_pgsql/pgsql_connections.c b/plugins/out_pgsql/pgsql_connections.c index 6e4965c0854..58b5d1a3e27 100644 --- a/plugins/out_pgsql/pgsql_connections.c +++ b/plugins/out_pgsql/pgsql_connections.c @@ -54,9 +54,12 @@ void *pgsql_create_connection(struct flb_pgsql_config *ctx) flb_errno(); return NULL; } + + flb_plg_debug(ctx->ins, "connection_options: %s", ctx->conn_options); conn->conn = PQsetdbLogin(ctx->db_hostname, ctx->db_port, - NULL, NULL, + ctx->conn_options, + NULL, ctx->db_name, ctx->db_user, ctx->db_passwd);