90 lines
2.6 KiB
Dart
90 lines
2.6 KiB
Dart
import 'dart:async';
|
|
import 'dart:io';
|
|
import 'package:flutter/foundation.dart';
|
|
import 'package:sqflite/sqflite.dart';
|
|
import 'package:path_provider/path_provider.dart' show MissingPlatformDirectoryException, getApplicationDocumentsDirectory;
|
|
import 'package:tetra_stats/services/crud_exceptions.dart';
|
|
import 'package:tetra_stats/services/tetrio_crud.dart';
|
|
import 'package:path/path.dart' show join;
|
|
|
|
const String dbName = "TetraStats.db";
|
|
|
|
/// Base class for CRUD services. Contains basic functions
|
|
class DB {
|
|
Database? _db;
|
|
|
|
/// Handles opening of DB and creates tables if they not exist
|
|
Future<void> open() async {
|
|
if (_db != null) {
|
|
// in order to not open DB multiple times
|
|
throw DatabaseAlreadyOpen();
|
|
}
|
|
try {
|
|
String dbPath;
|
|
if (kIsWeb) { // i hate web
|
|
dbPath = dbName;
|
|
} else {
|
|
final docsPath = await getApplicationDocumentsDirectory();
|
|
dbPath = join(docsPath.path, dbName);
|
|
}
|
|
final db = await openDatabase(dbPath);
|
|
_db = db;
|
|
await db.execute(createTetrioUsersTable);
|
|
await db.execute(createTetrioUsersToTrack);
|
|
await db.execute(createTetrioTLRecordsTable);
|
|
await db.execute(createTetrioTLReplayStats);
|
|
await db.execute(createTetrioLeagueTable);
|
|
} on MissingPlatformDirectoryException {
|
|
throw UnableToGetDocuments();
|
|
}
|
|
}
|
|
|
|
/// Handles closing of DB
|
|
Future<void> close() async {
|
|
final db = _db;
|
|
if (db == null) {
|
|
throw DatabaseIsNotOpen();
|
|
} else {
|
|
await db.close();
|
|
_db = null;
|
|
}
|
|
}
|
|
|
|
/// if we need instance of our DB, it will return it.
|
|
Database getDatabaseOrThrow() {
|
|
final db = _db;
|
|
if (db == null) {
|
|
throw DatabaseIsNotOpen();
|
|
} else {
|
|
return db;
|
|
}
|
|
}
|
|
|
|
/// You can never be too sure. Although we can be 100% sure, that DB is open after executing that function
|
|
Future<void> ensureDbIsOpen() async {
|
|
try {
|
|
await open();
|
|
} on DatabaseAlreadyOpen {
|
|
// empty
|
|
}
|
|
}
|
|
|
|
/// Executes VACUUM command for our DB and returns number of bytes, that was saved with this operation
|
|
Future<int> compressDB() async{
|
|
await ensureDbIsOpen();
|
|
final db = getDatabaseOrThrow();
|
|
String dbPath;
|
|
if (kIsWeb) {
|
|
dbPath = dbName;
|
|
} else {
|
|
final docsPath = await getApplicationDocumentsDirectory();
|
|
dbPath = join(docsPath.path, dbName);
|
|
}
|
|
var dbFile = File(dbPath);
|
|
var dbStats = await dbFile.stat();
|
|
await db.execute("VACUUM");
|
|
var newDBStats = await dbFile.stat();
|
|
return dbStats.size - newDBStats.size;
|
|
}
|
|
}
|