testcassandra.js

'use strict';
var cassandra = require('./libs/cassandra/cql');
var cql = require('./config/index.js').cassandra.cql;
var multiline = require('multiline');
var extend = require('node.extend');
var User = require('libs/cassandra/user');
var Timeseries = require('libs/cassandra/contestA/exports').Timeseries;
var GetTimeseries = require('libs/contestA/exports').GetTimeseries;

/*
User.insert([
  '12000000-0000-0000-0000-000000005eb3',
  'test1@test.com',
  true,
  new Date(),
  'hello1',
  'world',
  'first name',
  'last name',
  20,
  'address',
  'paymentinfo',
  0,
  'fbid',
  0,
  'image'
], function(err) {
  if (err) {
    console.log(err);  
  }
})

var query = 'insert into birds (name, bird) VALUES (?, ?)';
var query = 'select * from birds where name = ?'*/

//var query = 'update test42 set bool1 = false where name = ? if bool1 = false and num1 = 1';
/*
cassandra.queryOneRow(
  query, 
  ['hello'],
  cql.types.consistencies.one, 
  function (err, result) {
    if (err) {
      console.log('fuq');
      console.log(err);
    } 
    else {
      console.log(result);
      //console.log(result['[applied]']);
      if (!result) {
        console.log('yoo');
      }
    }
  }
);*/
/*
cassandra.query(
  query, 
  ['david lu', JSON.stringify({want: {name: {david : 'lu'}}, cracker: 'lu'})],
  cql.types.consistencies.one, 
  function (err, result) {
    if (err) {
      console.log('fuq');
      console.log(err);
    } 
    else {
      console.log('world hello');
    }
  }
);*/
/*
cassandra.queryOneRow(
  query, 
  ['david lu'],
  cql.types.consistencies.one, 
  function (err, result) {
    if (err) {
      console.log(cql.types.dataTypes)
      console.log('fuq');
      console.log(err);
    } 
    else {
      console.log(result);
      console.log(result.name);
      console.log(JSON.parse(result.bird).want);
      console.log('world hello');
    }
  }
);
*/
/*
var hello = {
  0: ['hi', 2],
  1: 'hi1',
  2: 'hi2',
  3: 'hi3'
};*/
/*
(function (callback){
  var a = function(callback) {
    callback('hello world');
  }
  a(function(err) {console.log(err)});
  console.log('a');
  callback();
}(function(err){
  console.log('hello');
}));
*/
/*
var str = JSON.stringify(hello[4]);
console.log(str);
console.log(JSON.parse(str)[0][1]);
*/
/*
var retval = (function() {
  hello = extend(hello, {9 : 'one'});
  var a = function() {
    console.log(hello[0]);
  }
  hello[0] = 2;
  return a;
}());

retval();

var query = 'insert into contest_b (sport, contest_id, athletes) values (?, ?, ?)';

cassandra.query(query, ['soccer', '00000000-0000-0000-0000-000000000000', {value: {1: 'hello'}, hint: 'map'}], cql.types.consistencies.one, function(err) {
  if (err) {
    console.log(err);
  }
})*/
/*
var hello = {
  awayTeam: 'TEST_A',
  awayTeamId: '00000000-0000-0000-0000-000000000000',
  gameDate: (new Date()).getTime(),
  gameId: '00000000-0000-0000-0000-000000000000',
  homeTeam: 'TEST_B',
  homeTeamId: '00000000-0000-0000-0000-000000000001',
}*/
/*
require('./libs/cassandra/contestB/update.js').insert([
  ['John Snow00', 'John Snow01', 'John Snow02', 'John Snow03', 'John Snow04'],
  //athlete_names
  [
    '{"athleteName":"John Snow00",' +
       '"athleteId":"00000000-0000-0000-0000-000000000000",' +
       '"gameContestId":0,"gameId":"00000000-0000-0000-0000-000000000000",' +
       '"isOnHomeTeam":true,' + 
       '"position":"test_pitcher",' +
       '"shortTeamName":"TEST_GOT",' + 
       '"longTeamName":"THE_TEST_GOT", ' +
       '"teamId":"00000000-0000-0000-0000-000000000000"}',
    '{"athleteName":"John Snow01",' +
       '"athleteId":"00000000-0000-0000-0000-000000000001",' +
       '"gameContestId":0,"gameId":"00000000-0000-0000-0000-000000000000",' +
       '"isOnHomeTeam":true,' + 
       '"position":"test_pitcher",' +
       '"shortTeamName":"TEST_GOT",' + 
       '"longTeamName":"THE_TEST_GOT", ' +
       '"teamId":"00000000-0000-0000-0000-000000000000"}',
    '{"athleteName":"John Snow02",' +
       '"athleteId":"00000000-0000-0000-0000-000000000002",' +
       '"gameContestId":0,"gameId":"00000000-0000-0000-0000-000000000000",' +
       '"isOnHomeTeam":true,' + 
       '"position":"test_pitcher",' +
       '"shortTeamName":"TEST_GOT",' + 
       '"longTeamName":"THE_TEST_GOT", ' +
       '"teamId":"00000000-0000-0000-0000-000000000000"}',
    '{"athleteName":"John Snow03",' +
       '"athleteId":"00000000-0000-0000-0000-000000000003",' +
       '"gameContestId":0,"gameId":"00000000-0000-0000-0000-000000000000",' +
       '"isOnHomeTeam":true,' + 
       '"position":"test_pitcher",' +
       '"shortTeamName":"TEST_GOT",' + 
       '"longTeamName":"THE_TEST_GOT", ' +
       '"teamId":"00000000-0000-0000-0000-000000000000"}',
    '{"athleteName":"John Snow04",' +
       '"athleteId":"00000000-0000-0000-0000-000000000004",' +
       '"gameContestId":0,"gameId":"00000000-0000-0000-0000-000000000000",' +
       '"isOnHomeTeam":true,' + 
       '"position":"test_pitcher",' +
       '"shortTeamName":"TEST_GOT",' + 
       '"longTeamName":"THE_TEST_GOT", ' +
       '"teamId":"00000000-0000-0000-0000-000000000000"}'
  ], //athletes
  0,  //commission_earned
  new Date(new Date().getTime() + 1000000), //contest_deadline_time
  null, //contest_end_time
  cql.types.timeuuid(), //contest_id
  'THE_DAILY_PROPHET',
  new Date(), //contest_start_time
  0,  //contest_state
  {}, //contestants
  0, //cooldown_minutes
  0, //current_entries
  2, //entries_allowed_per_contestant
  1000, //entry_fee
  [    '{"awayTeam":"TEST_A",' +
       '"awayTeamId":"00000000-0000-0000-0000-000000000000",' +
       '"gameDate":1403899335204,' +
       '"gameId":"00000000-0000-0000-0000-000000000000",' +
       '"homeTeam":"TEST_B",' +
       '"homeTeamId":"00000000-0000-0000-0000-000000000001"}'
  ],  //games
  false, //isfiftyfifty
  8000,   //max_wager
  3, //maximum_entries
  1, //minimum_entries
  [1.0, 10.0, 11.0, 12.0, 13.0], //pay_outs
  null, //processed_payouts_timestamp
  'TEST_SPORT',  //sport
  10000, //starting_virtual_money
  10  //total_prize_pool
], function (err, result) {
  if (err) {
    console.log(err);
  }
});
*/
//console.log(JSON.stringify(hello));
/*
var hbs = require('hbs');
var express = require('express');
var app = express();
hbs.registerHelper('hello', function(options) {
  return options.fn(this);
});
app.engine('hbs', hbs.__express);
var path = require('path');
app.set('views', path.join(__dirname, './views'));
app.get('/', function(req, res) {
  res.render('hello.hbs', {text: 'ohaiyo sekai'});
});
app.listen(3000);*/

