Added JSON fields parsing to AWS Data Api RQBv2

Author: Sukairo-02

drizzle-orm/src/aws-data-api/pg/driver.ts

@@ -126,7 +126,7 @@ function construct<
 		logger,
 		cache: config.cache,
 	}, undefined);
-	const db = new AwsDataApiPgDatabase(dialect, session, relations, schema as V1.RelationalSchemaConfig<any>);
+	const db = new AwsDataApiPgDatabase(dialect, session, relations, schema as V1.RelationalSchemaConfig<any>, true);
 	(<any> db).$client = client;
 	(<any> db).$cache = config.cache;
 	if ((<any> db).$cache) {

drizzle-orm/src/pg-core/db.ts

@@ -73,6 +73,7 @@ export class PgDatabase<
 		readonly session: PgSession<any, any, any, any>,
 		relations: TRelations,
 		schema: V1.RelationalSchemaConfig<TSchema> | undefined,
+		parseRqbJson: boolean = false,
 	) {
 		this._ = schema
 			? {
@@ -117,6 +118,7 @@ export class PgDatabase<
 				relation,
 				dialect,
 				session,
+				parseRqbJson,
 			);
 		}
 

drizzle-orm/src/pg-core/query-builders/query.ts

@@ -28,6 +28,7 @@ export class RelationalQueryBuilder<
 		private tableConfig: TableRelationalConfig,
 		private dialect: PgDialect,
 		private session: PgSession,
+		private parseJson: boolean,
 	) {}
 
 	findMany<TConfig extends DBQueryConfig<'many', TSchema, TFields>>(
@@ -41,6 +42,7 @@ export class RelationalQueryBuilder<
 			this.session,
 			config as DBQueryConfig<'many'> | undefined ?? true,
 			'many',
+			this.parseJson,
 		);
 	}
 
@@ -55,6 +57,7 @@ export class RelationalQueryBuilder<
 			this.session,
 			config as DBQueryConfig<'one'> | undefined ?? true,
 			'first',
+			this.parseJson,
 		);
 	}
 }
@@ -77,6 +80,7 @@ export class PgRelationalQuery<TResult> extends QueryPromise<TResult>
 		private session: PgSession,
 		private config: DBQueryConfig<'many' | 'one'> | true,
 		private mode: 'many' | 'first',
+		private parseJson: boolean,
 	) {
 		super();
 	}
@@ -91,7 +95,7 @@ export class PgRelationalQuery<TResult> extends QueryPromise<TResult>
 				undefined,
 				name,
 				(rawRows, mapColumnValue) => {
-					const rows = rawRows.map((row) => mapRelationalRow(row, query.selection, mapColumnValue));
+					const rows = rawRows.map((row) => mapRelationalRow(row, query.selection, mapColumnValue, this.parseJson));
 					if (this.mode === 'first') {
 						return rows[0] as TResult;
 					}