mirror of
https://github.com/hpware/news-analyze.git
synced 2025-06-23 13:04:23 +00:00
feat: implement go_links table and update database connection handling
This commit is contained in:
parent
4aab557523
commit
1208866757
4 changed files with 44 additions and 14 deletions
7
server/components/postgres.ts
Normal file
7
server/components/postgres.ts
Normal file
|
@ -0,0 +1,7 @@
|
|||
import { SQL } from "bun";
|
||||
|
||||
const postgres = new SQL({
|
||||
url: process.env.POSTGRES_URL,
|
||||
})
|
||||
|
||||
export default postgres;
|
|
@ -0,0 +1,24 @@
|
|||
import sql from "~/server/components/postgres";
|
||||
export default defineEventHandler(async (event) => {
|
||||
const slug = getRouterParam(event, 'slug');
|
||||
if (!slug || typeof slug !== 'string') {
|
||||
throw createError({
|
||||
statusCode: 400,
|
||||
message: 'Invalid slug parameter'
|
||||
});
|
||||
}
|
||||
const cleanSlug = slug.replace(/[^a-zA-Z0-9-_]/g, '');
|
||||
try {
|
||||
const result = await sql`
|
||||
select * from go_links
|
||||
where slug = ${cleanSlug}
|
||||
`
|
||||
return result.rows[0] || null;
|
||||
} catch (error) {
|
||||
console.error('Database error:', error);
|
||||
throw createError({
|
||||
statusCode: 500,
|
||||
message: 'Internal server error'
|
||||
});
|
||||
}
|
||||
})
|
Loading…
Add table
Add a link
Reference in a new issue