Moduletrace/datasquirel
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updates

Browse Source
This commit is contained in:
Benjamin Toby
2025-06-01 12:32:16 +01:00
parent cd96c11817
commit 8639c9f34d
11 changed files with 257 additions and 136 deletions
Download Patch File Download Diff File Expand all files Collapse all files
package-shared/utils/data-fetching/crud-batch-get.ts
+43
View File
@@ -0,0 +1,43 @@
// import sqlGenerator from "../../functions/dsql/sql/sql-generator";
// import { DsqlCrudParam } from "../../types";
// import connDbHandler, { ConnDBHandlerQueryObject } from "../db/conn-db-handler";
// import { DsqlCrudReturn } from "./crud";
// export default async function dsqlCrudBatchGet({
// batchQuery,
// }: DsqlCrudParam<any>): Promise<DsqlCrudReturn> {
// try {
// const queryObjects = batchQuery?.map((q) =>
// sqlGenerator({
// tableName: q.tableName,
// genObject: q,
// })
// );
// const DB_CONN = global.DSQL_READ_ONLY_DB_CONN || global.DSQL_DB_CONN;
// let connQueries: ConnDBHandlerQueryObject[] | undefined =
// queryObjects?.map((q) => ({
// query: q.string,
// values: q.values,
// }));
// if (!connQueries) return null;
// const res = (await connDbHandler(DB_CONN, connQueries)) as any[][];
// const isSuccess = Array.isArray(res) && Array.isArray(res[0]);
// if (!isSuccess) return null;
// return {
// success: isSuccess,
// batchPayload: isSuccess ? res : null,
// };
// } catch (error: any) {
// return {
// success: false,
// error: error.message,
// };
// }
// }
package-shared/utils/data-fetching/crud-get.ts
+68
View File
@@ -0,0 +1,68 @@
import sqlGenerator from "../../functions/dsql/sql/sql-generator";
import { DsqlCrudParam } from "../../types";
import connDbHandler, { ConnDBHandlerQueryObject } from "../db/conn-db-handler";
import { DsqlCrudReturn } from "./crud";
export default async function dsqlCrudGet({
table,
query,
count,
countOnly,
}: DsqlCrudParam<any>): Promise<DsqlCrudReturn> {
let queryObject: ReturnType<Awaited<typeof sqlGenerator>> | undefined;
queryObject = sqlGenerator({
tableName: table,
genObject: query,
});
const DB_CONN = global.DSQL_READ_ONLY_DB_CONN || global.DSQL_DB_CONN;
let connQueries: ConnDBHandlerQueryObject[] = [
{
query: queryObject?.string,
values: queryObject?.values || [],
},
];
const countQueryObject =
count || countOnly
? sqlGenerator({
tableName: table,
genObject: query,
count: true,
})
: undefined;
if (count && countQueryObject) {
connQueries.push({
query: countQueryObject.string,
values: countQueryObject.values,
});
} else if (countOnly && countQueryObject) {
connQueries = [
{
query: countQueryObject.string,
values: countQueryObject.values,
},
];
}
const res = await connDbHandler(DB_CONN, connQueries);
const isSuccess = Array.isArray(res) && Array.isArray(res[0]);
return {
success: isSuccess,
payload: isSuccess ? (countOnly ? null : res[0]) : null,
error: isSuccess ? undefined : res?.error,
queryObject,
count: isSuccess
? res[1]?.[0]?.["COUNT(*)"]
? res[1][0]["COUNT(*)"]
: res[0]?.[0]?.["COUNT(*)"]
? res[0][0]["COUNT(*)"]
: undefined
: undefined,
};
}
package-shared/utils/data-fetching/crud.ts
+21 -74
View File
@@ -1,90 +1,37 @@
import get from "../../actions/get";
import post from "../../actions/post";
import sqlGenerator from "../../functions/dsql/sql/sql-generator";
import { DsqlCrudParam, PostReturn } from "../../types";
import connDbHandler, { ConnDBHandlerQueryObject } from "../db/conn-db-handler";
// import dsqlCrudBatchGet from "./crud-batch-get";
import dsqlCrudGet from "./crud-get";
export default async function dsqlCrud<
T extends { [key: string]: any } = { [key: string]: any }
>({
action,
data,
table,
targetValue,
query,
sanitize,
debug,
targetField,
targetId,
count,
countOnly,
}: DsqlCrudParam<T>): Promise<
export type DsqlCrudReturn =
| (PostReturn & {
queryObject?: ReturnType<Awaited<typeof sqlGenerator>>;
count?: number;
batchPayload?: any[][] | null;
})
| null
> {
| null;
export default async function dsqlCrud<
T extends { [key: string]: any } = { [key: string]: any }
>(params: DsqlCrudParam<T>): Promise<DsqlCrudReturn> {
const {
action,
data,
table,
targetValue,
sanitize,
targetField,
targetId,
} = params;
const finalData = sanitize ? sanitize(data) : data;
let queryObject: ReturnType<Awaited<typeof sqlGenerator>> | undefined;
switch (action) {
case "get":
queryObject = sqlGenerator({
tableName: table,
genObject: query,
});
return await dsqlCrudGet(params);
const DB_CONN =
global.DSQL_READ_ONLY_DB_CONN || global.DSQL_DB_CONN;
let connQueries: ConnDBHandlerQueryObject[] = [
{
query: queryObject?.string,
values: queryObject?.values || [],
},
];
const countQueryObject =
count || countOnly
? sqlGenerator({
tableName: table,
genObject: query,
count: true,
})
: undefined;
if (count && countQueryObject) {
connQueries.push({
query: countQueryObject.string,
values: countQueryObject.values,
});
} else if (countOnly && countQueryObject) {
connQueries = [
{
query: countQueryObject.string,
values: countQueryObject.values,
},
];
}
const res = await connDbHandler(DB_CONN, connQueries);
const isSuccess = Array.isArray(res) && Array.isArray(res[0]);
return {
success: isSuccess,
payload: isSuccess ? (countOnly ? null : res[0]) : null,
error: isSuccess ? undefined : res?.error,
queryObject,
count: isSuccess
? res[1]?.[0]?.["COUNT(*)"]
? res[1][0]["COUNT(*)"]
: res[0]?.[0]?.["COUNT(*)"]
? res[0][0]["COUNT(*)"]
: undefined
: undefined,
};
// case "batch-get":
// return await dsqlCrudBatchGet(params);
case "insert":
return await post({