MongoDB

MongoDB 引擎是只读表引擎,允许从远程 MongoDB 集合中读取数据(SELECT查询)。引擎只支持非嵌套的数据类型。不支持 INSERT 查询。

创建一张表

  1. CREATE TABLE [IF NOT EXISTS] [db.]table_name
  2. (
  3. name1 [type1],
  4. name2 [type2],
  5. ...
  6. ) ENGINE = MongoDB(host:port, database, collection, user, password);

引擎参数

  • host:port — MongoDB 服务器地址.

  • database — 数据库名称.

  • collection — 集合名称.

  • user — MongoDB 用户.

  • password — 用户密码.

用法示例

ClickHouse 中的表,从 MongoDB 集合中读取数据:

  1. CREATE TABLE mongo_table
  2. (
  3. key UInt64,
  4. data String
  5. ) ENGINE = MongoDB('mongo1:27017', 'test', 'simple_table', 'testuser', 'clickhouse');

查询:

  1. SELECT COUNT() FROM mongo_table;
  1. ┌─count()─┐
  2. 4
  3. └─────────┘