init mysql

Author: 3003h

lib/store/mysql/connection_info.dart

@@ -0,0 +1,19 @@
+class ConnectionInfo {
+ ConnectionInfo({
+ required this.host,
+ required this.port,
+ required this.userName,
+ required this.password,
+ required this.databaseName,
+ this.secure,
+ this.collation,
+ });
+
+ final String host;
+ final int port;
+ final String userName;
+ final String password;
+ final String databaseName;
+ final bool? secure;
+ final String? collation;
+}

lib/store/mysql/const.dart

@@ -0,0 +1 @@
+const kVersion = 1;

lib/store/mysql/migration.dart

@@ -0,0 +1,13 @@
+import 'package:mysql_client/mysql_client.dart';
+
+class Migration {
+ Migration(
+ this.originVersion,
+ this.targetVersion,
+ this.execute,
+ );
+
+ final int originVersion;
+ final int targetVersion;
+ final Function(MySQLConnection) execute;
+}

lib/store/mysql/mysql.dart

@@ -0,0 +1,69 @@
+import 'package:mysql_client/mysql_client.dart';
+
+import 'connection_info.dart';
+import 'migration.dart';
+
+class FeMySql {
+ // 工厂构造函数，用于创建单例实例
+ factory FeMySql({ConnectionInfo? connectionInfo}) {
+ return _instance.._init(connectionInfo);
+ }
+ // 私有构造方法，确保只能在类内部创建实例
+ FeMySql._();
+
+ // 单例实例
+ static final FeMySql _instance = FeMySql._();
+
+ late MySQLConnection _conn;
+ List<Migration>? migrations;
+
+ // 内部初始化方法
+ Future<void> _init(ConnectionInfo? connectionInfo) async {
+ _conn = await MySQLConnection.createConnection(
+ host: connectionInfo!.host,
+ port: connectionInfo.port,
+ userName: connectionInfo.userName,
+ password: connectionInfo.password,
+ databaseName: connectionInfo.databaseName,
+ );
+ await _conn.connect();
+ }
+
+ FeMySql addMigrations(List<Migration> migrations) {
+ this.migrations = migrations;
+ return this;
+ }
+
+ Future<void> migrate() async {
+ if (migrations == null) {
+ return;
+ }
+
+ final version = await getVersion() ?? 0;
+ final lastVersion = migrations!.last.targetVersion;
+
+ if (version == lastVersion) {
+ return;
+ }
+
+ for (final migration in migrations!) {
+ if (version < migration.targetVersion) {
+ await migration.execute(_conn);
+ await setVersion(migration.targetVersion);
+ }
+ }
+ }
+
+ Future<int?> getVersion() async {
+ final result = await _conn.execute('SELECT version FROM version');
+ if (result.isEmpty) {
+ return null;
+ }
+
+ return result.first as int;
+ }
+
+ Future<void> setVersion(int targetVersion) async {
+ await _conn.execute('UPDATE version SET version = $targetVersion');
+ }
+}

pubspec.lock

@@ -146,6 +146,14 @@ packages:
  url: "https://pub.flutter-io.cn"
  source: hosted
  version: "2.1.1"
+ buffer:
+ dependency: transitive
+ description:
+ name: buffer
+ sha256: "94f60815065a8f0fd4f05be51faf86cf86519327e039d5c2aac72e1d1cc1dad4"
+ url: "https://pub.flutter-io.cn"
+ source: hosted
+ version: "1.2.2"
  build:
  dependency: transitive
  description:
@@ -1461,6 +1469,14 @@ packages:
  url: "https://pub.flutter-io.cn"
  source: hosted
  version: "2.1.2"
+ mysql_client:
+ dependency: "direct main"
+ description:
+ name: mysql_client
+ sha256: "6a0fdcbe3e0721c637f97ad24649be2f70dbce2b21ede8f962910e640f753fc2"
+ url: "https://pub.flutter-io.cn"
+ source: hosted
+ version: "0.0.27"
  native_dio_adapter:
  dependency: "direct main"
  description:
@@ -2142,6 +2158,14 @@ packages:
  url: "https://pub.flutter-io.cn"
  source: hosted
  version: "1.0.1"
+ tuple:
+ dependency: transitive
+ description:
+ name: tuple
+ sha256: a97ce2013f240b2f3807bcbaf218765b6f301c3eff91092bcfa23a039e7dd151
+ url: "https://pub.flutter-io.cn"
+ source: hosted
+ version: "2.0.2"
  typed_data:
  dependency: transitive
  description:

pubspec.yaml

@@ -196,6 +196,7 @@ dependencies:
  flutter_windowmanager: ^0.2.0
  integral_isolates: ^0.4.1
  cupertino_battery_indicator: ^1.1.0
+ mysql_client: ^0.0.27
 
 dev_dependencies:
  # flutter pub run build_runner build --delete-conflicting-outputs