Skip to content

Instantly share code, notes, and snippets.

@the-simian
Created January 1, 2025 00:35
Show Gist options
  • Save the-simian/6c1b4fe47954977d39627c5b2f7e9f2f to your computer and use it in GitHub Desktop.
Save the-simian/6c1b4fe47954977d39627c5b2f7e9f2f to your computer and use it in GitHub Desktop.
diff --git a/node_modules/drizzle-kit/bin.cjs b/node_modules/drizzle-kit/bin.cjs
index 9a93653..d4c61ad 100755
--- a/node_modules/drizzle-kit/bin.cjs
+++ b/node_modules/drizzle-kit/bin.cjs
@@ -119591,6 +119591,9 @@ var init_connections = __esm({
return result;
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
const prepared = session.prepareQuery(
{
sql: params.sql,
@@ -119632,6 +119635,9 @@ var init_connections = __esm({
return result.rows;
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
const result = await client.query({
text: params.sql,
values: params.params,
@@ -119658,6 +119664,9 @@ var init_connections = __esm({
return result;
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
if (params.mode === "object") {
return await client.unsafe(params.sql, params.params);
}
@@ -119689,6 +119698,9 @@ var init_connections = __esm({
return result.rows;
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
const result = await client.query({
text: params.sql,
values: params.params,
@@ -119724,6 +119736,9 @@ var init_connections = __esm({
return result.rows;
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
const result = await client.query({
text: params.sql,
values: params.params,
@@ -119775,6 +119790,9 @@ var init_connections = __esm({
return res[0];
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
const result2 = await connection2.query({
sql: params.sql,
values: params.params,
@@ -119803,6 +119821,9 @@ var init_connections = __esm({
return res.rows;
};
const proxy = async (params) => {
+ params.sql = params.sql.replace(/a.attidentity AS identity_type/i, 'a.attidentity::text AS identity_type');
+ params.sql = params.sql.replace(/a.attgenerated AS generated_type/i, 'a.attgenerated::text AS generated_type');
+ params.sql = params.sql.replace(/con\.contype AS constraint_type/i, 'con.contype::text AS constraint_type');
const result2 = params.mode === "object" ? await connection2.execute(params.sql, params.params) : await connection2.execute(params.sql, params.params, {
as: "array"
});
diff --git a/node_modules/drizzle-orm/aws-data-api/pg/driver.js b/node_modules/drizzle-orm/aws-data-api/pg/driver.js
index 7d47bf5..920ee81 100644
--- a/node_modules/drizzle-orm/aws-data-api/pg/driver.js
+++ b/node_modules/drizzle-orm/aws-data-api/pg/driver.js
@@ -45,6 +45,7 @@ class AwsPgDialect extends PgDialect {
}
}
function drizzle(client, config) {
+
const dialect = new AwsPgDialect();
let logger;
if (config.logger === true) {
diff --git a/node_modules/drizzle-orm/aws-data-api/pg/session.cjs b/node_modules/drizzle-orm/aws-data-api/pg/session.cjs
index 5ffcd99..b4b2212 100644
--- a/node_modules/drizzle-orm/aws-data-api/pg/session.cjs
+++ b/node_modules/drizzle-orm/aws-data-api/pg/session.cjs
@@ -91,6 +91,7 @@ class AwsDataApiPreparedQuery extends import_pg_core.PgPreparedQuery {
}
async values(placeholderValues = {}) {
const params = (0, import_sql.fillPlaceholders)(this.params, placeholderValues ?? {});
+ this.rawQuery.input.sql = this.rawQuery.input.sql.replace('$1', ':1');
this.rawQuery.input.parameters = params.map((param, index) => ({
name: `${index + 1}`,
...(0, import_common.toValueParam)(param, this.typings[index])
diff --git a/node_modules/drizzle-orm/aws-data-api/pg/session.js b/node_modules/drizzle-orm/aws-data-api/pg/session.js
index 59e63a9..81331b8 100644
--- a/node_modules/drizzle-orm/aws-data-api/pg/session.js
+++ b/node_modules/drizzle-orm/aws-data-api/pg/session.js
@@ -75,6 +75,7 @@ class AwsDataApiPreparedQuery extends PgPreparedQuery {
}
async values(placeholderValues = {}) {
const params = fillPlaceholders(this.params, placeholderValues ?? {});
+ this.rawQuery.input.sql = this.rawQuery.input.sql.replace('$1', ':1');
this.rawQuery.input.parameters = params.map((param, index) => ({
name: `${index + 1}`,
...toValueParam(param, this.typings[index])
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment