function saveMessage(content) {
	var body;

	var id = 0;
	var conn = $.db.getConnection(conSQLConnection);
	conn.prepareStatement("SET SCHEMA " + conSchema).execute(); // Setting the SCHEMA

	var pStmt = conn.prepareStatement('select max( "id" ) from "' + conMessageTable + '"');
	var rs = pStmt.executeQuery();
	if (rs.next()) {
		id = Number(rs.getNString(1)) + 1;
	}
	rs.close();

	pStmt = conn.prepareStatement('insert INTO "'+conMessageTable+'"("id", "createdTime", "content") values(?, now(), ?)');
	pStmt.setInteger(1, id);
	pStmt.setNString(2, JSON.stringify(content));
	pStmt.executeUpdate();
	pStmt.close();

	var i = 0;
	if(content.result && content.result.length > 0) {
		for(i = 0; i < content.result.length; i++) {
			createEvent(conn, id, content.result[i]);
		}
	}

	// All database changes must be explicitly commited
	conn.commit();

	$.response.status = $.net.http.OK;
	body = {
			id: id,
			info: "Success!"
		};

	if (conn) {
		conn.close();
	}
	return body;
}

function createEvent(conn, id, event) {

	var pStmt, mid, toMid, j, persons;

	toMid = event.to[0];

	pStmt = conn.prepareStatement('INSERT INTO "'+conEventTable+'"("message", "id", "createdTime", "eventType", "fromUser.id", "toUser.id", "content") values(?, ?, ?, ?, ?, ?, ?)');
	pStmt.setInteger(1, id);
	pStmt.setNString(2, event.id);
	if(event.createdTime) {
		pStmt.setTimestamp(3, new Date(event.createdTime) );
	}else {
		pStmt.setNull(3);
	}
	pStmt.setNString(4, event.eventType);
	pStmt.setNString(5, event.from);
	pStmt.setNString(6, toMid);
	pStmt.setNString(7, JSON.stringify(event));

	pStmt.executeUpdate();
	pStmt.close();

	if(event.content.params) {
		for(j = 0; j < event.content.params.length; j++) {
			mid = event.content.params[j];
			if(!mid) {
				continue;
			}
			createSubscriber(conn, event.id, mid);
		}
	}

	if(event.content.from) {
		createSubscriber(conn, event.id, event.content.from);
	}

	if(event.to && event.to.length) {
	    createUser(conn, event, event.to[0]);
	}
}

function createSubscriber(conn, event, mid) {
	var pStmt = conn.prepareStatement('INSERT INTO "'+conSubscriberTable+'"("event", "user.id") values(?, ?)');
	pStmt.setNString(1, event);
	pStmt.setNString(2, mid);
	pStmt.executeUpdate();
	pStmt.close();

	createUser(conn, event, mid);
}

function createUser(conn, event, mid) {
	var pStmt;
	pStmt = conn.prepareStatement('UPDATE "' + conUserTable + '" set "displayName" = ?, "pictureUrl" = ?, "statusMessage" = ? where "id" = ?');
	pStmt.setNString(1, 'tiven');
	pStmt.setNString(2, 'http://tiven.wang');
	pStmt.setNString(3, '');
	pStmt.setNString(4, mid);
	var update = pStmt.executeUpdate();
	pStmt.close();

	if(!update) {
		pStmt = conn.prepareStatement('INSERT INTO "'+conUserTable+'"("id", "displayName", "pictureUrl", "statusMessage") values(?, ?, ?, ?)');
		pStmt.setNString(1, mid);
		pStmt.setNString(2, 'tiven');
		pStmt.setNString(3, 'http://tiven.wang');
		pStmt.setNString(4, '');
		update = pStmt.executeUpdate();
		pStmt.close();
	}
}

{
  "result": [
    {
      "from": "u206d25c2ea6bd87c17655609a1c47cb8",
      "fromChannel": 1341301815,
      "to": [
        "u93892c0a44ffce86e7b5cb67ecc55677"
      ],
      "toChannel": 1480700431,
      "eventType": "138311609000106303",
      "id": "ABCDEF-12345678903",
      "content": {
        "id": "1234567890123",
        "contentType": 1,
        "from": "Line",
        "createdTime": 1476083982493,
        "to": [
          "u93892c3a44ffce86e7b5cb67edc55677"
        ],
        "toType": 1,
        "contentMetadata": null,
        "text": "Hello,world!",
        "location": null
      }
    }
  ]
}

let	conSchema = "DigAcc",
	conMessageTable = "digital-account.data::DigAccMessage.Message";

function createMessage(param) {

	let before = param.beforeTableName;
	let after = param.afterTableName;

	let content = "";
	let pStmt = param.connection.prepareStatement('select "content" from "' + after +'"');
	var rs = pStmt.executeQuery();
	if (rs.next()) {
		content = rs.getNString(1);
		$.trace.error(JSON.stringify(content));
	}
	rs.close();
	pStmt.close();

	let id = 0;
	pStmt = param.connection.prepareStatement('select max( "id" ) from "'+conSchema+'"."'+ conMessageTable + '"');
	rs = pStmt.executeQuery();
	if (rs.next()) {
		id = Number(rs.getNString(1)) + 1;
	}
	rs.close();
	pStmt.close();

	pStmt = param.connection.prepareStatement('insert into "'+conMessageTable+'"("id", "createdTime", "content") values(?, now(), ?)');
	pStmt.setInteger(1, id);
	pStmt.setNString(2, content);
	pStmt.executeUpdate();
	pStmt.close();
}