#endpoint #node-postgres #bytea #sveltekit
Вопрос:
Хранение ~100 файлов JPEG (24K-100K каждый) в таблице в PostgreSQL в виде столбца bytea. Атрибуты <img/>
src тега ссылаются на конечную точку SvelteKit:
<img src="/api/file/18.json" alt="Person"/>
Получение этой ошибки:
Недопустимый ответ из route /api/file/76.json: тело Uint8Array должно сопровождаться заголовком типа содержимого: приложение/октетный поток
export async function get({ params }) {
const { id } = params
const sql = `SELECT _id, name, type, data FROM files WHERE _id = $1;`
const { rows } = await db.query(sql, [id])
const file = rows[0]
return {
headers: {
'Content-disposition': `attachment; filename=${file.name}`,
'Content-type': file.type
},
body: file.data
}
}
Поскольку конечные точки SvelteKit не взаимодействуют с объектами req/res, поскольку они доступны только на определенных платформах, я не могу просто записать значение bytea в виде потока для объекта ответа, но я не уверен, что это правильный подход.
Также попробовал эту инструкцию SQL…
SELECT _id, name, type, encode(data, 'base64') as data FROM files WHERE _id = $1;
Но это не помогло.
Есть какие-нибудь мысли?
ОБНОВЛЕНИЕ: Проблема может быть связана с ошибкой SvelteKit — см. https://github.com/sveltejs/kit/issues/1438.
Ответ №1:
Ограничение в Свелтеките было устранено 11 июня. Мне также нужно было положить файл.данные в новом Uint8Array…
// routes/api/file/[filenum].ts
import type { RequestHandler } from '@sveltejs/kit'
import { query } from '../_db'
export const get: RequestHandler = async ({ params }) => {
const { filenum } = params
const { rows } = await query(`SELECT * FROM find_file($1);`, [filenum])
if (rows) {
const file = rows[0]
return {
headers: {
'Content-Disposition': `attachment; filename="${file.name}"`,
'Content-Type': file.type
},
body: new Uint8Array(file.data)
}
} else return {
status: 404
}
}
Вот исходный код функции find_file() в PostgreSQL:
CREATE OR REPLACE FUNCTION public.find_file(
integer,
OUT _id integer,
OUT name character varying,
OUT type character varying,
OUT data bytea)
RETURNS record
LANGUAGE 'sql'
COST 100
VOLATILE PARALLEL UNSAFE
AS $BODY$
SELECT _id, name, type, data FROM files WHERE _id = $1 LIMIT 1
$BODY$;
и функция query ()…
import pg from 'pg'
const pgNativePool = new pg.native.Pool({
max: 10, // default
connectionString: <string> import.meta.env.VITE_DATABASE_URL,
ssl: {
rejectUnauthorized: false
}
})
type QueryResponse = (sql: string, params?: Array<any>) => Promise<pg.QueryResult<any>>
export const query: QueryResponse = (sql: string, params?: Array<any>) => pgNativePool.query(sql, params)