This commit is contained in:
Benjamin Toby 2025-11-17 11:12:19 +01:00
parent 5fcfc4dc2c
commit 8eebe3215a
8 changed files with 31 additions and 19 deletions

View File

@ -5,10 +5,7 @@ export default function dbGrabUserResource<T extends {
batch: T[] | null; batch: T[] | null;
single: T | null; single: T | null;
debug: { debug: {
queryObject: { queryObject: import("../../../../types").ResponseQueryObject | undefined;
sql?: string;
params?: string[];
} | undefined;
error: any; error: any;
msg: string | undefined; msg: string | undefined;
}; };

View File

@ -109,8 +109,9 @@ function grabPrimaryRequiredDbSchema({ userId, dbId, dbSlug }) {
// return existingSchemaInMainJSON; // return existingSchemaInMainJSON;
// } // }
// } // }
console.log(`userSchemaDir not found!`); console.log(`Coudln't grab Required DB Schema!`);
console.log(`userId`, userId); console.log(`userId`, userId);
console.log(`dbId`, dbId);
return undefined; return undefined;
} }
function findDbNameInSchemaDir({ userId, dbName, }) { function findDbNameInSchemaDir({ userId, dbName, }) {

View File

@ -1402,6 +1402,10 @@ export type PagePropsType = {
docsPages?: DocsLinkType[] | null; docsPages?: DocsLinkType[] | null;
docsPageEditURL?: string | null; docsPageEditURL?: string | null;
}; };
export type ResponseQueryObject = {
sql?: string;
params?: string[];
};
export type APIResponseObject<T extends any = any> = { export type APIResponseObject<T extends any = any> = {
success: boolean; success: boolean;
payload?: T; payload?: T;
@ -1411,10 +1415,8 @@ export type APIResponseObject<T extends any = any> = {
payloadThumbnailURL?: string; payloadThumbnailURL?: string;
error?: any; error?: any;
msg?: string; msg?: string;
queryObject?: { queryObject?: ResponseQueryObject;
sql?: string; countQueryObject?: ResponseQueryObject;
params?: string[];
};
status?: number; status?: number;
count?: number; count?: number;
errors?: DSQLErrorObject[]; errors?: DSQLErrorObject[];

View File

@ -40,7 +40,7 @@ function default_1(_a) {
dbFullName, dbFullName,
}) })
: undefined; : undefined;
if (count && countQueryObject) { if ((count || countOnly) && countQueryObject) {
connQueries.push({ connQueries.push({
query: countQueryObject.string, query: countQueryObject.string,
values: countQueryObject.values, values: countQueryObject.values,
@ -81,12 +81,16 @@ function default_1(_a) {
sql: queryObject === null || queryObject === void 0 ? void 0 : queryObject.string, sql: queryObject === null || queryObject === void 0 ? void 0 : queryObject.string,
params: queryObject === null || queryObject === void 0 ? void 0 : queryObject.values, params: queryObject === null || queryObject === void 0 ? void 0 : queryObject.values,
}, },
countQueryObject: {
sql: countQueryObject === null || countQueryObject === void 0 ? void 0 : countQueryObject.string,
params: countQueryObject === null || countQueryObject === void 0 ? void 0 : countQueryObject.values,
},
count: isSuccess count: isSuccess
? ((_c = (_b = res[1]) === null || _b === void 0 ? void 0 : _b[0]) === null || _c === void 0 ? void 0 : _c["COUNT(*)"]) ? ((_c = (_b = res[1]) === null || _b === void 0 ? void 0 : _b[0]) === null || _c === void 0 ? void 0 : _c["COUNT(*)"])
? res[1][0]["COUNT(*)"] ? res[1][0]["COUNT(*)"]
: ((_e = (_d = res[0]) === null || _d === void 0 ? void 0 : _d[0]) === null || _e === void 0 ? void 0 : _e["COUNT(*)"]) : ((_e = (_d = res[0]) === null || _d === void 0 ? void 0 : _d[0]) === null || _e === void 0 ? void 0 : _e["COUNT(*)"])
? res[0][0]["COUNT(*)"] ? res[0][0]["COUNT(*)"]
: undefined : 0
: undefined, : undefined,
}; };
}); });

View File

@ -129,8 +129,9 @@ export function grabPrimaryRequiredDbSchema({ userId, dbId, dbSlug }: Params) {
// } // }
// } // }
console.log(`userSchemaDir not found!`); console.log(`Coudln't grab Required DB Schema!`);
console.log(`userId`, userId); console.log(`userId`, userId);
console.log(`dbId`, dbId);
return undefined; return undefined;
} }

View File

@ -1633,6 +1633,11 @@ export type PagePropsType = {
docsPageEditURL?: string | null; docsPageEditURL?: string | null;
}; };
export type ResponseQueryObject = {
sql?: string;
params?: string[];
};
export type APIResponseObject<T extends any = any> = { export type APIResponseObject<T extends any = any> = {
success: boolean; success: boolean;
payload?: T; payload?: T;
@ -1642,10 +1647,8 @@ export type APIResponseObject<T extends any = any> = {
payloadThumbnailURL?: string; payloadThumbnailURL?: string;
error?: any; error?: any;
msg?: string; msg?: string;
queryObject?: { queryObject?: ResponseQueryObject;
sql?: string; countQueryObject?: ResponseQueryObject;
params?: string[];
};
status?: number; status?: number;
count?: number; count?: number;
errors?: DSQLErrorObject[]; errors?: DSQLErrorObject[];

View File

@ -44,7 +44,7 @@ export default async function <
}) })
: undefined; : undefined;
if (count && countQueryObject) { if ((count || countOnly) && countQueryObject) {
connQueries.push({ connQueries.push({
query: countQueryObject.string, query: countQueryObject.string,
values: countQueryObject.values, values: countQueryObject.values,
@ -88,12 +88,16 @@ export default async function <
sql: queryObject?.string, sql: queryObject?.string,
params: queryObject?.values, params: queryObject?.values,
}, },
countQueryObject: {
sql: countQueryObject?.string,
params: countQueryObject?.values,
},
count: isSuccess count: isSuccess
? res[1]?.[0]?.["COUNT(*)"] ? res[1]?.[0]?.["COUNT(*)"]
? res[1][0]["COUNT(*)"] ? res[1][0]["COUNT(*)"]
: res[0]?.[0]?.["COUNT(*)"] : res[0]?.[0]?.["COUNT(*)"]
? res[0][0]["COUNT(*)"] ? res[0][0]["COUNT(*)"]
: undefined : 0
: undefined, : undefined,
}; };
} }

View File

@ -1,6 +1,6 @@
{ {
"name": "@moduletrace/datasquirel", "name": "@moduletrace/datasquirel",
"version": "5.4.1", "version": "5.4.2",
"description": "Cloud-based SQL data management tool", "description": "Cloud-based SQL data management tool",
"main": "dist/index.js", "main": "dist/index.js",
"bin": { "bin": {