class MyPostgresPersistence extends IdentifiablePostgresPersistence<MyData, String> {
MyPostgresPersistence() : super('mydata', null);
@override
void defineSchema_() {
// clear all previously autogenerated schemas
clearSchema();
// create a table
ensureSchema_('CREATE TABLE ' +
tableName_! +
' (id TEXT PRIMARY KEY, key TEXT, content TEXT)');
// create an index
ensureIndex_(tableName_! + '_key', {'key': 1}, {'unique': true});
}
Future<MyData?> getOneRandom(String correlationId, String filter) async {
return await super.getOneRandom_(correlationId, filter);
}
Future<List<MyData>> getListByFilter(
String correlationId, String filter, sort, select) async {
return await super.getListByFilter_(correlationId, filter, sort, select);
}
Future<int> getCountByFilter(String correlationId, String filter) async {
return await super.getCountByFilter_(correlationId, filter);
}
Future<DataPage<MyData>> getPageByFilter(String correlationId, String filter,
PagingParams paging, sort, select) async {
return await super
.getPageByFilter_(correlationId, filter, paging, sort, select);
}
Future<void> deleteByFilter(String correlationId, String filter) async {
return await super.deleteByFilter_(correlationId, filter);
}
}