Merge pull request #3 from inf3cti0n95/rxjs6

Upgraded to RxJS 6

README.md

@@ -1,24 +1,29 @@
 # rx-sql
+
+[![Build Status](https://travis-ci.org/inf3cti0n95/rx-sql.svg?branch=master)](https://travis-ci.org/inf3cti0n95/rx-sql)
+
 RxJS Implementation of MySQL
 
-```
+```js
 import { RxSQL } from "rx-sql";
 import { createConnection } from "mysql";
+import { flatMap } from "rxjs/operators";
 
-db = createConnection({
-    host: localhost,
-    database: test,
-    user: root,
-    password: ""
+let db = createConnection({
+  host: "localhost",
+  database: "database",
+  user: "root",
+  password: "password"
 });
 
 let rxsql$ = new RxSQL(db);
 
-rxsql$.query("SELECT * FROM TESTTABLE")
-    .flatMap(result => result.col1)
-    .subscribe(
-        result => console.log(result),
-        error => console.log(error)
-    );
-
-```
+rxsql$
+  .query("SELECT * FROM table")
+  .pipe(flatMap(result => result))
+  .subscribe(
+      result => console.log(result),
+      error => console.error(error)
+      () => console.info("Completed!")
+      );
+```

lib/rx-sql.d.ts

@@ -1,8 +1,8 @@
-import { IConnection } from "mysql";
+import { Connection, QueryOptions } from "mysql";
 import { Observable } from "rxjs";
 export declare class RxSQL {
-    connection: IConnection;
-    constructor(connectionParam: IConnection);
-    query<T>(query: string): Observable<T>;
+    connection: Connection;
+    constructor(connectionParam: Connection);
+    query<T>(query: string | QueryOptions): Observable<T>;
     destroyConnection(): void;
 }

src/rx-sql.ts

@@ -1,25 +1,25 @@
-import { createConnection, IConnection, IQuery, IConnectionConfig } from "mysql";
+import { Connection, QueryOptions } from "mysql";
 import { Observable, Observer } from "rxjs";
 
 export class RxSQL {
-    public connection: IConnection;
-    constructor(connectionParam: IConnection) {
-        this.connection =  connectionParam;      
-    }
+  public connection: Connection;
+  constructor(connectionParam: Connection) {
+    this.connection = connectionParam;
+  }
 
-    public query<T>(query: string): Observable<T>{
-        return Observable.create((observer: Observer<T>) => {
-                this.connection.query(query,(error, result, fields) => {
-                        if(error)
-                            observer.error(error)
-                        else
-                            observer.next(result)
-                        observer.complete();
-                })
-        })
-    }
+  public query<T>(query: string | QueryOptions): Observable<T> {
+    return Observable.create((observer: Observer<T>) => {
+      this.connection.query(query, (error, result) => {
+        if (error) observer.error(error);
+        else {
+          observer.next(result);
+        }
+        observer.complete();
+      });
+    });
+  }
 
-    public destroyConnection(){
-        this.connection.destroy();
-    }
-}
+  public destroyConnection() {
+    this.connection.destroy();
+  }
+}