Updated to Chapel 1.21

Makefile

@@ -29,7 +29,7 @@ pgsql:
 
 #WArning, you should run `mysql_config --cflags --libs` in order to know the library path
 mysqlex:
-	chpl -o ./bin/mysqlex ./example/exmysql.chpl ./src/mysql_helper.c ./src/mysql_helper.c    -M ./src -I./src -I/usr/include/mysql -L/usr/lib/x86_64-linux-gnu -lmysqlclient -lpthread -lz -lm -lrt -latomic -ldl
+	chpl -o ./bin/mysqlex ./example/exmysql.chpl ./src/mysql_helper.c ./src/mysql_helper.c    -M ./src -I./src -I/usr/include/mysql -L/usr/lib/x86_64-linux-gnu -lmysqlclient -lpthread -lz -lm -lrt -latomic -lssl -lcrypto -ldl
 
 update_mysql_ex:
 	chpl -o ./bin/update_mysql_ex ./example/update_mysql_ex.chpl  -M ./src  ./src/mysql_helper.c -I./src -I/usr/include/mysql -L/usr/lib/x86_64-linux-gnu -lmysqlclient -lpthread -lz -lm -lrt -latomic -ldl

Mason.lock

@@ -0,0 +1,8 @@
+
+[root]
+name = "Cdo"
+version = "0.1.1"
+chplVersion = "1.20.0..1.20.0"
+authors = ["Marcos Cleison Silva Santana <[email protected]>"]
+
+

README.md

@@ -22,11 +22,15 @@ On Ubuntu do:
 sudo apt-get install libpq-dev
 ```
 3. Go to example/expq.chpl and inform database host, user, password. 
-4. Go to repository folder and compile:
+4. Import database
+```bash
+psql teste < postgreData.sql 
+```
+5. Go to repository folder and compile:
 ```bash
 make pgsql
 ```
-5. Run the example:
+6. Run the example:
 ```bash
 ./expq
 ```
@@ -117,8 +121,8 @@ var cursor = con.cursor();
 //Queries from database
 cursor.query("SELECT * FROM contacts");
 //Get one row.
-var res:Row = cursor.fetchone();
-while(res.isValid()){
+var res: Row? = cursor.fetchone();
+while(res != nil){
 //print the results.
 writeln(res);
 //get the next row one.

example/exmysql.chpl

@@ -12,23 +12,33 @@ proc main(){
         //Queries from database
         cursor.query("SELECT * FROM contacts"); 
         //Get one row.
-        var res: Row = cursor.fetchone();
-        while(res.isValid()){
+        var res: Row? = cursor.fetchone();
+        if(res != nil) {
+            try! {
+            const r = res: shared Row;
+            writeln("name = ", r["name"]," email = ", r["email"] );
+            }
+        }
+        while(res != nil){
             //print the results.
             writeln(res);
+
             //get the next row one.
             res = cursor.fetchone();
+
         }
 
         // Queries passing tuple to formated query string.
         cursor.query("SELECT %s, %s FROM contacts",("email","name"));
         // writeln(cursor);
         // iterate over all rows
-        for row in cursor{
+        for row in cursor {
+            res = row;
             //get row data by column name and print it.
             writeln("name = ", row["name"]," email = ", row["email"] );
         }
-
+        writeln("Checking ");
+        writeln("name = ", res!["name"]," email = ", res!["email"] );
         cursor.query("SELECT * FROM contacts");
 
         // iterate over all rows

example/expq.chpl

@@ -13,8 +13,8 @@ module Main{
         //Queries from database
         cursor.query("SELECT * FROM public.contacts"); 
         //Get one row.
-        var res: Row = cursor.fetchone();
-        while(res.isValid()) {
+        var res: Row? = cursor.fetchone();
+        while(res != nil) {
             //print the results.
             writeln(res);
             //get the next row one.

example/update_pg_ex.chpl

@@ -1,6 +1,7 @@
 module Main{
 use Cdo;
 use Postgres;
+use Map;
 
 proc main(){
     //Open connection with Postgres database. Parametrs are host,username, database, password

mysqlData.sql

@@ -1,8 +1,9 @@
-CREATE TABLE IF NOT EXISTS "contacts" (
-	`id`	INTEGER PRIMARY KEY AUTOINCREMENT,
-	`name`	TEXT,
-	`email`	TEXT,
-	`age`	INTEGER
+CREATE TABLE IF NOT EXISTS contacts (
+  `id` INTEGER PRIMARY KEY AUTO_INCREMENT,
+  `name` TEXT,
+  `email` TEXT,
+  `age` INTEGER
 );
+
 INSERT INTO contacts VALUES(1,'Marcos','[email protected]',35);
 INSERT INTO contacts VALUES(2,'Paulo','[email protected]',28);