Update: init SQL feedbacks tags tmpfs

This commit is contained in:
2021-12-07 14:15:46 +08:00
parent 47a60ae671
commit 2d7ac69db5

View File

@@ -21,8 +21,7 @@ var initFoldersTableQuery = `CREATE TABLE IF NOT EXISTS folders (
var initFeedbacksTableQuery = `CREATE TABLE IF NOT EXISTS feedbacks ( var initFeedbacksTableQuery = `CREATE TABLE IF NOT EXISTS feedbacks (
id INTEGER PRIMARY KEY, id INTEGER PRIMARY KEY,
time INTEGER NOT NULL, time INTEGER NOT NULL,
feedback TEXT NOT NULL, feedback TEXT NOT NULL
header TEXT NOT NULL
);` );`
var initUsersTableQuery = `CREATE TABLE IF NOT EXISTS users ( var initUsersTableQuery = `CREATE TABLE IF NOT EXISTS users (
@@ -55,9 +54,9 @@ var initFileHasTagTableQuery = `CREATE TABLE IF NOT EXISTS file_has_tag (
);` );`
var initLikesTableQuery = `CREATE TABLE IF NOT EXISTS likes ( var initLikesTableQuery = `CREATE TABLE IF NOT EXISTS likes (
id INTEGER PRIMARY KEY,
user_id INTEGER NOT NULL, user_id INTEGER NOT NULL,
file_id INTEGER NOT NULL, file_id INTEGER NOT NULL,
PRIMARY KEY (user_id, file_id),
FOREIGN KEY (user_id) REFERENCES users(id), FOREIGN KEY (user_id) REFERENCES users(id),
FOREIGN KEY (file_id) REFERENCES files(id) FOREIGN KEY (file_id) REFERENCES files(id)
);` );`
@@ -90,6 +89,17 @@ var initLogsTableQuery = `CREATE TABLE IF NOT EXISTS logs (
FOREIGN KEY (user_id) REFERENCES users(id) FOREIGN KEY (user_id) REFERENCES users(id)
);` );`
var initTmpfsTableQuery = `CREATE TABLE IF NOT EXISTS tmpfs (
id INTEGER PRIMARY KEY,
path TEXT NOT NULL,
size INTEGER NOT NULL,
file_id INTEGER NOT NULL,
ffmpeg_config TEXT NOT NULL,
created_time INTEGER NOT NULL,
accessed_time INTEGER NOT NULL,
FOREIGN KEY (file_id) REFERENCES files(id)
);`
var insertFolderQuery = `INSERT INTO folders (folder, foldername) var insertFolderQuery = `INSERT INTO folders (folder, foldername)
VALUES (?, ?);` VALUES (?, ?);`
@@ -153,6 +163,7 @@ type Stmt struct {
initReviewsTable *sql.Stmt initReviewsTable *sql.Stmt
initPlaybacksTable *sql.Stmt initPlaybacksTable *sql.Stmt
initLogsTable *sql.Stmt initLogsTable *sql.Stmt
initTmpfsTable *sql.Stmt
insertFolder *sql.Stmt insertFolder *sql.Stmt
insertFile *sql.Stmt insertFile *sql.Stmt
findFolder *sql.Stmt findFolder *sql.Stmt
@@ -238,6 +249,12 @@ func NewPreparedStatement(sqlConn *sql.DB) (*Stmt, error) {
return nil, err return nil, err
} }
// init tmpfs table
stmt.initTmpfsTable, err = sqlConn.Prepare(initTmpfsTableQuery)
if err != nil {
return nil, err
}
// run init statement // run init statement
_, err = stmt.initFilesTable.Exec() _, err = stmt.initFilesTable.Exec()
if err != nil { if err != nil {
@@ -283,6 +300,10 @@ func NewPreparedStatement(sqlConn *sql.DB) (*Stmt, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
_, err = stmt.initTmpfsTable.Exec()
if err != nil {
return nil, err
}
// init insert folder statement // init insert folder statement
stmt.insertFolder, err = sqlConn.Prepare(insertFolderQuery) stmt.insertFolder, err = sqlConn.Prepare(insertFolderQuery)