Skip to main content

sea_schema/mysql/query/
version.rs

1use super::SchemaQueryBuilder;
2use crate::sqlx_types::SqlxRow;
3use sea_query::{Func, Query, SelectStatement};
4
5#[derive(sea_query::Iden)]
6enum MysqlFunc {
7    Version,
8}
9
10#[derive(Debug, Default)]
11pub struct VersionQueryResult {
12    pub version: String,
13}
14
15impl SchemaQueryBuilder {
16    pub fn query_version(&self) -> SelectStatement {
17        Query::select().expr(Func::cust(MysqlFunc::Version)).take()
18    }
19}
20
21#[cfg(feature = "sqlx-mysql")]
22impl From<SqlxRow> for VersionQueryResult {
23    fn from(row: SqlxRow) -> Self {
24        use crate::mysql::discovery::GetMySqlValue;
25        let row = row.mysql();
26        Self {
27            version: row.get_string(0),
28        }
29    }
30}
31
32#[cfg(not(feature = "sqlx-mysql"))]
33impl From<SqlxRow> for VersionQueryResult {
34    fn from(_: SqlxRow) -> Self {
35        Self::default()
36    }
37}