1 |
const { Database: DB } = require('sqlite3'); |
import DiscordClient from './Client'; |
2 |
|
import mongoose from "mongoose"; |
3 |
|
|
4 |
class Database { |
export default class Database { |
5 |
constructor(dbpath) { |
client: DiscordClient; |
|
this.dbpath = dbpath; |
|
|
this.db = new DB(dbpath, (err) => { |
|
|
if (err) { |
|
|
console.log(err); |
|
|
} |
|
|
}); |
|
|
} |
|
|
|
|
|
get(sql, callback1, callback2) { |
|
|
return this.db.get(sql, callback1, callback2); |
|
|
} |
|
|
|
|
|
all(sql, callback1, callback2) { |
|
|
return this.db.all(sql, callback1, callback2); |
|
|
} |
|
|
|
|
|
runAsync(sql, paramsOrCallback = []) { |
|
|
return new Promise((resolve, reject) => { |
|
|
this.db.run(sql, paramsOrCallback, err => { |
|
|
if (err) { |
|
|
reject(err); |
|
|
return; |
|
|
} |
|
6 |
|
|
7 |
resolve(); |
constructor(client: DiscordClient) { |
8 |
}); |
this.client = client; |
|
}); |
|
|
} |
|
|
|
|
|
getAsync(sql, paramsOrCallback = []) { |
|
|
return new Promise((resolve, reject) => { |
|
|
this.db.get(sql, paramsOrCallback, (err, data) => { |
|
|
if (err) { |
|
|
reject(err); |
|
|
return; |
|
|
} |
|
|
|
|
|
resolve(data); |
|
|
}); |
|
|
}); |
|
|
} |
|
|
|
|
|
allAsync(sql, paramsOrCallback = []) { |
|
|
return new Promise((resolve, reject) => { |
|
|
this.db.all(sql, paramsOrCallback, (err, data) => { |
|
|
if (err) { |
|
|
reject(err); |
|
|
return; |
|
|
} |
|
9 |
|
|
10 |
resolve(data); |
mongoose.connect(process.env.MONGO_URI!) |
11 |
}); |
.then(() => console.log("Connected to MongoDB")) |
12 |
}); |
.catch(console.error); |
13 |
} |
} |
|
} |
|
|
|
|
|
module.exports = Database; |
|
14 |
|
} |