From 4c254e8edf3ac511048f44fe7cbb74d64f72610f Mon Sep 17 00:00:00 2001
From: Arkady Emelyanov <arkady.emelyanov@gmail.com>
Date: Sat, 26 Jan 2013 16:36:09 +0400
Subject: [PATCH] force utf-8 encoding on connect

---
 lib/connection-parameters.js                   | 1 +
 lib/connection.js                              | 2 ++
 test/unit/connection/outbound-sending-tests.js | 2 ++
 3 files changed, 5 insertions(+)

diff --git a/lib/connection-parameters.js b/lib/connection-parameters.js
index 55efd0f5..98faa826 100644
--- a/lib/connection-parameters.js
+++ b/lib/connection-parameters.js
@@ -61,6 +61,7 @@ ConnectionParameters.prototype.getLibpqConnectionString = function(cb) {
     params.push("host=" + this.getDomainSocketName());
     return cb(null, params.join(' '));
   }
+  params.push("options=--client_encoding='utf-8'");
   dns.lookup(this.host, function(err, address) {
     if(err) return cb(err, null);
     params.push("hostaddr=" + address);
diff --git a/lib/connection.js b/lib/connection.js
index 06aa687e..ffd7d9c5 100644
--- a/lib/connection.js
+++ b/lib/connection.js
@@ -116,6 +116,8 @@ p.startup = function(config) {
     .addCString(config.user)
     .addCString('database')
     .addCString(config.database)
+    .addCString('options')
+    .addCString("--client_encoding='utf-8'")
     .addCString('').flush();
   //this message is sent without a code
 
diff --git a/test/unit/connection/outbound-sending-tests.js b/test/unit/connection/outbound-sending-tests.js
index 731a46de..2679dfda 100644
--- a/test/unit/connection/outbound-sending-tests.js
+++ b/test/unit/connection/outbound-sending-tests.js
@@ -23,6 +23,8 @@ test("sends startup message", function() {
                   .addCString('brian')
                   .addCString('database')
                   .addCString('bang')
+                  .addCString('options')
+                  .addCString("--client_encoding='utf-8'")
                   .addCString('').join(true))
 });