/**
* 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)
* 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)) {
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 * 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 {}