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

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

Usage

创建 PostgresDb 并打开它：

var db = PostgresDb.fromUrl('postgresql://username:password@hosturl/databaseName');
await db.open();

或者直接传入参数：

var db = PostgresDb(host: 'host', databaseName: 'databaseName', username: 'username', password: 'password');
await db.open();

示例

插入数据

// 插入数据
await db.table('tableName').insert(columns: ['name', 'age'], values: ['Name Name', 30]);

更新数据

// 更新特定记录
await db.table('tableName').update(update: {"age": 40}, where: Where('name', WhereOperator.isEqual, 'Name Name'));

// 更新所有记录
await db.table('tableName').update(update: {"age": 40}, where: null);

删除数据

// 删除特定记录
await db.table('tableName').delete(Where('name', WhereOperator.isEqual, 'Name Name'));

// 删除所有记录
await db.table('tableName').deleteAll();

查询数据

// 查询数据
await db.table('tableName').select(
  columns: [Column('id'), Column('name', columnAs: 'userName'), Column('age')],
  where: Where('name', WhereOperator.isEqual, 'Name Name'),
  orderBy: OrderBy('name', ascending: true)
);

聚合函数

// 求最大值
await db.table('tableName').max([Max('age')]);

// 求最小值
await db.table('tableName').min([Min('age', label: 'minAge')]);

// 计数
await db.table('tableName').count([Count(columnName: '*')]);

// 求和
await db.table('tableName').sum([Sum(columnName: 'age', label: 'totalAge'), Sum(columnName: 'amount')]);

// 求平均值
await db.table('tableName').avg([Avg(columnName: 'age', label: 'averageAge'), Avg(columnName: 'amount')]);

复合聚合

// 复合聚合
await db.table('tableName').aggregate([
  Count(columnName: '*'),
  Sum(columnName: 'amount', label: 'totalAmount'),
  Avg(columnName: 'age', label: 'averageAge'),
]);

分组查询

// 分组查询
await db.table('tableName').group(
  groupBy: ['gender'],
  columns: [Column('gender')],
  aggregates: [
    Count(columnName: '*'),
    Sum(columnName: 'amount', label: 'totalAmount'),
    Avg(columnName: 'age', label: 'averageAge'),
  ]
);

连接查询

// 连接查询
await db.table('tableName').join(
  tableAs: 't1',
  columns: [Column('t1.id', columnAs: 'id'), Column('t1.name', columnAs: 'name'), Column('t3.age', columnAs: 'age'),],
  joins: [
    Join(joinType: JoinType.inner, tableName: 'table2', tableAs: 't2', onorUsing: JoinOn(leftColumnName: 't1.id', rightColumnName: 't2.userid', operator: WhereOperator.isEqual)),
    Join(joinType: JoinType.inner, tableName: 'table3', tableAs: 't3', onorUsing: JoinUsing(columnName: 'userid')),
  ]
);

更多关于Flutter数据库连接插件postgres_dart的使用的实战教程也可以访问 https://www.itying.com/category-92-b0.html

1 回复

更多关于Flutter数据库连接插件postgres_dart的使用的实战系列教程也可以访问 https://www.itying.com/category-92-b0.html


当然，下面是一个关于如何在Flutter项目中使用postgres_dart插件连接PostgreSQL数据库的示例代码。需要注意的是，postgres_dart是一个纯Dart实现的PostgreSQL客户端库，通常用于服务器端或命令行应用程序。由于Flutter运行在客户端（如移动设备或Web），直接连接数据库并不是最佳实践，因为这可能涉及到安全性和性能问题。通常，你会在服务器端设置一个API，然后通过Flutter应用调用这些API来间接与数据库交互。

不过，如果你出于学习目的或特定需求需要在Flutter中直接连接PostgreSQL，可以参考以下代码（注意：这仅用于教育目的，并不推荐在生产环境中使用）：

  1. 首先，在pubspec.yaml文件中添加依赖：

    dependencies:
  flutter:
    sdk: flutter
  postgres_dart: ^2.0.0 # 请检查最新版本号

  2. 然后，在Flutter项目中创建一个数据库连接和查询的示例：

    import 'package:flutter/material.dart';
import 'package:postgres_dart/postgres_dart.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('Postgres Dart Example'),
        ),
        body: Center(
          child: FutureBuilder<String>(
            future: fetchData(),
            builder: (context, snapshot) {
              if (snapshot.connectionState == ConnectionState.done) {
                if (snapshot.hasError) {
                  return Text('Error: ${snapshot.error}');
                } else {
                  return Text('Data: ${snapshot.data}');
                }
              } else {
                return CircularProgressIndicator();
              }
            },
          ),
        ),
      ),
    );
  }
}

Future<String> fetchData() async {
  // 数据库连接信息
  var connection = PostgreSQLConnection(
    'your_host', // 例如 'localhost'
    port: 5432,
    dbName: 'your_database',
    username: 'your_username',
    password: 'your_password',
  );

  try {
    // 打开连接
    await connection.open();

    // 执行查询
    var result = await connection.query('SELECT * FROM your_table LIMIT 1');
    var row = result.single;
    var data = row['your_column']; // 替换为你的列名

    // 关闭连接
    await connection.close();

    return data.toString();
  } catch (e) {
    // 处理异常
    print('Error connecting to PostgreSQL: $e');
    return 'Error connecting to database';
  }
}

重要提示：

  • 上面的代码直接在Flutter客户端尝试连接PostgreSQL数据库，这在实际应用中是不安全的，也不推荐。
  • 正确的做法是通过Flutter应用调用后端API，后端API再连接数据库执行查询。
  • 如果你确实需要在客户端处理数据库连接（例如，开发一个本地桌面应用），请考虑使用更安全的方法，如使用本地数据库或通过安全的API与后端服务交互。
  • 确保在生产环境中使用HTTPS来保护API请求，避免敏感信息泄露。

希望这个示例能帮助你理解如何在Flutter中使用postgres_dart，但请记住最佳实践和安全考虑。

回到顶部