rbdc-mysql 4.6.0

use crate::options::MySqlConnectOptions;
use futures_core::future::BoxFuture;
use rbdc::db::{ConnectOptions, Connection, Driver, Placeholder};
use rbdc::Error;

#[derive(Debug)]
pub struct MysqlDriver {}

impl Driver for MysqlDriver {
    fn name(&self) -> &str {
        "mysql"
    }

    fn connect(&self, url: &str) -> BoxFuture<Result<Box<dyn Connection>, Error>> {
        let url = url.to_owned();
        Box::pin(async move {
            let mut opt = self.default_option();
            opt.set_uri(&url)?;
            if let Some(opt) = opt.downcast_ref::<MySqlConnectOptions>() {
                let conn = opt.connect().await?;
                Ok(Box::new(conn) as Box<dyn Connection>)
            } else {
                Err(Error::from("downcast_ref failure"))
            }
        })
    }

    fn connect_opt<'a>(
        &'a self,
        opt: &'a dyn ConnectOptions,
    ) -> BoxFuture<'a,Result<Box<dyn Connection>, Error>> {
        let opt: &MySqlConnectOptions = opt.downcast_ref().unwrap();
        Box::pin(async move {
            let conn = opt.connect().await?;
            Ok(conn)
        })
    }

    fn default_option(&self) -> Box<dyn ConnectOptions> {
        Box::new(MySqlConnectOptions::default())
    }
}

impl Placeholder for MysqlDriver {
    fn exchange(&self, sql: &str) -> String {
        sql.to_string()
    }
}

#[cfg(test)]
mod test {
    #[test]
    fn test_default() {
        assert_eq!(true, true);
    }
}
// #[cfg(test)]
// mod test {
//     use crate::driver::MysqlDriver;
//     use rbdc::block_on;
//     use rbdc::db::Driver;
//     use rbdc::pool::Pool;
//     use rbs::{value, Value};
//     use std::collections::BTreeMap;
//
//     #[test]
//     fn test_mysql_pool() {
//         let task = async move {
//             let pool =
//                 Pool::new_url(MysqlDriver {}, "mysql://root:123456@localhost:3306/test").unwrap();
//             std::thread::sleep(std::time::Duration::from_secs(2));
//             let mut conn = pool.get().await.unwrap();
//             let data = conn
//                 .get_values("select * from sys_dict where code = ?", vec![Value::String("111".to_string())])
//                 .await
//                 .unwrap();
//             for mut x in data {
//                 println!("row: {}", x);
//             }
//         };
//         block_on!(task);
//     }
//
//     #[test]
//     fn test_mysql_rows() {
//         let task = async move {
//             let mut d = MysqlDriver {};
//             let mut c = d
//                 .connect("mysql://root:123456@localhost:3306/test")
//                 .await
//                 .unwrap();
//             let data = c
//                 .get_values("select * from sys_dict", vec![])
//                 .await
//                 .unwrap();
//             for mut x in data {
//                 println!("row: {}", x);
//             }
//         };
//         block_on!(task);
//     }
//
//     //
//     // #[tokio::test]
//     // async fn test_mysql_count() {
//     //     let mut d = MysqlDriver {};
//     //     let mut c = d
//     //         .connect("mysql://root:123456@localhost:3306/test")
//     //         .await
//     //         .unwrap();
//     //     let data = c
//     //         .exec(
//     //             "update biz_activity set pc_link = '111' where id  = '1'",
//     //             vec![],
//     //         )
//     //         .await
//     //         .unwrap();
//     //     println!("{}", data);
//     // }
//     //
//
//     #[test]
//     fn test_mysql_param() {
//         let task = async move {
//             let mut d = MysqlDriver {};
//             let mut c = d
//                 .connect("mysql://root:123456@localhost:3306/test")
//                 .await
//                 .unwrap();
//             let param = vec![
//                 Value::String("http://www.test.com".to_string()),
//                 Value::U64(1658848837828).into_ext("Timestamp"),
//                 Value::String("12312".to_string()),
//             ];
//             println!("param => {}", Value::Array(param.clone()));
//             let data = c
//                 .exec(
//                     "update biz_activity set pc_link = ?,create_time = ? where id  = ?",
//                     param,
//                 )
//                 .await
//                 .unwrap();
//             println!("{}", data);
//         };
//         block_on!(task);
//     }
//     #[test]
//     fn test_count() {
//         let task = async move {
//             let mut d = MysqlDriver {};
//             let mut c = d
//                 .connect("mysql://root:123456@localhost:3306/test")
//                 .await
//                 .unwrap();
//             let param = vec![
//             ];
//             let data = c
//                 .get_values(
//                     "select count(1) as count from sys_dict where id!='' order by create_date",
//                     param,
//                 )
//                 .await
//                 .unwrap();
//             println!("{:?}", data);
//         };
//         block_on!(task);
//     }
//
//     #[test]
//     fn test_insert() {
//         let task = async move {
//             let mut d = MysqlDriver {};
//             let mut c = d
//                 .connect("mysql://root:123456@localhost:3306/test")
//                 .await
//                 .unwrap();
//             let param:Vec<Value> = vec![
//                 "111".into(),
//                 "111".into(),
//                 "111".into()
//                 ,1.into(),
//                  Value::Ext("DateTime",Box::new("2022-08-07 21:33:59".into()))
//             ];
//             let data = c
//                 .exec(
//                     "insert into sys_dict (id,name,code,state,create_date) VALUES (?,?,?,?,?)",
//                     param,
//                 )
//                 .await
//                 .unwrap();
//             println!("{:?}", data);
//         };
//         block_on!(task);
//     }
// }