Flutter插件fennec_pg的使用_fennec_pg是一个用于通过ORM连接到PostgreSQL的dart插件

Flutter插件fennec_pg的使用_fennec_pg是一个用于通过ORM连接到PostgreSQL的dart插件

fennec_pg 是一个用于通过ORM连接到PostgreSQL的dart插件。它属于Fennec框架，但可以单独使用。

Flutter插件fennec_pg安装

安装该插件可以从 pub.dev 下载：

dependencies:
  fennec_pg:

然后运行 flutter pub get。

支持的功能

• 连接到PostgreSQL数据库。
• SelectBuilder 用于带有 where 子句的选择操作。
• FilterBuilder 用于过滤搜索数据。
• SelectBuilderWithNestedJsonOutput 用于连接操作，特别是当您希望将相关对象作为嵌套JSON时。
• Serializable 用于动态序列化您的模型。
• Repository 接口，可用于创建自己的存储库。
• 关系 包括一对一、一对多和属于关系。

创建模型

以下是如何定义用户和账户模型的示例：

// 用户模型
@Table('users')
class User extends Serializable {
  @PrimaryKey(autoIncrement: true, columnType: ColumnType.bigInt)
  int? id;

  @Column(isNullable: false, indexType: IndexType.unique)
  late String name;

  @Column(isNullable: false, indexType: IndexType.unique)
  late String email;

  @HasOne(
      localKey: 'user_id',
      foreignKey: 'id',
      fetchType: FetchType.include,
      cascadeType: CascadeType.delete)
  Account? account;

  User();

  User.fromJson(Map<String, dynamic> map) {
    id = map['id'];
    name = map['name'];
    email = map['email'];
    if (map['account'] != null) {
      account = Account.fromJson(map['account']);
    }
  }
}

// 账户模型
@Table('accounts')
class Account extends Serializable {
  Account();

  @PrimaryKey(autoIncrement: true, columnType: ColumnType.bigInt)
  int? id;

  @BelongsTo(
      localKey: 'id', foreignKey: 'user_id', fetchType: FetchType.include)
  User? user;

  Account.fromJson(Map<String, dynamic> map) {
    id = map['id'];
    if (map['user'] != null) {
      user = User.fromJson(map['user']);
    }
  }
}

创建存储库

class UserRepository extends Repository<User, int> {}
class AccountRepository extends Repository<Account, int> {}

使用存储库示例

void main() async {
  AccountRepository accountRepository = AccountRepository();
  UserRepository userRepository = UserRepository();

  User user = User();
  user.email = '131@web.de';
  user.name = 'ak1';
  user.account = Account();

  User? userResult = await userRepository.insert(user);
  if (userResult != null) {
    print(userResult.toJson());
  }

  final result = await accountRepository.findAll();
  for (var row in result) {
    print(row.toJson());
  }
}

使用 SelectBuilder 和 FilterBuilder

void main() async {
  SelectBuilder selectBuilder = SelectBuilder(['*'], table: 'users');
  FilterBuilder filterBuilder = FilterBuilder(Field.tableColumn('id'), '=', Field.int(2));
  filterBuilder.or(FilterBuilder(Field.tableColumn('id'), '=', Field.int(4)));

  selectBuilder.where(filterBuilder);
  
  final result = await PGConnectionAdapter.connection
     .query(selectBuilder.makeQuery())
     .toList();

  for (var row in result) {
    print(row.toMap());
  }
}

自定义查询

void main() async {
  final result = await PGConnectionAdapter.connection
    .query('select * from users')
    .toList();

  for (var row in result) {
    print(row.toMap());
  }
}

启动与PostgreSQL的连接

void main() async {
  var uri = 'postgres://user:password[@localhost](/user/localhost):5432/db-name';
  await PGConnectionAdapter.init(uri);
}