Index: configs/cdr_pgsql.conf.sample =================================================================== --- configs/cdr_pgsql.conf.sample (revision 287933) +++ configs/cdr_pgsql.conf.sample (working copy) @@ -7,3 +7,4 @@ ;password=password ;user=postgres ;table=cdr ;SQL table where CDRs will be inserted +;encoding=LATIN9 ; Encoding of logged characters in Asterisk (this is unlikely to be UTF8). Index: cdr/cdr_pgsql.c =================================================================== --- cdr/cdr_pgsql.c (revision 287933) +++ cdr/cdr_pgsql.c (working copy) @@ -54,7 +54,7 @@ static char *name = "pgsql"; static char *config = "cdr_pgsql.conf"; -static char *pghostname = NULL, *pgdbname = NULL, *pgdbuser = NULL, *pgpassword = NULL, *pgdbport = NULL, *table = NULL; +static char *pghostname = NULL, *pgdbname = NULL, *pgdbuser = NULL, *pgpassword = NULL, *pgdbport = NULL, *table = NULL, *encoding = NULL; static int connected = 0; static int maxsize = 512, maxsize2 = 512; @@ -112,6 +112,9 @@ conn = PQsetdbLogin(pghostname, pgdbport, NULL, NULL, pgdbname, pgdbuser, pgpassword); if (PQstatus(conn) != CONNECTION_BAD) { connected = 1; + if (PQsetClientEncoding(conn, encoding)) { + ast_log(LOG_WARNING, "Failed to set encoding to '%s'. Encoding set to default '%s'\n", encoding, pg_encoding_to_char(PQclientEncoding(conn))); + } } else { pgerror = PQerrorMessage(conn); ast_log(LOG_ERROR, "Unable to connect to database server %s. Calls will not be logged!\n", pghostname); @@ -452,6 +455,19 @@ return -1; } + if (!(tmp = ast_variable_retrieve(cfg, "global", "encoding"))) { + ast_log(LOG_WARNING, "Encoding not specified. Assuming LATIN9\n"); + tmp = "LATIN9"; + } + + if (encoding) { + ast_free(encoding); + } + if (!(encoding = ast_strdup(tmp))) { + ast_config_destroy(cfg); + return -1; + } + if (option_debug) { if (ast_strlen_zero(pghostname)) { ast_debug(1, "using default unix socket\n"); @@ -472,6 +488,9 @@ int i, rows, version; ast_debug(1, "Successfully connected to PostgreSQL database.\n"); connected = 1; + if (PQsetClientEncoding(conn, encoding)) { + ast_log(LOG_WARNING, "Failed to set encoding to '%s'. Encoding set to default '%s'\n", encoding, pg_encoding_to_char(PQclientEncoding(conn))); + } version = PQserverVersion(conn); if (version >= 70300) {