import { RxSQL } from "rx-sql";
import { createConnection } from "mysql";
import { flatMap } from "rxjs/operators";
 
let db = createConnection({
  host: "localhost",
  database: "database",
  user: "root",
  password: "password"
});
 
let rxsql$ = new RxSQL(db);
 
rxsql$
  .query("SELECT * FROM table")
  .pipe(flatMap(result => result))
  .subscribe(
      result => console.log(result),
      error => console.error(error)
      () => console.info("Completed!")
      );