因为是复刻Java系的Mybatis，因此框架暂命名 Rbatis。小部分功能还在进行中。github链接https://github.com/rbatis/rbatis

• 1 框架必须支持异步（future）, 想象一下，假设我们执行N多条慢sql，那么很有可能耗尽线程池资源造成等待。因为协程或者说纤程只消耗几kb而且可以启动成百上千甚至上万条，并发更高。
• 为了节省时间，支持future网络部分拷贝sqlx-core（注意sqlx框架大量使用宏 ，近乎偏执的使用编译期生成代码，这导致代码智能提示基本不起作用，这不是我想要的）部分基础的网络实现代码。
• 因为Rust语言本身中立，可以选择例如Tokio（Actor模型），Async_Std（Actor模型）,may(CSP模型和go类似，但其作者使用了固定容量的栈内存空间，有可能造成内存溢出，笔者暂时不考虑它。如果未来他能解决的话...)。考虑到框架必须尽可能低开销，高并发，默认支持了Tokio和AsyncStd. 目前使用Tokio系web框架的性能似乎是除了C++以外性能最高的并发框架，可以参考国外权威web框架性能评测网站

• 既然支持future，那么框架必须支持跨协程共享，且跨协程修改（mut）。我们可以使用lazy_static 这个库保证框架可以被任意协程使用。但是，lazy_static 包裹的变量必须实现了Rust官方接口 Send和Sync，即保证是线程、协程安全竞争并发的。
• 笔者首先尝试使用rust std库的线程Mutex锁，也就是线程互斥锁(肯定不是最佳方案)
• 1代码部分

struct Rbatis{
pub map:HashMap<String, Data>
}
pub fn query(&mut self, sql: &str){
//......
}
}
lazy_static! {
//全局变量
static ref RB:Mutex<Rbatis>=Mutex::new(Rbatis::new());
}

• 2代码部分

 RB.lock().unwrap().query("select * from table");

use tokio::sync::Mutex;#[derive(Debug)]pub struct SyncMap<T> {    pub cell: Mutex<RefCell<HashMap<String, T>>>}
impl<T> SyncMap<T> {    pub fn new() -> SyncMap<T> {        SyncMap {            cell: Mutex::new(RefCell::new(HashMap::new()))        }    }
    /// put an value,this value will move lifetime into SyncMap    pub async fn put(&self, key: &str, value: T) {        let lock = self.cell.lock().await;        let mut b = lock.borrow_mut();        b.insert(key.to_string(), value);      //函数结尾 lock锁即可释放，因此不管是put还是pop，锁定的时间都是比较小的。而且锁定是依赖tokio运行时调度，而不是线程阻塞    }
    /// pop value,lifetime will move to caller    pub async fn pop(&self, key: &str) -> Option<T> {        let lock = self.cell.lock().await;        let mut b = lock.borrow_mut();        return b.remove(key);    }}

pub struct Rbatis<'r> { context_tx: SyncMap<Transaction<PoolConnection<MySqlConnection>>>, }
impl Rbatis{
//这里我们可以看到，使用SyncMap既可以修改context上下文，又不必吧&self改为&mut self。即保证了并发安全和性能
pub async fn begin(&self, tx_id: &str) -> Result<u64, rbatis_core::Error> { if tx_id.is_empty() { return Err(rbatis_core::Error::from("[rbatis] tx_id can not be empty")); } let conn = self.get_pool()?.begin().await?; self.context_tx.put(tx_id, conn).await; return Ok(1); }
}

fn decode_json<T>(&mut self) -> BoxFuture<Result<T, crate::Error>>    where T: DeserializeOwned {    Box::pin(async move {        let mut arr = vec![];        while let Some(row) = self.next().await? as Option<MySqlRow<'_>> {            let mut m = serde_json::Map::new();            let keys = row.names.keys();            for x in keys {                let key = x.to_string();                let key_str=key.as_str();                let v:serde_json::Value = row.json_decode_impl(key_str)?;                m.insert(key, v);            }            arr.push(serde_json::Value::Object(m));        }        let r = json_decode(arr)?;        return Ok(r);    })}

let rb = Rbatis::new(MYSQL_URL).await.unwrap();    let py = r#"SELECT * FROM biz_activityWHERE delete_flag = #{delete_flag}if name != null:  AND name like #{name+'%'}if ids != null:  AND id in (  trim ',':     for item in ids:       #{item},  )"#;    let data: serde_json::Value = rb.py_fetch("", py, &json!({   "delete_flag": 1 })).await.unwrap();    println!("{}", data);

-   go语言版本(标准库http+GoMybatis) 65 Qps/s-   rust语言版本(rbatis+hyper) 132Qps/s

• 逻辑删除插件
• 乐观锁插件
• 版本号控制插件