chore: bump version to 1.0.8 in package.json and enhance pagination functionality in Repository class

Author: kingRayhan

__tests__/repository/paginate.test.ts

@@ -1,13 +1,5 @@
-import {
-  cleanupTestTables,
-  DomainPost,
-  DomainUser,
-  executor,
-  seedTestData,
-  setupTestTables,
-} from "../../test-setup";
-import { Repository } from "../../src";
-import { asc, desc } from "../../src";
+import {cleanupTestTables, DomainPost, DomainUser, executor, seedTestData, setupTestTables,} from "../../test-setup";
+import {asc, desc, Repository} from "../../src";
 
 describe("Repository Pagination", () => {
   let postRepository: Repository<DomainPost>;
@@ -79,4 +71,27 @@ describe("Repository Pagination", () => {
       );
     }
   });
+
+  it('Should return all result when limit is -1', async () => {
+    const countQuery = await executor.executeSQL<{ count: 0 }>(`
+      SELECT COUNT(*) as count
+      FROM "posts"
+    `, []);
+
+    const page = await postRepository.paginate({
+      page: 1,
+      limit: -1,
+    });
+
+    expect(page.meta.totalCount).toBe(+countQuery.rows[0].count);
+    expect(page.nodes.length).toBe(+countQuery.rows[0].count);
+  })
+
+  it('Should return 10 result when limit is not provided', async () => {
+    const page = await postRepository.paginate({
+      page: 1,
+    });
+
+    expect(page.nodes.length).toBe(10);
+  })
 });

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sqlkit",
-  "version": "1.0.6",
+  "version": "1.0.8",
   "description": "A lightweight SQL builder for TypeScript",
   "license": "MIT",
   "author": {

src/dialects/postgres.ts

@@ -4,7 +4,7 @@ import { SQLKITException } from "../exceptions";
 export class PostgresAdapter implements SqlExecutor {
   constructor(private pgPool: any) {}
 
-  async executeSQL<T>(sql: string, values: any[]): Promise<QueryResult> {
+  async executeSQL<T>(sql: string, values: any[]): Promise<QueryResult<T>> {
     return new Promise((resolve, reject) => {
       this.pgPool.query(sql, values, (err, result) => {
         if (err) {

src/query-builder/select.ts

@@ -92,17 +92,17 @@ export class SelectQueryBuilder<T> extends BaseQueryBuilder<T> {
       ${joinConditionClause ? joinConditionClause : ""}
       ${whereClause ? `WHERE ${whereClause}` : ""}
       ${orderByClause ? orderByClause : ""}
-      ${limit ? `LIMIT ${limit}` : ""} ${offset ? `OFFSET ${offset}` : ""};
+      ${limit != -1 ? `LIMIT ${limit}` : ""} ${offset ? `OFFSET ${offset}` : ""};
     `;
 
     return { sql, values };
   }
 
   async paginate(options: PaginationOptions<T>): Promise<PaginatedResult<T>> {
-    if(!this?.executor){
+    if (!this?.executor) {
       throw new SQLKITException("Executor is not set for the query builder.");
     }
-    
+
     const limit = options.limit || 10;
     const page = options.page || 1;
     const offset = (page - 1) * limit;

src/repository/repository.ts

@@ -13,15 +13,27 @@ import {
 } from "../types";
 import { buildWhereClause } from "../utils";
 
+interface RepositoryOptions {
+  logging?: boolean;
+}
+
 export class Repository<T> {
   constructor(
     protected readonly tableName: string,
-    protected readonly executor: SqlExecutor
+    protected readonly executor: SqlExecutor,
+    protected options?: RepositoryOptions
   ) {}
 
   async findRow(where: WhereCondition<T>): Promise<T | null> {
     const builder = new SelectQueryBuilder<T>(this.tableName, this.executor);
     const result = await builder.where(where).limit(1).commit();
+    if (this.options?.logging) {
+      console.log({
+        sql: builder.build().sql,
+        values: builder.build().values,
+        result: result.rows[0]
+      });
+    }
     return result.rows[0] ?? null;
   }
 
@@ -34,9 +46,15 @@ export class Repository<T> {
     if (payload?.orderBy) builder.orderBy(payload.orderBy);
     if (payload?.limit) builder.limit(payload.limit);
     if (payload?.offset) builder.offset(payload.offset);
-    // console.log(builder.build().sql);
-    // console.log(builder.build().values);
     const result = await builder.commit();
+
+    if (this.options?.logging) {
+      console.log({
+        sql: builder.build().sql,
+        values: builder.build().values,
+        result: result.rows[0]
+      });
+    }
     return result.rows;
   }
 
@@ -76,6 +94,13 @@ export class Repository<T> {
   ): Promise<T> {
     const builder = new InsertQueryBuilder<T>(this.tableName, this.executor);
     const result = await builder.values(data).returning(returning).commit();
+    if (this.options?.logging) {
+      console.log({
+        sql: builder.build().sql,
+        values: builder.build().values,
+        result: result.rows[0]
+      });
+    }
     return result.rows[0];
   }
 
@@ -85,6 +110,13 @@ export class Repository<T> {
   ): Promise<T[]> {
     const builder = new InsertQueryBuilder<T>(this.tableName, this.executor);
     const result = await builder.values(data).returning(returning).commit();
+    if (this.options?.logging) {
+      console.log({
+        sql: builder.build().sql,
+        values: builder.build().values,
+        result: result.rows[0]
+      });
+    }
     return result.rows;
   }
 
@@ -101,17 +133,32 @@ export class Repository<T> {
       .where(where)
       .returning(returning)
       .commit();
+    if (this.options?.logging) {
+      console.log({
+        sql: builder.build().sql,
+        values: builder.build().values,
+        result: result.rows[0]
+      });
+    }
     return result.rows[0] ?? null;
   }
 
-  async delete(
-    arg: {
-      where: WhereCondition<T>;
-      returning?: Array<keyof T>;
-    }
-  ): Promise<T | null> {
+  async delete(arg: {
+    where: WhereCondition<T>;
+    returning?: Array<keyof T>;
+  }): Promise<T | null> {
     const builder = new DeleteQueryBuilder<T>(this.tableName, this.executor);
-    const result = await builder.where(arg.where).returning(arg.returning).commit();
+    const result = await builder
+      .where(arg.where)
+      .returning(arg.returning)
+      .commit();
+    if (this.options?.logging) {
+      console.log({
+        sql: builder.build().sql,
+        values: builder.build().values,
+        result: result.rows[0]
+      });
+    }
     return result.rows[0] ?? null;
   }
 }