如何快速给Flutter增加云同步功能
今天以一个漂亮的开源记账项目为例,来给大家提供一个思路,用最简单的方法将一个本地存储项目变为可以云同步的项目。
这个App名叫《出入》,地址在https://github.com/Livinglist/Churu
。为什么选这个项目呢?因为这个项目本身就是使用的本地sqlite
进行数据存储,可以比较方便将它改成在线postgre
数据库,从而用有云同步功能。
对于没有使用sqlite
的项目也是可以改造的,只不过要重新写存储逻辑,如果某个项目你有特别喜欢和需要的功能,也是值得花点时间改造的。
废话少说,我们来看项目。
我们找到项目中的db_provider.dart
文件,接下来的主要任务就是改造这个本地数据库功能。
首先我们引入dart的postgre驱动,并初始化数据库。
import 'package:postgres/postgres.dart';
...
connection = PostgreSQLConnection(dbIp, dbPort, dbName,
username: dbAccount, password: dbPasswd);
await connection.open();
...
这里需要准备一个有公网ip免费云数据库MemFireDB,一键创建,一键查询,十分方便。
接下来创建数据库方式也要修改成postgre
的方式。
CREATE TABLE $tableName ("""
$colId SERIAL PRIMARY KEY,
$colUuid TEXT,
$colTimestamp BIGINT,
$colDescription TEXT,
$colType INTEGER,
$colAmount REAL);
""");
这一步成功之后,我们就将数据库搬到了云上。接下来将它所有操作数据库的业务逻辑改成postgre
方式。
可以看到源代码中有这个几个方法。
updateTransaction
deleteTransaction
addTransaction
getAllTransactions
我们看其中一个添加交易的方法可以看到,dart
的sqlite
库对SQL
语句做了一些封装,可以直接插入一个map
,使用起来比较方便。
Future<int> addTransaction(Transaction transaction) async {
...
return db.insert('Transactions', transaction.toMap());
}
但是postgre
库没有提供这些,需要自己做一点封装。下面是我封装的方法,方便插入和更新数据。
static String getInsertSql(String table, Map<String, dynamic> values,
{List<String> ignores}) {
if (ignores != null && ignores.length > 0) {
ignores = ignores.map((e) => e.toLowerCase()).toList();
}
final insert = StringBuffer();
insert.write('INSERT');
insert.write(' INTO ');
insert.write(_escapeName(table));
insert.write(' (');
final size = (values != null) ? values.length : 0;
if (size > 0) {
final sbValues = StringBuffer(') VALUES (');
var i = 0;
values.forEach((String colName, dynamic value) {
if (ignores == null || !ignores.contains(colName.toLowerCase())) {
if (i++ > 0) {
insert.write(', ');
sbValues.write(', ');
}
/// This should be just a column name
insert.write(_escapeName(colName));
sbValues.write(PostgreSQLFormat.id(colName));
}
});
insert.write(sbValues);
}
insert.write(')');
var sql = insert.toString();
return sql;
}
还有一些别的封装,都写在pg_helper.dart
文件中。
这里我们添加交易的方法就变成了。
Future<int> addTransaction(Transaction transaction) async {
...
var sql = PgHelper.getInsertSql(tableName, transaction.toMap(), ignores: [colId]);
var res = await db.execute(sql, substitutionValues: transaction.toMap());
return res;
}
同样的其他的方法也都要改造,将这些方法都改造完成之后就完成了。
如果你的应用需要提供给其他人用,或者你想跟你的对象(如果你有的话)一起记账,那么可以写一个配置数据库的界面,方便动态配置数据库。
我这里写了一个,可供参考。
到这里,你就可以跟你对象愉快的一起记账啦![狗头]
App还是很好用的,现在又有了云同步功能,就更加强大了。
这里只是给大家提供一个思路,更多的玩法大家发挥自己的想象。