'use strict';

const mysqlx = require('@mysql/xdevapi');

mysqlx
    .getSession({
        dbPassword: '<passwd>',
        dbUser: 'root',
        host: 'localhost',
        port: 33060
    })
    .then(session => {
        console.log('A new session has been created.');

        return session
            .createSchema('mySchema')
            .then(schema => ({ schema, session }))
    })
    .then(ctx => {
        console.log('The schema has been created.');

        return ctx.schema
            .createCollection('myCollection')
            .then(collection => Object.assign(ctx, { collection }))
    })
    .then(ctx => {
        console.log('The collection has been created.')

        return Promise
            .all([
                ctx.collection
                    .add({ baz: { foo: 'bar' } }, { foo: { bar: 'baz' } })
                    .execute()
                    .then(() => {
                        console.log('The documents where added to the collection.');
                    }),
                ctx.collection
                    .find('baz.foo = "bar"')
                    .execute(row => {
                        console.log('A row has been found: %j', row);
                    })
                    .then(() => {
                        console.log('The collection find operation has finished.');
                    }),
                ctx.collection
                    .remove('foo.bar = "baz"')
                    .execute()
                    .then(() => {
                        console.log('The document has been removed from the collection.');
                    }),
                ctx.schema
                    .dropCollection('myCollection')
                    .then(() => {
                        console.log('The collection has been deleted.');
                    })
            ])
            .then(() => ctx)
    })
    .then(ctx => {
        return ctx.session
            .dropSchema('mySchema')
            .then(() => ctx);
    })
    .then(ctx => {
        console.log('The schema has been deleted.');

        return ctx.session.close();
    })
    .then(() => {
        console.log('The session has been closed.');
        process.exit(0);
    })
    .catch(err => {
        console.log(err.stack);
        process.exit(1);
    });