/*var today = new Date();
var date = ('0' + today.getDate()).slice(-2);
var month = ('0' + (today.getMonth() + 1)).slice(-2);
var year = today.getFullYear();
console.log(year);
today = year + '/' + month + '/' + date;

var BaseballGame = require('libs/cassandra/baseball/game');
BaseballGame.insert(
[
  0,
  new Date((new Date()).setHours(23, 59, 59, 999)),
  '00001111-0000-0000-0000-000011110000',
  today,
  0,
  'away',
  'home',
  ['hello', 'world'],
  ['world'],
  'shortAway',
  'shortHome',
  new Date((new Date()).setHours(20, 59, 59, 999)),
  'open'
],
function (err) {
  if (err) {
    console.log(err);
  }
  else {
    console.log('success');
  }
});

BaseballGame.selectTodaysGames(function(err, result) {
  if (err) {
    console.log(err);
  }
  else {
    console.log(result);
  }
});

*/

var hello = [];
for (var i = 0; i !== 100; ++i) {
  hello[i] = i;
}
var async = require('async');

async.parallel(
[
  function(callback) {
    async.reduce(
      hello, 
      {},
      function(memo, index, callback) {
        setTimeout(function() {
          Timeseries.insert(
            '00000000-0000-0000-0000-000000000000', 
            Math.random()*20, 
            index, 
            function(err) {
              callback(null, memo);
            });
        }, 1000);
      },  
      function(err) {
        callback(err);
      })
  },
  function(callback) {
    async.reduce(
      hello, 
      {},
      function(memo, index, callback) {
        setTimeout(function() {
          Timeseries.insert(
            '00000000-0000-0000-0000-000000000001', 
            Math.random()*20, 
            index, 
            function(err) {
              callback(null, memo);
            });
        }, 1000);
      },  
      function(err) {
        callback(err);
      })
  },
  function(callback) {
    async.reduce(
      hello, 
      {},
      function(memo, index, callback) {
        setTimeout(function() {
          Timeseries.insert(
            '00000000-0000-0000-0000-000000000002', 
            Math.random()*20, 
            index, 
            function(err) {
              callback(null, memo);
            });
        }, 1000);
      },  
      function(err) {
        callback(err);
      })
  },
  function(callback) {
    async.reduce(
      hello, 
      {},
      function(memo, index, callback) {
        setTimeout(function() {
          Timeseries.insert(
            '00000000-0000-0000-0000-000000000003', 
            Math.random()*20, 
            index, 
            function(err) {
              callback(null, memo);
            });
        }, 1000);
      },  
      function(err) {
        callback(err);
      })
  },
  function(callback) {
    async.reduce(
      hello, 
      {},
      function(memo, index, callback) {
        setTimeout(function() {
          Timeseries.insert(
            '00000000-0000-0000-0000-000000000004', 
            Math.random()*20, 
            index, 
            function(err) {
              callback(null, memo);
            });
        }, 1000);
      },  
      function(err) {
        callback(err);
      })
  }
],
function(err) {
  console.log(err);
});