实际上官方支持auth 的认证的，只是模式为None,我们可以自定义自己的一个auth，以下主要说明下关于mysql 协议的，因为特殊性
http 走的是websocket（后期添加）
参考修改的代码
- auth
#[async_trait]
impl SqlAuthService for SqlAuthDefaultImpl {
async fn authenticate(&self, _user: Option<String>) -> Result<Option<String>, CubeError> {
let m = match _user {
None => {
println!("{}", "user is null");
Err(CubeError {
message: "error".to_string(),
cause: CubeErrorCauseType::User,
})
}
Some(user) => {
println!("auth user{}", user);
Ok(None)
}
};
m
}
}
- 协议处理
tokio::spawn(async move {
if let Err(e) = AsyncMysqlIntermediary::run_on(
Backend {
sql_service,
auth,
// 使用自定义环境变量
user: env::var("CUBESTORE_USERNAME").ok(),
},
socket,
)
.await
{
error!("Error during processing MySQL connection: {}", e);
}
});
运行
export CUBESTORE_LOG_LEVEL=debug
export CUBESTORE_SERVER_NAME=localhost:9999
export CUBESTORE_META_PORT=9999
export CUBESTORE_S3_BUCKET=test
export CUBESTORE_S3_ENDPOINT=http://localhost:9000
export CUBESTORE_S3_REGION=us-east-1
export CUBESTORE_S3_PATH_STYLE=1
export CUBESTORE_USERNAME=dalong
export CUBESTORE_REMOTE_DIR=./cube/data
export CUBESTORE_AWS_ACCESS_KEY_ID=dalongrong
export CUBESTORE_AWS_SECRET_ACCESS_KEY=dalongrong
./target/debug/cubestored
使用
可以使用以下命令测试
mysql -udalong -h127.0.0.1
说明
因为http 以及websocket 的特殊性，后期调整添加