Flutter MongoDB数据库连接插件mongo_db_driver的使用

本包是用于通过Dart连接到MongoDB服务器的新版本驱动程序。它受到了mongo_dart包的启发，但已经重构以改善用户体验。

___________这是预Alpha版 ___________不适合生产环境

此包仅允许早期采用者进行测试。

API可能会发生变化！

该库可以在任何环境中使用，除了Web环境之外。

注意 从这个版本开始，我们只支持MongoDB 5.0及更高版本。 所有API都已更新以反映最新版本的命令。

与mongo_dart的区别

有一些与mongo_dart的不同之处需要注意：

• 连接是通过客户端对象完成的。一旦建立连接，您可以获取一个数据库对象。您可以为同一个客户端实例创建不同的数据库对象。
• 会话。
• 事务。
• 连接池已重新设计。
• 高级消息传递。
• 网络问题或选举时自动重连。

API

API通常是为了尽可能地模仿mongo shell的行为而创建的。 显然，并不是所有的操作都是相同的，但至少是以最佳的方式执行某些操作。 命名约定也尽可能保持与shell一致。

贡献

如果您能为这个包的发展做出贡献，欢迎您的帮助！

基本用法

获取连接

var client = MongoClient("mongodb://localhost:27017/mongo_dart-blog");
await client.connect();
var db = client.db();

打开会话

如果要创建会话，可以这样做：

var session = client.startSession();
(ret, _, _, _) = await collection.insertOne(<String, dynamic>{
  '_id': 2,
  'name': 'Ezra',
  'state': 'active',
  'rating': 90,
  'score': 6
}, session: session);

if (!ret.isSuccess) {
  print('Error detected in record insertion');
}
await session.endSession();

事务

以下是一个简单的事务示例：

session = client.startSession();
session.startTransaction();
(ret, _, _, _) = await collection.insertOne(<String, dynamic>{
  '_id': 3,
  'name': 'Nathan',
  'state': 'active',
  'rating': 98,
  'score': 4
}, session: session);

if (!ret.isSuccess) {
  print('Error detected in record insertion');
}
var commitRes = await session.commitTransaction();
if (commitRes?[keyOk] == 0.0) {
  print('${commitRes?[keyErrmsg]}');
}
await session.endSession();

示例代码

import 'dart:io' show Platform;

import 'package:mongo_db_driver/src/client/mongo_client.dart';
import 'package:mongo_db_query/mongo_db_query.dart';

String host = Platform.environment['MONGO_DART_DRIVER_HOST'] ?? '127.0.0.1';
String port = Platform.environment['MONGO_DART_DRIVER_PORT'] ?? '27017';

void main() async {
  var client = MongoClient('mongodb://$host:$port/mongo_dart-blog');
  await client.connect();
  final db = client.db();
  
  var authors = <String, Map>{};
  var users = <String, Map>{};

  await db.dropDatabase();
  print('====================================================================');
  print('>> 添加作者');
  
  var collection = db.collection('authors');
  await collection.insertMany([
    {
      'name': 'William Shakespeare',
      'email': 'william@shakespeare.com',
      'age': 587
    },
    {'name': 'Jorge Luis Borges', 'email': 'jorge@borges.com', 'age': 123}
  ]);
  await db.ensureIndex('authors',
      name: 'meta', keys: {'_id': 1, 'name': 1, 'age': 1});
  await collection.find().forEach((v) {
    print(v);
    authors[v['name'].toString()] = v;
  });
  
  print('====================================================================');
  print('>> 按年龄升序排列的作者');
  await collection.find(filter: where..sortBy('age')).forEach(
      (auth) => print("[${auth['name']}]:[${auth['email']}]:[${auth['age']}]"));
  
  print('====================================================================');
  print('>> 添加用户');
  
  var usersCollection = db.collection('users');
  await usersCollection.insertMany([
    {'login': 'jdoe', 'name': 'John Doe', 'email': 'john@doe.com'},
    {'login': 'lsmith', 'name': 'Lucy Smith', 'email': 'lucy@smith.com'}
  ]);
  await db.ensureIndex('users', keys: {'login': -1});
  await usersCollection.find().forEach((user) {
    users[user['login'].toString()] = user;
    print(user);
  });
  
  print('====================================================================');
  print('>> 按登录名降序排列的用户');
  await usersCollection.find(filter: where..sortBy({'login': -1})).forEach(
      (user) =>
          print("[${user['login']}]:[${user['name']}]:[${user['email']}]"));
  
  print('====================================================================');
  print('>> 添加文章');
  
  var articlesCollection = db.collection('articles');
  await articlesCollection.insertMany([
    {
      'title': 'Caminando por Buenos Aires',
      'body': 'Las callecitas de Buenos Aires tienen ese no se que...',
      'author_id': authors['Jorge Luis Borges']?['_id']
    },
    {
      'title': 'I must have seen thy face before',
      'body': 'Thine eyes call me in a new way',
      'author_id': authors['William Shakespeare']?['_id'],
      'comments': [
        {'user_id': users['jdoe']?['_id'], 'body': 'great article!'}
      ]
    }
  ]);
  
  print('====================================================================');
  print('>> 按标题升序排列的文章');
  await articlesCollection
      .find(filter: where..sortBy('title'))
      .forEach((article) {
    print("[${article['title']}]:[${article['body']}]:"
        "[${article['author_id'].toHexString()}]");
  });
  
  await client.close();
}