Merge pull request #96 from ThePrez/test/extendedchar

Improved support for multibyte characters

Author: worksofliam

src/connection/serverComponent.ts

@@ -56,7 +56,7 @@ export class ServerComponent {
     const path = this.getComponentPath();
 
     if (path) {
-      return `/QOpenSys/QIBM/ProdData/JavaVM/jdk80/64bit/bin/java -jar ${path}`
+      return `/QOpenSys/QIBM/ProdData/JavaVM/jdk80/64bit/bin/java -Dos400.stdio.convert=N -jar ${path}`
     }
   }
 

src/connection/sqlJob.ts

@@ -56,7 +56,8 @@ export class SQLJob {
     const instance = getInstance();
     const connection = instance.getConnection();
     return new Promise((resolve, reject) => {
-      connection.client.connection.exec(ServerComponent.getInitCommand() + ` && exit`, {}, (err: any, stream: any) => {
+      // Setting QIBM_JAVA_STDIO_CONVERT and QIBM_PASE_DESCRIPTOR_STDIO to make sure all PASE and Java converters are off
+      connection.client.connection.exec(`QIBM_JAVA_STDIO_CONVERT=N QIBM_PASE_DESCRIPTOR_STDIO=B exec `+ServerComponent.getInitCommand(), {}, (err: any, stream: any, options: {encoding: `binary`}) => {
         if (err)
           reject(err);
         let outString = ``;

src/testing/jobs.ts

@@ -100,6 +100,22 @@ export const JobsSuite: TestSuite = {
       newJob.close();
     }},
 
+    {name: `Can round-trip Extended characters`, test: async () => {
+      assert.strictEqual(ServerComponent.isInstalled(), true);
+
+      let testString = `¯\\_(ツ)_/¯`
+      let newJob = new SQLJob();
+      await newJob.connect();
+      let qryResults = await newJob.query(`create table qtemp.weewoo (col1 varchar(1208) ccsid 1208)`).run();
+      assert.equal(qryResults.success, true);
+      qryResults = await newJob.query(`insert into qtemp.weewoo values('${testString}')`).run();
+      assert.equal(qryResults.success, true);
+      qryResults = await newJob.query(`select COL1 from qtemp.weewoo`).run();
+      assert.equal(qryResults.success, true);
+      let resultData = qryResults.data[0]['COL1'];
+      assert.equal(resultData, testString);
+      newJob.close();
+    }},
     {name: `Auto close statements`, test: async () => {
       let newJob = new SQLJob();
       await newJob.connect();