nodejs-documents-query-stream.js

/*
* Copyright (c) 2015-2025 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
*/
var should = require('should');
//var should = require('chai').should();

var testconfig = require('../etc/test-config-qa.js');

var marklogic = require('../');
var q = marklogic.queryBuilder;

var db = marklogic.createDatabaseClient(testconfig.restReaderConnection);
var dbWriter = marklogic.createDatabaseClient(testconfig.restWriterConnection);
var dbAdmin = marklogic.createDatabaseClient(testconfig.restAdminConnection);

describe('Document query stream test', function () {
    before(function (done) {
        this.timeout(10000);
        dbWriter.documents.write({
            uri: '/test/query/matchDir/doc1.json',
            collections: ['matchCollection1'],
            contentType: 'application/json',
            content: {
                title: 'Vannevar Bush',
                popularity: 5,
                id: '0011',
                date: '2005-01-01',
                price: {
                    amt: 0.1
                },
                p: 'Vannevar Bush wrote an article for The Atlantic Monthly'
            }
        }, {
            uri: '/test/query/matchDir/doc2.json',
            collections: ['matchCollection1', 'matchCollection2'],
            contentType: 'application/json',
            content: {
                title: 'The Bush article',
                popularity: 4,
                id: '0012',
                date: '2006-02-02',
                price: {
                    amt: 0.12
                },
                p: 'The Bush article described a device called a Memex'
            }
        }, {
            uri: '/test/query/matchDir/doc3.json',
            collections: ['matchCollection2'],
            contentType: 'application/json',
            content: {
                title: 'For 1945',
                popularity: 3,
                id: '0013',
                date: '2007-03-03',
                price: {
                    amt: 1.23
                },
                p: 'For 1945, the thoughts expressed in the Atlantic Monthly were groundbreaking'
            }
        }, {
            uri: '/test/query/matchDir/doc4.json',
            collections: [],
            contentType: 'application/json',
            content: {
                title: 'Vannevar served',
                popularity: 5,
                id: '0024',
                date: '2008-04-04',
                price: {
                    amt: 12.34
                },
                p: 'Vannevar served as a prominent policymaker and public intellectual'
            }
        }, {
            uri: '/test/query/matchList/doc5.json',
            collections: ['matchList'],
            contentType: 'application/json',
            content: {
                title: 'The memex',
                popularity: 5,
                id: '0026',
                date: '2009-05-05',
                price: {
                    amt: 123.45
                },
                p: 'The Memex, unfortunately, had no automated search feature'
            }
        }).
            result(function (response) {
                done();
            }, done);
    });

    it('should do word query', function (done) {
        db.documents.query(
            q.where(
                q.word('title', 'vannevar bush')
            )
        ).
            stream().
            on('data', function (data) {
                data.content.id.should.equal('0011');
            }).
            on('end', function () {
                done();
            }, done);
    });

    it('should do simple parse', function (done) {
        db.documents.query(
            q.where(
                q.parsedFrom('intitle:"The memex"',
                    q.parseBindings(
                        q.value('title', q.bind('intitle'))
                    )
                )
            )
        ).
            stream().
            on('data', function (data) {
                data.content.id.should.equal('0026');
            }).
            on('end', function () {
                done();
            }, done);
    });

    it('should do extract with include-with-ancestors', function (done) {
        db.documents.query(
            q.where(
                q.word('title', '1945')
            ).
                slice(1, 10,
                    q.extract({
                        selected: 'include-with-ancestors',
                        paths: [
                            '/node("id")'
                        ]
                    })
                )
        ).
            stream().
            on('data', function (data) {
                //console.log(data);
                data.content.id.should.equal('0013');
            }).
            on('end', function () {
                done();
            }, done);
    });

    it('should do collections query', function (done) {
        var count = 0;
        var str = '';
        var chunks = [];
        db.documents.query(
            q.where(
                q.collection('matchCollection1')
            )
                .slice(0, 5)
        )
            .stream()
            .on('data', function (chunk) {
                count++;
            })
            .on('end', function () {
                //console.log(count);
                count.should.equal(2);
                done();
            }, done);
    });

    it('should delete all documents', function (done) {
        dbAdmin.documents.removeAll({
            all: true
        }).
            result(function (response) {
                done();
            }, done);
    });

});