SELECT *

FROM messages

WHERE id = ? LIMIT 1;

SELECT *

FROM messages

WHERE session_id = ?

ORDER BY created_at ASC;

INSERT INTO messages (

id,

session_id,

role,

parts,

model,

created_at,

updated_at

) VALUES (

?, ?, ?, ?, ?, strftime('%s', 'now'), strftime('%s', 'now')

)

RETURNING *;

UPDATE messages

parts = ?,

finished_at = ?,

updated_at = strftime('%s', 'now')

WHERE id = ?;

DELETE FROM messages

WHERE id = ?;

DELETE FROM messages

WHERE session_id = ?;