Top 9 Examples of "massive in functional component" in JavaScript

});
// console.log(object)
}
// ------------------------------------------
// Sends a notification to all clients
// ------------------------------------------
var notify           = function (request,res,next) {
   console.log('_____________________');
   console.log('Forced change notification');
   io.emit("change");
}
// ******************************************
//                PostgreSQL
// ******************************************
var connectionString = "postgres://"+config.postgres.user+":"+config.postgres.password+"@"+config.postgres.host+"/"+config.postgres.db;
var massiveInstance  = massive.connectSync({connectionString : connectionString});
var db;
var pgClient         = new pg.Client(connectionString);
pgClient.connect();
pgClient.query('LISTEN "changes"');
pgClient.on('notification', function(data) {
   console.log('_____________________');
   console.log('Change notification');
   io.emit("change");
});
// ******************************************
//             Express Setup
// ******************************************
// Data parsing
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true }));
// Define API routes

var config				= require('./config.json');
// ******************************************
//		Install NodeJS Dependencies
// ******************************************
// Express
var express				= require('express');
// Serve-Static 
var serveStatic			= require('serve-static');
// Body-Parser
var bodyParser			= require('body-parser');
// Multer
var multer				= require('multer');
// PostgreSQL
var massive				= require("massive");
var connectionString	= "postgres://"+config.postgres.user+":"+config.postgres.password+"@"+config.postgres.host+"/"+config.postgres.db;
var massiveInstance		= massive.connectSync({connectionString : connectionString});
var db;
// ******************************************
//					Initialize
// ******************************************
var app					= express();
var startExpress		= function() {
    app.listen(config.express.port);
	db = app.get('db');
	console.log('_____________________');
	console.log('HTTP and API server online')
    console.log('Listening on port '+config.express.port);
	console.log('_____________________');
}
var initialize 			= function() {
	startExpress()
}

//  name: data.datasetName,
    //key: data.key,
    //schemeGenes: data['fileProfile_headers'],
    //metadata: data['fileMetadata_headers'],
    //profiles: data.fileProfile,
    //isolates: data.fileMetadata,
    //positions: {},
    //newick: data.fileNewick
  //});

  //instance.save(function(e){
    //console.log('saved');
    //callback();
  //});
  
  massive.connect({
    db: "phyloviz"}, function(err, db){
    db.saveDoc("datasets", instance, function(err,res){ console.log('done'); });
    callback();
  });
}

import * as Massive from 'massive';

Massive.connect({connectionString: 'foo'}, (err: Error, db: Massive.Massive) => {});

Massive.run('foo', 123, (err: Error, db: Massive.Massive) => {});

connect() {
    this.db_url = config.get('db_url')
    if (!this.db_url) {
      throw new Error('Could not find db connection string')
    }
    this.connection = massive.connectSync({connectionString: this.db_url})
  }

var express = require('express');
var bodyParser = require('body-parser');
var cors = require('cors');
var massive = require('massive');
var connectionString = "postgress://jameslemire@localhost/sandbox";
var massiveInstance = massive.connectSync({connectionString : connectionString});
var config = require('./config.js');

var app = module.exports = express();
app.set('db', massiveInstance);

var peopleCtrl = require('./controller/peopleCtrl.js');

app.use(cors(config.corsOptions));
app.use(bodyParser.json());
app.use(express.static('../public'));

app.post('/api/people', peopleCtrl.createPerson);
app.get('/api/people', peopleCtrl.readPeople);
app.put('/api/person/:personId', peopleCtrl.updatePerson);
app.delete('/api/person/:personId', peopleCtrl.deletePerson);

protected async setup(): Promise {
    if (this.initialized) {
      return
    }

    try {
      this.massiveInstance = await massive(this.massiveConfig)
      if (this.enablePgMonitor) {
        await pgMonitor.attach(this.massiveInstance.driverConfig)
      }
      this.db = this.massiveInstance[this.dbSchema]
      await this.addDbIndex('action_trace', 'transaction_id', 'transaction_id_idx1')
      await this.addDbIndex('action_trace_authorization', 'transaction_id', 'transaction_id_idx2')
    } catch (err) {
      throw new NotInitializedError('', err)
    }
  }

const init = async () => {
  const db = await massive(dbConfig)
  loop(db[dbConfig.schema], db)
}

const init = async () => {

  const db = await massive(dbConfig)

  const actionHandler = new MassiveActionHandler(
    updaters,
    effects,
    db,
    dbConfig.schema,
  )

  const inlineListeners = [
    "eoslocal::greet",
  ]

  const actionReader = new MongoActionReader(
    MONGO_URI,
    INITIAL_BLOCK,
    false,