Adding postgres query into the test for Travis.CI

Author: Michael Anderson

.travis.yml

@@ -2,4 +2,7 @@ language: node_js
 node_js:
   - "8"
   - "7"
-  - "6"
+  - "6"
+services: postgresql
+before_script:
+  - psql -c 'create database test;' -U postgres

index.js

@@ -9,6 +9,11 @@ class PostgreSQL {
         this[m_transaction] = false;
     }
 
+    /**
+     * Queries the database
+     * @param {string} sql 
+     * @returns {Promise<Array<any>>}
+     */
     query(sql) {
         var self = this;
         return new Promise((resolve, reject) => {
@@ -24,10 +29,19 @@ class PostgreSQL {
         });
     }
 
+    /**
+     * Executes the sql on the database
+     * @param {string} sql 
+     * @returns {Promise<Array<any>>}
+     */
     execute(sql) {
         return this.query(sql);
     }
 
+    /**
+     * Closes the database
+     * @returns {Promise}
+     */
     close() {
         var self = this;
         return new Promise((resolve, reject) => {
@@ -102,8 +116,9 @@ class PostgreSQL {
 }
 
 /**
- * 
+ * Opens a connection
  * @param {{Hostname: string, Port: number, Username: string, Password: string, Database: string}} connection 
+ * @returns {PostgreSQL}
  */
 function OpenConnection(connection) {
     let base = new pg.Client({

test.js

@@ -1 +1,33 @@
 var Postgres = require('.');
+
+
+var Connection = Postgres.open({
+    Hostname: 'localhost',
+    Port: 5432,
+    Username: 'postgres',
+    Database: 'test'
+});
+
+var promises = [];
+promises.push(Connection.execute('DROP TABLE IF EXISTS test1; CREATE TABLE test1 (key character varying(255), value character varying(1024));').then(() => {
+    promises.push(Connection.execute("INSERT INTO test1 VALUES('name', 'Michael Anderson');").then(() => {
+        promises.push(Connection.query("SELECT * FROM test1 WHERE key = 'name';").then(data => {
+            if (data.length != 1) {
+                console.error('Invalid data returned');
+                Connection.execute('DROP TABLE test1;').then(() => {
+                    Connection.close().then(() => {
+                        process.exit(1);
+                    });
+                })
+            }
+        }));
+    }));
+}));
+
+Promise.all(promises).then(() => {
+    Connection.execute('DROP TABLE IF EXISTS test1;').then(() => {
+        Connection.close().then(() => {
+            process.exit(0);
+        });
+    });
+});