diff --git a/doc/src/sgml/connection-pooling.sgml b/doc/src/sgml/connection-pooling.sgml
index daa84c3f7..eaaade5f7 100644
--- a/doc/src/sgml/connection-pooling.sgml
+++ b/doc/src/sgml/connection-pooling.sgml
@@ -380,7 +380,7 @@
      <para>
       <productname>Pgpool-II</productname> supports two destinations
       for logging the <productname>Pgpool-II</productname> messages.
-      The supported log destinations are <literal>stderr</literal>
+      The supported log destinations are <literal>stderr</literal>, <literal>csvlog</literal>
       and <literal>syslog</literal>. You can also set this parameter to a list
       of desired log destinations separated by commas if you want the log messages
       on the multiple destinations.
diff --git a/src/Makefile.am b/src/Makefile.am
index e32c41269..7a5e5e887 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -53,6 +53,7 @@ pgpool_SOURCES = main/main.c \
 	utils/mmgr/mcxt.c \
 	utils/mmgr/aset.c \
 	utils/error/elog.c \
+	utils/error/csvlog.c \
 	utils/error/assert.c \
 	utils/pcp/pcp_stream.c \
 	utils/regex_array.c \
diff --git a/src/config/pool_config_variables.c b/src/config/pool_config_variables.c
index 4fa039664..41a290d6b 100644
--- a/src/config/pool_config_variables.c
+++ b/src/config/pool_config_variables.c
@@ -4423,6 +4423,10 @@ LogDestinationProcessFunc(char *newval, int elevel)
 		{
 			log_destination |= LOG_DESTINATION_STDERR;
 		}
