• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

delphixe----操作mongoDB驱动,TMongoWire(DelphiMongoDBDriver)

原作者: [db:作者] 来自: [db:来源] 收藏 邀请
所有例子来自:https://github.com/stijnsanders/TMongoWire

一个Delphi的驱动程序来访问mongoDB的服务器。用jsonDoc.pas来存储JSON文档。ijsondocument将变量类型映射Delphi的多种变量,类似于 松散型的JavaScript。 主要有三个单位和两大类能够访问一个Mongo DB:

jsonDoc.pas

IJSONDocument

1)function JSON:IJSONDocument; //overload; //创建一个新的IJSONDocument实例:

 例子: d:=JSON;

2)function JSON(const x:array of Variant):IJSONDocument; //overload;//创建并填充一个新的IJSONDocument实例:

传递一个交替键和值的列表,
d:=JSON(['a',1,'b{','x','foo','}','c{','x','bar','}','d',VarArrayOf([JSON(['x','hello']),JSON(['y','world'])]),'e',true]);


{"a":1,"b":{"x":"foo"},"c":{"x":"bar"},"d":[{"x":"hello"},{"x":"world"}],"e":true}.
例子:

  d:=JSON([
    '_id',ListView1.Selected.SubItems[siiID],
    'name',ItemForm.txtName.Text,
    'address',ItemForm.txtAddress.Text,
    'phone',ItemForm.txtPhone.Text
    ]);

3)function JSON(const x: Variant): IJSONDocument; overload;//将一个变量转换成一个IJSONDocument引用。

例子:  dSelector:=JSON(['_id',ListView1.Selected.SubItems[siiID]]);

取决于论证的价值:

Null(或空或未赋值)返回nil,

将字符串类型解析为一个新的IJSONDocument实例

在所有其他情况下,该变量都被探测,以引用一个IJSONDocument instace。

4)     function ToString: WideString; stdcall;:展示出json数据

例子

 

 

mongoWire.pas

利用一个对象TMongoWire连接到MongoDB服务器。它支持获取单个项,执行插入、更新和删除。
利用一个类对象TMongoWireQuery 来查询mongoDB 服务器。它在需要时处理游标和服务器的后续请求,以获得更多的数据。

1)TMongoWire

方法

1)constructor TMongoWire.Create(const NameSpace: WideString);//创建

例子:

  procedure TMainForm.FormCreate(Sender: TObject);
  begin
    FMongoWire:=TMongoWire.Create(mwx1NameSpace);//mwx1NameSpace  数据库名
  end;

2)procedure TMongoWire.Open(const ServerName: string; Port: integer);//与mongoDB数据库连接

 例子:1)FMongoWire.Open(AnsiString(ConnectionForm.txtHost.Text),StrToInt(ConnectionForm.txtPort.Text))

    2)FDB.Open('192.168.0.68',27017);

3)procedure TMongoWire.Insert(const Collection: WideString;const Doc: IJSONDocument);

4)procedure TMongoWire.Insert(const Collection: WideString;const Docs: array of IJSONDocument);

3)procedure TMongoWire.Insert(const Collection: WideString;const Docs: IJSONDocArray);//增加

例子:FMongoWire.Insert(mwx1Collection,d);

4)function TMongoWire.Get(const Collection: WideString; const QryObj,ReturnFieldSelector: IJSONDocument): IJSONDocument;//获取单条

 例子: d:=FMongoWire.Get(mwx1Collection,dSelector);

5)procedure TMongoWire.Update(const Collection: WideString; const Selector,Doc: IJSONDocument; Upsert, MultiUpdate: oolean);//更新

例子:   FMongoWire.Update(mwx1Collection,dSelector,d);

6)procedure TMongoWire.Delete(const Collection: WideString;const Selector: IJSONDocument; SingleRemove: boolean);

例子:FMongoWire.Delete(mwx1Collection,JSON(['_id',ListView1.Selected.SubItems[siiID]]));

2)TMongoWireQuery

方法

1)constructor TMongoWireQuery.Create(MongoWire: TMongoWire);//创建

例子:    q:=TMongoWireQuery.Create(FMongoWire);)

2)procedure TMongoWireQuery.Query(const Collection: WideString; const QryObj,ReturnFieldSelector: IJSONDocument; Flags: integer);//查询

例子:q.Query(mwx1Collection,nil);//查询集合中所有文档(数据)

3)function TMongoWireQuery.Next(const Doc: IJSONDocument): boolean;//下一条

例子:q.Next(d)

 

MongoStream

使用TMongoStream 来加载和存储文件。在内部.files和.chunks集合用于存储数据。

方法

1)constructor TMongoStream.Create(db: TMongoWire; const prefix: WideString;const filequery: IJSONDocument);

     例子: m:=TMongoStream.Create(FDB,FilesCollection,li.SubItems[siID]);

2)class function TMongoStream.Add(db: TMongoWire; prefix: WideString;stream: TStream; const info: IJSONDocument): Variant;//添加上传文档信息

例子:

id:=TMongoStream.Add(FDB,FilesCollection,f,JSON([
'name',fn,
'contentType',contentType,
'created',VarFromDateTime(Now)
//more?
]));//将json数据添加到数据库里,返回mongoObjectId

3)class function TMongoStream.Add(db: TMongoWire; const prefix,filepath: WideString): Variant;

4)procedure TMongoStream.SaveToFile(const FileName: string);//另保存文件信息(下载)

 

二、实例

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap