//
//	mongo_create.ts
//
//					May/05/2020
//
// ----------------------------------------------------------------
var text_manipulate=require ("/var/www/data_base/common/node_common/text_manipulate")
// ----------------------------------------------------------------
function data_prepare_proc ()
{
	var dict_aa = new Object ()

	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1161','さいたま',93152,'2012-5-14')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1162','所沢',21657,'2012-3-26')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1163','越谷',98421,'2012-8-12')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1164','久喜',37864,'2012-9-18')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1165','熊谷',67358,'2012-7-14')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1166','秩父',51792,'2012-2-12')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1167','川越',38251,'2012-5-15')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1168','和光',54386,'2012-4-20')
	dict_aa = text_manipulate.dict_append_proc (dict_aa,'t1169','新座',26893,'2012-6-24')
	
	return	dict_aa
}

// ----------------------------------------------------------------
const insertDocuments = function(collection,array_aa, callback) {
	collection.insertMany(array_aa,
		function(err, result) {
		assert.equal(err, null)
		console.log("*** Inserted to the collection ***")
		callback(result)
	})
}

// ----------------------------------------------------------------
function loop_insert_proc (dict_aa,collection)
{
	var array_aa = []

	for (var key in dict_aa)
		{
		const name = dict_aa[key].name
		const population = dict_aa[key].population
		const date_mod = dict_aa[key].date_mod
		const unit_aa = {'key': key, 'name': name,
			 'population': population,'date_mod': date_mod}
		array_aa = array_aa.concat(unit_aa)
		}

    console.log("*** check *** ppp ***")

//	console.log(array_aa)

insertDocuments(collection,array_aa, function() {
	console.log ("*** 終了 ***")
	client.close()
	})
}

// ----------------------------------------------------------------
const MongoClient = require('mongodb').MongoClient
const assert = require('assert')
require('dotenv').config()

console.log ("*** 開始 ***")

const user:string = process.env.user
const password:string = process.env.password
const db_name:string = process.env.db
const collection_name:string = process.env.collection

const host = user + ':' + password + '@localhost'
const port = 27017

const dict_aa = data_prepare_proc ()



const url = 'mongodb://' + host + ':' + port
console.log("Connecting to " + host + ":" + port)

const client = new MongoClient(url,
    {useNewUrlParser: true,useUnifiedTopology: true})

client.connect (function(err)
	{
	const db = client.db(db_name)
	db.dropDatabase(function(err, result)
		{
		const collection = db.collection(collection_name)
		collection.deleteOne ({},function (err, result)
			{
			loop_insert_proc (dict_aa,collection)
			})

		})
	})

// ----------------------------------------------------------------