merged Fiedzia initial mysql support, added examples for mysql

Author: jcesar

Cargo.lock

@@ -31,3 +31,4 @@ rusqlite = "*"
 time = "*"
 r2d2 = "*"
 r2d2_postgres = "*"
+mysql = "*"

Cargo.toml

@@ -0,0 +1,15 @@
+## connecting to mysql
+
+mysql -u root -h localhost -p
+
+
+create user 'test'@'localhost' identified by 'test';
+
+create user 'bazaar'@'localhost' identified by 'b4z44r';
+
+SET PASSWORD FOR 'test'@'localhost' = password('test');
+
+ create database bazaar_v6;
+ 
+ 
+ GRANT SELECT,INSERT,UPDATE,DELETE,CREATE,DROP on bazaar.* to 'bazaar'@'localhost';

MySQL.md

@@ -40,7 +40,7 @@ impl IsDao for Photo{
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(&url, 1);
-    let db = pool.connect().unwrap();
+    let mut db = pool.connect().unwrap();
 
     let mut query = Query::select_all();
 
@@ -60,7 +60,7 @@ fn main(){
         .asc("product.name")
         .desc("product.created")
         ;
-    let frag = query.build(db.as_ref());
+    let frag = query.build(db.as_ref_mut());
 
     let expected = "
 SELECT *

examples/complex_query.rs

@@ -13,11 +13,11 @@ use rustorm::pool::ManagedPool;
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(&url, 1);
-    let db = pool.connect().unwrap();
+    let mut db = pool.connect().unwrap();
     match Query::delete()
         .from_table("bazaar.category")
             .filter("name", Equality::LIKE, &"Test%")
-        .execute(db.as_ref()){
+        .execute(db.as_ref_mut()){
 
         Ok(x) => println!("deleted {}", x),
         Err(e) => println!("Error {}", e)

examples/delete_category.rs

@@ -66,11 +66,11 @@ impl IsTable for Product{
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(url, 1);
-    let db = pool.connect();
+    let mut db = pool.connect();
 
     match db{
-            Ok(db) => {
-            show_product(db.as_ref());//borrow a database
+            Ok(mut db) => {
+            show_product(db.as_ref_mut());//borrow a database
          }
         Err(e) => {
             println!("Unable to connect to database {}", e);
@@ -79,7 +79,7 @@ fn main(){
 }
 
 /// a dispatched controller with an accesss to a database reference
-fn show_product(db: &Database){
+fn show_product(db: &mut Database){
     let prod: Product = Query::select_all()
         .from_table("bazaar.product")
         .filter("name", Equality::EQ, &"GTX660 Ti videocard")

examples/formal_usage.rs

@@ -94,8 +94,8 @@ impl IsTable for Product{
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(&url, 1);
-    let db = pool.connect().unwrap();
-    let em = EntityManager::new(db.as_ref());
+    let mut db = pool.connect().unwrap();
+    let mut em = EntityManager::new(db.as_ref_mut());
 
     let pid = Uuid::parse_str("6db712e6-cc50-4c3a-8269-451c98ace5ad").unwrap();
     let prod: Product = em.get_exact(&pid).unwrap();

examples/get_exact_record.rs

@@ -55,7 +55,7 @@ impl IsTable for Photo{
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(url, 1);
-    let db = pool.connect().unwrap();
+    let mut db = pool.connect().unwrap();
 
     let photo: Photo = Query::select_all()
                         .column("photo.url")
@@ -65,7 +65,7 @@ fn main(){
                         .left_join_table("bazaar.photo",
                             "product_photo.photo_id", "photo.photo_id")
                         .filter("product.name", Equality::EQ, &"GTX660 Ti videocard")
-                        .collect_one(db.as_ref()).unwrap();
+                        .collect_one(db.as_ref_mut()).unwrap();
 
     println!("photo: {} {}",photo.photo_id, photo.url.unwrap());
 }

examples/get_one_product_photo.rs

@@ -7,10 +7,10 @@ use rustorm::pool::ManagedPool;
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(&url, 1);
-    let db = pool.connect().unwrap();
+    let mut db = pool.connect().unwrap();
 
         Query::insert()
             .set("name", &"Test Category112")
         .into_table(&"bazaar.category")
-            .execute(db.as_ref());
+            .execute(db.as_ref_mut());
 }

examples/insert_category.rs

@@ -106,12 +106,12 @@ impl IsTable for Category{
 fn main(){
     let url = "postgres://postgres:p0stgr3s@localhost/bazaar_v6";
     let mut pool = ManagedPool::init(&url, 1);
-    let db = pool.connect().unwrap();
+    let mut db = pool.connect().unwrap();
 
     let category: Category = Query::insert()
             .set("name", &"Test Category12121")
         .into_table(&"bazaar.category")
             .return_all()
-            .collect_one(db.as_ref()).unwrap();
+            .collect_one(db.as_ref_mut()).unwrap();
     println!("category: {}", category.name.unwrap());
 }

examples/insert_category_with_return.rs

@@ -77,18 +77,18 @@ fn main(){
     let mut pool = Arc::new(Mutex::new(ManagedPool::init(url, 5)));
     for i in 0..3000{
     	let pool = pool.clone();
-        let db: Platform = pool.lock().unwrap().connect().unwrap();//important to obtain a connection before opening a thread
+        let mut db: Platform = pool.lock().unwrap().connect().unwrap();//important to obtain a connection before opening a thread
         thread::spawn(move || {
                 println!("spawning thread {}", i);
-                show_product(db.as_ref());//borrow a database
+                show_product(db.as_ref_mut());//borrow a database
         });
     }
      thread::sleep_ms(5000);
 }
 
 
 /// a dispatched controller with an accesss to a database reference
-fn show_product(db: &Database){
+fn show_product(db: &mut Database){
     let prod: Product = Query::select_all()
         .from_table("bazaar.product")
         .filter("name", Equality::EQ, &"GTX660 Ti videocard")