+		else if (!strcmp(destinations[i], "csvlog"))
+		{
+			log_destination |= LOG_DESTINATION_CSVLOG;
+		}
 		else
 		{
 			int			k;
diff --git a/src/include/utils/elog.h b/src/include/utils/elog.h
index 92eb298fa..3364a67b4 100644
--- a/src/include/utils/elog.h
+++ b/src/include/utils/elog.h
@@ -528,5 +528,9 @@ void		on_proc_exit(pg_on_exit_callback function, Datum arg);
 void		on_shmem_exit(pg_on_exit_callback function, Datum arg);
 void		on_system_exit(pg_on_exit_callback function, Datum arg);
 
+/* Destination-specific functions */
+extern void write_csvlog(ErrorData *edata);
+extern const char *error_severity(int elevel, bool for_frontend);
+extern void write_pipe_chunks(char *data, int len, int dest);
 
 #endif							/* ELOG_H */
diff --git a/src/sample/pgpool.conf.sample-stream b/src/sample/pgpool.conf.sample-stream
index ee3757b17..44d427e23 100644
--- a/src/sample/pgpool.conf.sample-stream
+++ b/src/sample/pgpool.conf.sample-stream
@@ -233,7 +233,7 @@ backend_clustering_mode = 'streaming_replication'
 #log_destination = 'stderr'
                                    # Where to log
                                    # Valid values are combinations of stderr,
-                                   # and syslog. Default to stderr.
+                                   # csvlog and syslog. Default to stderr.
 
 # - What to log -
 
diff --git a/src/utils/error/csvlog.c b/src/utils/error/csvlog.c
new file mode 100644
index 000000000..9011e5e34
--- /dev/null
+++ b/src/utils/error/csvlog.c
@@ -0,0 +1,171 @@
+/*-------------------------------------------------------------------------
+ *
+ * csvlog.c
+ *	  CSV logging
+ *
+ * Portions Copyright (c) 2003-2025, PgPool Global Development Group
+ * Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
+ * Portions Copyright (c) 1994, Regents of the University of California
+ *
+ *
+ * IDENTIFICATION
+ *	  src/utils/error/csvlog.c
+ *
+ *-------------------------------------------------------------------------
+ */
+
+
+#include "pool.h"
+#include "pool_config.h"
+#include <string.h>
+#include <time.h>
+#include "main/pgpool_logger.h"
+#include "utils/elog.h"
+#include "utils/memutils.h"
+#include "utils/ps_status.h"
+#include "context/pool_session_context.h"
+
+
+/*
+ * append a CSV'd version of a string to a StringInfo
+ * We use the PostgreSQL defaults for CSV, i.e. quote = escape = '"'
+ * If it's NULL, append nothing.
+ */
+static inline void
+appendCSVLiteral(StringInfo buf, const char *data)
+{
+	const char *p = data;
+	char		c;
+
+	/* avoid confusing an empty string with NULL */
+	if (p == NULL)
+		return;
+
+	appendStringInfoCharMacro(buf, '"');
+	while ((c = *p++) != '\0')
+	{
+		if (c == '"')
+			appendStringInfoCharMacro(buf, '"');
+		appendStringInfoCharMacro(buf, c);
+	}
+	appendStringInfoCharMacro(buf, '"');
+}
+
+/*
+ * write_csvlog -- Generate and write CSV log entry
+ *
+ * Constructs the error message, depending on the Errordata it gets.
+ */
+void
+write_csvlog(ErrorData *edata)
+{
+	StringInfoData buf;
+	char		strbuf[129];
+
+	/* static counter for line numbers */
+	static long log_line_number = 0;
+
+    char *appname;
+
+	/* has counter been reset in current process? */
+	static int	log_my_pid = 0;
+
+	POOL_CONNECTION *frontend = NULL;
+	POOL_SESSION_CONTEXT *session = pool_get_session_context(true);
+
+    if (session)
+		frontend = session->frontend;
+
+	/*
+	 * This is one of the few places where we'd rather not inherit a static
+	 * variable's value from the postmaster.  But since we will, reset it when
+	 * MyProcPid changes.
+	 */
+	if (log_my_pid != myProcPid)
+	{
+		log_line_number = 0;
+		log_my_pid = myProcPid;
+	}
+	log_line_number++;
+
+	initStringInfo(&buf);
+
+	/* timestamp with milliseconds */
+    time_t		now = time(NULL);
+    strftime(strbuf, sizeof(strbuf), "%Y-%m-%d %H:%M:%S", localtime(&now));
+	appendCSVLiteral(&buf, strbuf);
+	appendStringInfoChar(&buf, ',');
+
+    appname = get_application_name();
+	/* application name */
+	if (appname)
+		appendCSVLiteral(&buf, appname);
+
+	appendStringInfoChar(&buf, ',');
+
+	/* Process id  */
+	if (myProcPid != 0)
+		appendStringInfo(&buf, "%d", myProcPid);
+	appendStringInfoChar(&buf, ',');
+
+	/* Error severity */
+	appendStringInfoString(&buf, _(error_severity(edata->elevel, false)));
+	appendStringInfoChar(&buf, ',');
+
+	/* Line number */
+	appendStringInfo(&buf, "%ld", log_line_number);
+	appendStringInfoChar(&buf, ',');
+
+	/* username */
+    const char *username = frontend ? frontend->username : "[No Connection]";
+    appendCSVLiteral(&buf, username);
+	appendStringInfoChar(&buf, ',');
+
+	/* database name */
+    const char *dbname = frontend ? frontend->database : "[No Connection]";
+	appendCSVLiteral(&buf, dbname);
+	appendStringInfoChar(&buf, ',');
+
+	/* errmessage */
+	appendCSVLiteral(&buf, edata->message);
+	appendStringInfoChar(&buf, ',');
+
+	/* errdetail or errdetail_log */
+	if (edata->detail_log)
+		appendCSVLiteral(&buf, edata->detail_log);
+	else
+		appendCSVLiteral(&buf, edata->detail);
+	appendStringInfoChar(&buf, ',');
+
+	/* errhint */
+	appendCSVLiteral(&buf, edata->hint);
+	appendStringInfoChar(&buf, ',');
+
+	/* file error location */
+	if (pool_config->log_error_verbosity >= PGERROR_VERBOSE)
+	{
+		StringInfoData msgbuf;
+
+		initStringInfo(&msgbuf);
+
+		if (edata->funcname && edata->filename)
+			appendStringInfo(&msgbuf, "%s, %s:%d",
+							 edata->funcname, edata->filename,
+							 edata->lineno);
+		else if (edata->filename)
+			appendStringInfo(&msgbuf, "%s:%d",
+							 edata->filename, edata->lineno);
+		appendCSVLiteral(&buf, msgbuf.data);
+		pfree(msgbuf.data);
+	}
+
+	appendStringInfoChar(&buf, '\n');
+
+	/* If in the syslogger process, try to write messages direct to file */
+	if (processType == PT_LOGGER)
+		write_syslogger_file(buf.data, buf.len, LOG_DESTINATION_CSVLOG);
+	else
+		write_pipe_chunks(buf.data, buf.len, LOG_DESTINATION_CSVLOG);
+
+	pfree(buf.data);
+}
diff --git a/src/utils/error/elog.c b/src/utils/error/elog.c
index ff978e7e6..a437001e2 100644
--- a/src/utils/error/elog.c
+++ b/src/utils/error/elog.c
@@ -148,7 +148,6 @@ static void write_syslog(int level, const char *line);
 
 static void send_message_to_server_log(ErrorData *edata);
 static void send_message_to_frontend(ErrorData *edata);
-static void write_pipe_chunks(char *data, int len, int dest);
 static void write_console(const char *line, int len);
 static void log_line_prefix(StringInfo buf, const char *line_prefix, ErrorData *edata);
 static const char *process_log_prefix_padding(const char *p, int *ppadding);
@@ -184,7 +183,6 @@ static int	frontend_error_recursion_depth = 0; /* to detect recursion in
 
 static char *expand_fmt_string(const char *fmt, ErrorData *edata);
 static const char *useful_strerror(int errnum);
-static const char *error_severity(int elevel, bool for_frontend);
 static const char *process_name(void);
 static void append_with_tabs(StringInfo buf, const char *str);
 static bool is_log_level_output(int elevel, int log_min_level);
@@ -1847,7 +1845,7 @@ write_console(const char *line, int len)
  * warning from ignoring write()'s result, so do a little dance with casting
  * rc to void to shut up the compiler.
  */
-static void
+void
 write_pipe_chunks(char *data, int len, int dest)
 {
 	PipeProtoChunk p;
@@ -2365,6 +2363,20 @@ send_message_to_server_log(ErrorData *edata)
 	}
 #endif							/* HAVE_SYSLOG */
 
+	/* Write to csvlog, if enabled */
+	if (pool_config->log_destination & LOG_DESTINATION_CSVLOG)
+	{
+		/*
+		 * Send CSV data if it's safe to do so (syslogger doesn't need the
+		 * pipe).  If this is not possible, fallback to an entry written to
+		 * stderr.
+		 */
+		if (redirection_done || processType == PT_LOGGER)
+			write_csvlog(edata);
+		else
+			write_console(buf.data, buf.len);
+	}
+
 	if (pool_config->log_destination & LOG_DESTINATION_STDERR)
 	{
 		/*
@@ -2473,7 +2485,7 @@ useful_strerror(int errnum)
 /*
  * error_severity --- get localized string representing elevel
  */
-static const char *
+const char *
 error_severity(int elevel, bool for_frontend)
 {
 	const char *prefix;
@@ -2547,7 +2559,7 @@ append_with_tabs(StringInfo buf, const char *str)
 /*
  * process_name --- get process name string of current process
  */
-static const char *
+const char *
 process_name(void)
 {
 	const char *prefix;