deprecated the query

Author: invisal

src/connections/bigquery.ts

@@ -204,7 +204,7 @@ export class BigQueryConnection extends SqlConnection {
      * @param parameters - An object containing the parameters to be used in the query.
      * @returns Promise<{ data: any, error: Error | null }>
      */
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         try {

src/connections/index.ts

@@ -32,7 +32,10 @@ export abstract class Connection {
 
     // Retrieve metadata about the database, useful for introspection.
     abstract fetchDatabaseSchema(): Promise<Database>;
-    abstract raw(query: string): Promise<QueryResult>;
+    abstract raw(
+        query: string,
+        params?: Record<string, unknown> | unknown[]
+    ): Promise<QueryResult>;
     abstract testConnection(): Promise<{ error?: string }>;
 
     // Connection common operations that will be used by Outerbase

src/connections/motherduck.ts

@@ -51,7 +51,7 @@ export class DuckDBConnection extends PostgreBaseConnection {
      * @param parameters - An object containing the parameters to be used in the query.
      * @returns Promise<{ data: any, error: Error | null }>
      */
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         const connection = this.connection;

src/connections/mysql.ts

@@ -225,7 +225,7 @@ export class MySQLConnection extends SqlConnection {
         return super.mapDataType(dataType);
     }
 
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         try {

src/connections/postgre/postgresql.ts

@@ -27,7 +27,7 @@ export class PostgreSQLConnection extends PostgreBaseConnection {
         await this.client.end();
     }
 
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         try {

src/connections/snowflake/snowflake.ts

@@ -175,7 +175,7 @@ export class SnowflakeConnection extends PostgreBaseConnection {
         );
     }
 
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         try {

src/connections/sql-base.ts

@@ -16,7 +16,7 @@ export abstract class SqlConnection extends Connection {
     abstract dialect: AbstractDialect;
     protected numberedPlaceholder = false;
 
-    abstract query<T = Record<string, unknown>>(
+    abstract internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>>;
 
@@ -26,6 +26,23 @@ export abstract class SqlConnection extends Connection {
         return dataType;
     }
 
+    /**
+     * This is a deprecated function, use raw instead. We keep this for
+     * backward compatibility.
+     *
+     * @deprecated
+     * @param query
+     * @returns
+     */
+    async query<T = Record<string, unknown>>(
+        query: Query
+    ): Promise<QueryResult<T>> {
+        return (await this.raw(
+            query.query,
+            query.parameters
+        )) as QueryResult<T>;
+    }
+
     async raw(
         query: string,
         params?: Record<string, unknown> | unknown[]
@@ -51,7 +68,10 @@ export abstract class SqlConnection extends Connection {
 
         // Named placeholder
         const { query: newQuery, bindings } = namedPlaceholder(query, params!);
-        return await this.query({ query: newQuery, parameters: bindings });
+        return await this.internalQuery({
+            query: newQuery,
+            parameters: bindings,
+        });
     }
 
     async select(

src/connections/sqlite/cloudflare.ts

@@ -107,7 +107,7 @@ export class CloudflareD1Connection extends SqliteBaseConnection {
      * @param parameters - An object containing the parameters to be used in the query.
      * @returns Promise<{ data: any, error: Error | null }>
      */
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         if (!this.apiKey) throw new Error('Cloudflare API key is not set');

src/connections/sqlite/starbase.ts

@@ -90,7 +90,7 @@ export class StarbaseConnection extends SqliteBaseConnection {
      * @param parameters - An object containing the parameters to be used in the query.
      * @returns Promise<{ data: any, error: Error | null }>
      */
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         if (!this.url) throw new Error('Starbase URL is not set');

src/connections/sqlite/turso.ts

@@ -16,7 +16,7 @@ export class TursoConnection extends SqliteBaseConnection {
         this.client = client;
     }
 
-    async query<T = Record<string, unknown>>(
+    async internalQuery<T = Record<string, unknown>>(
         query: Query
     ): Promise<QueryResult<T>> {
         try {