D1 Buffer mapping fix, tests fix

Author: Sukairo-02

changelogs/drizzle-orm/0.41.0.md

@@ -7,4 +7,5 @@
 - Fixed `isConfig` utility function checking types of wrong fields  
 - Enabled `supportBigNumbers` in auto-created `mysql2` driver instances  
 - Fixed custom schema tables querying in RQBv1: [#4060](https://github.com/drizzle-team/drizzle-orm/issues/4060)  
-- Removed in-driver mapping for postgres types `1231` (`numeric[]`), `1115` (`timestamp[]`), `1185` (`timestamp_with_timezone[]`), `1187` (`interval[]`), `1182` (`date[]`), preventing precision loss and data\\type mismatches  
+- Removed in-driver mapping for postgres types `1231` (`numeric[]`), `1115` (`timestamp[]`), `1185` (`timestamp_with_timezone[]`), `1187` (`interval[]`), `1182` (`date[]`), preventing precision loss and data\\type mismatches  
+- Fixed `SQLite` `buffer`-mode `blob` sometimes returning `number[]`

drizzle-orm/src/sqlite-core/columns/blob.ts

@@ -145,6 +145,14 @@ export class SQLiteBlobBufferBuilder<T extends ColumnBuilderBaseConfig<'buffer',
 export class SQLiteBlobBuffer<T extends ColumnBaseConfig<'buffer', 'SQLiteBlobBuffer'>> extends SQLiteColumn<T> {
 	static override readonly [entityKind]: string = 'SQLiteBlobBuffer';
 
+	override mapFromDriverValue(value: Buffer | Uint8Array | ArrayBuffer): T['data'] {
+		if (Buffer.isBuffer(value)) {
+			return value;
+		}
+
+		return Buffer.from(value as Uint8Array);
+	}
+
 	getSQLType(): string {
 		return 'blob';
 	}

integration-tests/tests/mysql/mysql-custom.test.ts

@@ -811,7 +811,7 @@ test('custom binary', async (ctx) => {
 
 	expect(res).toEqual([{
 		id,
-		sqlId: Buffer.from(id, 'hex'),
+		sqlId: Buffer.from(id, 'hex').toString(),
 		rawId: id,
 	}]);
 });

integration-tests/tests/pg/pg-proxy.test.ts

@@ -18,6 +18,11 @@ class ServerSimulator {
 		types.setTypeParser(types.builtins.TIMESTAMP, (val) => val);
 		types.setTypeParser(types.builtins.DATE, (val) => val);
 		types.setTypeParser(types.builtins.INTERVAL, (val) => val);
+		types.setTypeParser(1231, (val) => val);
+		types.setTypeParser(1115, (val) => val);
+		types.setTypeParser(1185, (val) => val);
+		types.setTypeParser(1187, (val) => val);
+		types.setTypeParser(1182, (val) => val);
 	}
 
 	async query(sql: string, params: any[], method: 'all' | 'execute') {

integration-tests/tests/relational/mysql.schema.ts

@@ -24,17 +24,17 @@ export const usersTable = mysqlTable('users', {
 const schemaV1 = mysqlSchema('schemaV1');
 
 export const usersV1 = schemaV1.table('usersV1', {
-	id: serial().primaryKey(),
-	name: text().notNull(),
-	verified: boolean().notNull().default(false),
-	invitedBy: bigint({ mode: 'number' }),
+	id: serial('id').primaryKey(),
+	name: text('name').notNull(),
+	verified: boolean('verified').notNull().default(false),
+	invitedBy: bigint('invited_by', { mode: 'number' }),
 });
 
 export const usersTableV1 = schemaV1.table('users_table_V1', {
-	id: serial().primaryKey(),
-	name: text().notNull(),
-	verified: boolean().notNull().default(false),
-	invitedBy: bigint({ mode: 'number' }),
+	id: serial('id').primaryKey(),
+	name: text('name').notNull(),
+	verified: boolean('verified').notNull().default(false),
+	invitedBy: bigint('invited_by', { mode: 'number' }),
 });
 
 export const usersConfig = relations(usersTable, ({ one, many }) => ({

integration-tests/tests/relational/pg.schema.ts

@@ -22,17 +22,17 @@ export const usersTable = pgTable('users', {
 export const schemaV1 = pgSchema('schemaV1');
 
 export const usersV1 = schemaV1.table('usersV1', {
-	id: serial().primaryKey(),
-	name: text().notNull(),
-	verified: boolean().notNull().default(false),
-	invitedBy: integer(),
+	id: serial('id').primaryKey(),
+	name: text('name').notNull(),
+	verified: boolean('verified').notNull().default(false),
+	invitedBy: integer('invited_by'),
 });
 
 export const usersTableV1 = schemaV1.table('users_table_V1', {
-	id: serial().primaryKey(),
-	name: text().notNull(),
-	verified: boolean().notNull().default(false),
-	invitedBy: integer(),
+	id: serial('id').primaryKey(),
+	name: text('name').notNull(),
+	verified: boolean('verified').notNull().default(false),
+	invitedBy: integer('invited_by'),
 });
 
 export const usersConfig = relations(usersTable, ({ one, many }) => ({