Flutter样式管理插件style_mongo的使用

使用

将style_mongo添加到组件树

[@override](/user/override)
Component build(BuildContext context) {
  return Server(
      dataAccess: DataAccess(
          MongoDbDataAccessImplementation("<connection-string>")
      ),
      children: [
        // 其他子组件
      ]);
}

或者

[@override](/user/override)
Component build(BuildContext context) {
  return ServiceWrapper<
      DataAccess>(
    service: DataAccess(
        MongoDbDataAccessImplementation("<connection-string>")
    ),
    child: YourChildComponent(),
  );
}

操作

FutureOr<Object> onCall(Request request) {
  return Access(
    collection: "<collection>",
    type: type,

    // 可选。对于某些操作是必要的
    // 也可以使用"Query"
    query: MongoQuery(where.eq("field", "value")),
    
    // 可选。聚合操作时必要
    pipeline: AggregationPipelineBuilder(/*stages*/),
    // 或者 pipeline: [{"\$project" : {"_id":0}}],
  );
}

你可以使用不同的风格进行操作，例如 DataAccess.of(ctx).read(..)。

使用Query时，selector参数必须是MongoDB样式的Map。因此必须是 where.eq("field", "value").map["\$query"]。

设置

MongoDB有许多操作设置，如WriteConcern。你可以通过以下方式设置这些设置：

f(){
  final access = Access(
      settings: MongoDbFindSettings(findOptions: FindOptions(returnKey: true))
    // 其他配置项
  );
}

所有操作都有相应的设置，除了count和exists。

示例用法

示例代码

以下是一个完整的示例代码，展示了如何使用style_mongo插件。

import 'package:mongo_dart/mongo_dart.dart';
import 'package:style_dart/style_dart.dart';
import 'package:style_mongo/src/mongo_query.dart';
import 'package:style_mongo/src/style_mongo_base.dart';

/// 在此示例中
///
/// 客户端示例。
///
/// 创建：
///
/// ```http 请求
/// http://localhost/c/users
///
/// {
///   "data" : {
///     "name" : "Mehmet"
///   }
/// }
/// ```
///
/// 读取：
///
/// ```http 请求
/// http://localhost/r/users
///
/// {
///   "query" : where.eq("name" ,"Mehmet").map
/// }
/// ```
/// 更多示例请查看测试文件
void main() {
  runService(MongoDbExampleServer());
}

class MongoDbExampleServer extends StatelessComponent {
  const MongoDbExampleServer({Key? key}) : super(key: key);

  [@override](/user/override)
  Component build(BuildContext context) {
    return Server(
        dataAccess: DataAccess(MongoDbDataAccessImplementation(
            "mongodb://0.0.0.0:27017/demo_col")),
        children: [
          Route("{type}", child: Route("{collection}", root: MyAccessPoint()))
        ]);
  }
}

///
class MyAccessPoint extends StatelessComponent {
  final Map<String, AccessType> _types = {
    "r": AccessType.read,
    "c": AccessType.create,
    "u": AccessType.update,
    "d": AccessType.delete,
    "rl": AccessType.readMultiple,
    "e": AccessType.exists,
    "co": AccessType.count,
    "a": AccessType.aggregation
  };

  [@override](/user/override)
  Component build(BuildContext context) {
    return AccessPoint((req, c) {
      if (req.body != null && req.body is! JsonBody?) {
        print(req.body.runtimeType);
        throw BadRequests();
      }
      var type = _types[req.arguments["type"]];
      if (type == null) {
        throw BadRequests();
      }
      var body = (req.body as JsonBody?)?.data;
      return AccessEvent(
          access: Access(
              collection: req.arguments["collection"],
              type: type,
              data: body?["data"],
              pipeline: body?["pipeline"],
              query: body["query"] != null
                  ? MongoQuery(SelectorBuilder().raw(body["query"]))
                  : null),
          context: c,
          request: req);
    });
  }
}