OpenSrv - MySQL

模拟 MySQL/MariaDB 服务器的绑定。

在开发新的数据库或缓存层时，使用现有应用程序测试您的系统非常有用。然而，这通常需要对应用程序进行大量修改以使用您的数据库。这个 crate 通过充当 MySQL 服务器并将查询和查询执行等操作委托给用户定义的逻辑来解决此问题。

使用方法

首先，为您的后端实现 AsyncMysqlShim，并在您的后端实例和连接流上创建一个 AsyncMysqlIntermediary。当客户端发出 QUERY、PREPARE 或 EXECUTE 命令时，将在您的后端上调用相应的方法，您将有机会适当地响应。例如，编写一个始终以“无结果”回复响应所有命令的 shim

use std::io;
use tokio::io::AsyncWrite;

use opensrv_mysql::*;
use tokio::net::TcpListener;

struct Backend;

#[async_trait::async_trait]
impl<W: AsyncWrite + Send + Unpin> AsyncMysqlShim<W> for Backend {
    type Error = io::Error;

    async fn on_prepare<'a>(
        &'a mut self,
        _: &'a str,
        info: StatementMetaWriter<'a, W>,
    ) -> io::Result<()> {
        info.reply(42, &[], &[]).await
    }

    async fn on_execute<'a>(
        &'a mut self,
        _: u32,
        _: opensrv_mysql::ParamParser<'a>,
        results: QueryResultWriter<'a, W>,
    ) -> io::Result<()> {
        results.completed(OkResponse::default()).await
    }

    async fn on_close(&mut self, _: u32) {}

    async fn on_query<'a>(
        &'a mut self,
        sql: &'a str,
        results: QueryResultWriter<'a, W>,
    ) -> io::Result<()> {
        println!("execute sql {:?}", sql);
        results.start(&[]).await?.finish().await
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let listener = TcpListener::bind("0.0.0.0:3306").await?;

    loop {
        let (stream, _) = listener.accept().await?;
        let (r, w) = stream.into_split();
        tokio::spawn(async move { AsyncMysqlIntermediary::run_on(Backend, r, w).await });
    }
}

此示例可以与此执行

cargo run --example=serve_one

更多示例可以在此处找到。

获取帮助

提交 问题 进行错误报告或在 讨论 中提问。

致谢

此项目是 jonhoo/msql-srv 的一个分支，专注于提供异步支持。

许可证

根据 Apache 许可证版本 2.0 许可。