blob: 7ce2c52816fc7bc4d3fdddbcfef43014a540be01 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
use sqlx::{self, ConnectOptions, Connection, Executor};
use crate::github::Repo;
pub struct Db {
connection: sqlx::SqliteConnection,
}
impl Db {
pub async fn connect(
path: &str,
) -> Result<Self, Box<dyn std::error::Error>> {
Ok(
Db {
connection: sqlx::sqlite::SqliteConnectOptions::new()
.filename(path)
.create_if_missing(true)
.connect()
.await?,
}
)
}
pub async fn create(&mut self) -> Result<(), Box<dyn std::error::Error>> {
let mut tx = self.connection.begin().await?;
tx.execute(r#"
CREATE TABLE repositories (
id INTEGER PRIMARY KEY,
name TEXT NOT NULL,
updated_at TEXT NOT NULL
);
"#).await?;
tx.execute(r#"
CREATE UNIQUE INDEX idx_repositories_id
ON repositories (id);
"#).await?;
tx.commit().await?;
Ok(())
}
pub fn repo_insert(repo: &Repo) -> Result<(), Box<dyn std::error::Error>> {
Ok(())
}
pub fn repo_is_updated() -> Result<bool, Box<dyn std::error::Error>> {
Ok(false)
}
pub fn repo_update(repo: &Repo) -> Result<(), Box<dyn std::error::Error>> {
Ok(())
}
}
|
