58 lines
1.4 KiB
Dart
58 lines
1.4 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:angel3_orm/angel3_orm.dart';
|
|
import 'package:angel3_serialize/angel3_serialize.dart';
|
|
import 'package:optional/optional.dart';
|
|
|
|
part 'main.g.dart';
|
|
|
|
void main() async {
|
|
var query = EmployeeQuery()
|
|
..where?.firstName.equals('Rich')
|
|
..where?.lastName.equals('Person')
|
|
..where?.raw('COM.deleted = false')
|
|
..orWhere((w) => w.salary.greaterThanOrEqualTo(75000))
|
|
..join('companies', 'company_id', 'id', alias: 'COM');
|
|
|
|
var richPerson = await query.getOne(_FakeExecutor());
|
|
if (richPerson.isPresent) {
|
|
print(richPerson.first.toJson());
|
|
}
|
|
}
|
|
|
|
class _FakeExecutor extends QueryExecutor {
|
|
const _FakeExecutor();
|
|
|
|
@override
|
|
Future<List<List>> query(
|
|
String tableName, String query, Map<String, dynamic> substitutionValues,
|
|
{String returningQuery = '',
|
|
List<String> returningFields = const []}) async {
|
|
var now = DateTime.now();
|
|
print(
|
|
'_FakeExecutor received query: $query and values: $substitutionValues');
|
|
return [
|
|
[1, now, now, 'Rich', 'Person', 100000.0]
|
|
];
|
|
}
|
|
|
|
@override
|
|
Future<T> transaction<T>(FutureOr<T> Function(QueryExecutor) f) {
|
|
throw UnsupportedError('Transactions are not supported.');
|
|
}
|
|
|
|
final Dialect _dialect = const PostgreSQLDialect();
|
|
|
|
@override
|
|
Dialect get dialect => _dialect;
|
|
}
|
|
|
|
@orm
|
|
@serializable
|
|
abstract class _Employee extends Model {
|
|
String? get firstName;
|
|
|
|
String? get lastName;
|
|
|
|
double? get salary;
|
|
}
|