Flutter数据库连接插件postgresql2的使用

postgresql2 是一个用于 Dart 的 PostgreSQL 数据库驱动程序，支持多种功能如连接池、SSL 连接等。以下是如何在 Flutter 应用中使用 postgresql2 插件的基本指南。

基本用法

获取连接

首先，需要通过提供的 URI 来获取数据库连接：

var uri = 'postgres://username:password@localhost:5432/database';
connect(uri).then((conn) {
  // 使用连接进行查询或执行操作
});

SSL 连接

为了启用 SSL 连接，在 URI 后添加 sslmode=require 参数：

var uri = 'postgres://username:password@localhost:5432/database?sslmode=require';
connect(uri).then((conn) {
  // 使用连接进行查询或执行操作
});

查询数据

可以使用 query 方法来执行 SQL 查询，并通过 toList 方法获取结果：

conn.query('select color from crayons').toList().then((rows) {
  for (var row in rows) {
    print(row.color); // 按列名引用
    print(row[0]);    // 或者按列索引引用
  }
});

执行更新操作

使用 execute 方法来执行更新操作：

conn.execute("update crayons set color = 'pink'").then((rowsAffected) {
  print(rowsAffected);
});

使用查询参数

为了防止 SQL 注入，可以通过提供参数映射的方式来安全地传递参数：

conn.query('select color from crayons where id = @id', {'id': 5})
  .toList()
  .then((result) { print(result); });

conn.execute('insert into crayons values (@id, @color)',
             {'id': 1, 'color': 'pink'})
  .then((_) { print('done.'); });

关闭连接

使用完毕后，记得关闭连接：

conn.close();

映射查询结果到对象

可以通过定义 Dart 类并将查询结果映射到该类实例：

class Crayon {
  String color;
  int length;
}

conn.query('select color, length from crayons')
    .map((row) => new Crayon()..color = row.color..length = row.length)
    .toList()
    .then((List<Crayon> crayons) {
      for (var c in crayons) {
        print(c.color);
        print(c.length);
      }
    });

示例 Demo

以下是一个完整的示例程序，展示了如何从 pubspec.yaml 文件中添加依赖项并运行一个简单的查询：

pubspec.yaml

确保你的 pubspec.yaml 文件包含以下内容：

name: postgresql_example
dependencies:
  postgresql2: any

Dart代码

import 'package:postgresql2/postgresql.dart';

void main() async {
  var uri = 'postgres://testdb:password@localhost:5432/testdb';
  var sql = "select 'oi'";
  
  try {
    var conn = await connect(uri);
    var result = await conn.query(sql).toList();
    print('Result: $result');
  } catch (e) {
    print('Error: $e');
  }
}

以上是关于如何在 Flutter 中使用 postgresql2 插件的基础教程。根据实际需求调整 URI 和 SQL 查询即可完成更复杂的数据操作。