cleanup and fixes

Author: halvardssm

deno.json

@@ -15,8 +15,7 @@
     "db:stop": "docker compose down --remove-orphans --volumes"
   },
   "imports": {
-    "@halvardm/sqlx": "../deno-sqlx/mod.ts",
-    "@halvardm/sqlx/testing": "../deno-sqlx/lib/testing.ts",
+    "@halvardm/sqlx": "jsr:@halvardm/[email protected]",
     "@std/assert": "jsr:@std/assert@^0.221.0",
     "@std/async": "jsr:@std/async@^0.221.0",
     "@std/crypto": "jsr:@std/crypto@^0.221.0",

lib/client.ts

@@ -53,7 +53,7 @@ export class MysqlQueriable extends SqlxBase implements
   readonly queryOptions: MysqlQueryOptions;
 
   get connected(): boolean {
-    throw new Error("Method not implemented.");
+    return this.connection.connected;
   }
 
   constructor(
@@ -181,9 +181,9 @@ export class MysqlPrepared extends SqlxBase implements
   ) {
     super();
     this.connection = connection;
-    this.#queriable = new MysqlQueriable(connection);
     this.sql = sql;
     this.queryOptions = options;
+    this.#queriable = new MysqlQueriable(connection, this.queryOptions);
   }
 
   execute(

lib/utils/errors.ts

@@ -1,4 +1,4 @@
-import { SqlxError } from "@halvardm/sqlx";
+import { isSqlxError, SqlxError } from "@halvardm/sqlx";
 
 export class MysqlError extends SqlxError {
   constructor(msg: string) {
@@ -46,5 +46,5 @@ export class MysqlTransactionError extends MysqlError {
  * Check if an error is a MysqlError
  */
 export function isMysqlError(err: unknown): err is MysqlError {
-  return err instanceof MysqlError;
+  return isSqlxError(err) && err instanceof MysqlError;
 }

lib/utils/logger.ts

@@ -1,4 +1,4 @@
-import { getLogger } from "@std/log";
+import { getLogger, type Logger } from "@std/log";
 import { MODULE_NAME } from "./meta.ts";
 
 /**
@@ -7,6 +7,6 @@ import { MODULE_NAME } from "./meta.ts";
  *
  * @see {@link https://deno.land/std/log/mod.ts}
  */
-export function logger() {
+export function logger(): Logger {
   return getLogger(MODULE_NAME);
 }

lib/utils/query.ts

@@ -58,7 +58,7 @@ export function replaceParams(
             })`;
           }
         case "string":
-          return `"${escapeString(val)}"`;
+          return `"${escapeString(val as string)}"`;
         case "undefined":
           return "NULL";
         case "number":