/**
* Name:  Simple Species MySql
* Author: Truong Minh Thai
* Description:  This model illustrates the use of the AgentDB species (instead of the SQLSKILL), and in particular following actions:
* 
 *    - testConection
 * 
 *    - isConnected
 * 
 *    - close 
 * 
 *    - executeUpdate
 * 
 *    - insert
 * 
 *    - select
 * 
 *    - getParameter 
 * 
 * 
 *  This model does SQl query commands:
 * 
 * - Create table 
 * 
 * - Insert data
 * 
 * - Select data
 * 
 * - Delete data
 * 
 * - Drop table 
 * 
 * 
 *  NOTE: YOU SHOULD HAVE ALREADY CREATED YOUR DATABASE (testDB here) AND IMPORTED THE FILE (../includes/meteo_DB_dump.sql)
 *        IN ORDER THAT THE MODEL CAN RUN PROPERLY.
* Tags: database
 */
model simpleSQL_DBSpecies_MySQL

global {
	map PARAMS <- ['host'::'localhost', 'dbtype'::'mysql', 'database'::'testDB', 'port'::'8889', 'user'::'root', 'passwd'::'root'];
	init {
		write "This model will work only if MySQL database server is installed and launched," color: #red;
		write "and if the database testDB has been created." color: #red;
		
		create DB_Accessor number: 1 {
			if ( testConnection (params::PARAMS) = false) {
				write "Impossible connection";
			} else {
				write "Connection of " + self;
				do connect params: PARAMS;
			}

		}

		if (!first(DB_Accessor).isConnected()) {
			write "No connection.";
			ask (DB_Accessor) {
				do close;
			}

			do pause;
		} else {
			write "  with parameters: " + first(DB_Accessor).getParameter();
			write "";		
		}

		ask (DB_Accessor) {
			do executeUpdate updateComm: "DROP TABLE IF EXISTS registration";		
			do executeUpdate updateComm: "CREATE TABLE registration" + "(id INTEGER PRIMARY KEY, " + " first TEXT NOT NULL, " + " last TEXT NOT NULL, " + " age INTEGER);";
			write "REGISTRATION table has been created.";
			do executeUpdate updateComm: "INSERT INTO registration " + "VALUES(100, 'Zara', 'Ali', 18);";
			do executeUpdate updateComm: "INSERT INTO registration " + "VALUES(?, ?, ?, ?);" values: [101, 'Mr', 'Mme', 45];
			do insert into: "registration" values: [102, 'Mahnaz', 'Fatma', 25];
			do insert into: "registration" columns: ["id", "first", "last"] values: [103, 'Zaid tim', 'Kha'];
			do insert into: "registration" columns: ["id", "first", "last"] values: [104, 'Bill', 'Clark'];
			write "Five records have been inserted.";
			write "Click on <> button to view selected data";
		}

	}

}

species DB_Accessor parent: AgentDB {
	reflex select {
		list t <- list (select (select::"SELECT * FROM registration"));
		write "Select before updated " + t;
	}

	reflex update {
		do executeUpdate updateComm: "UPDATE registration SET age = 30 WHERE id IN (100, 101)";
		do executeUpdate updateComm: "DELETE FROM registration where id=103 ";
		list t <- list (select("SELECT * FROM registration"));
		write "Select after updated " + t;
	}

	reflex drop {
		do executeUpdate updateComm: "DROP TABLE registration";
		write "Registration table has been dropped." color: #red;
		write "Another simulation step will throw an exception as the database is not available anymore." color: #red;
	}
}

experiment simple_SQL_exp type: gui {}