package com.qianwen.smartman.modules.visual.dynamic.provider;
|
|
import com.baomidou.mybatisplus.annotation.DbType;
|
import com.mysql.cj.jdbc.DatabaseMetaData;
|
import java.lang.reflect.Field;
|
import java.sql.SQLException;
|
import java.sql.Statement;
|
import com.qianwen.core.tool.utils.ReflectUtil;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/visual/dynamic/provider/MysqlCheckSqlProvider.class */
|
public class MysqlCheckSqlProvider implements CheckSqlProvider {
|
@Override // org.springblade.modules.visual.dynamic.provider.CheckSqlProvider
|
public String getExistTableSql() {
|
return "select count(*) from information_schema.TABLES where TABLE_SCHEMA ='{}' and table_name = 'blade_visual_db'";
|
}
|
|
@Override // org.springblade.modules.visual.dynamic.provider.CheckSqlProvider
|
public String getDatabaseSchema(Statement statement) throws SQLException {
|
Field field = ReflectUtil.findField(DatabaseMetaData.class, "database");
|
ReflectUtil.makeAccessible(field);
|
return ReflectUtil.getField(field, statement.getConnection().getMetaData()).toString();
|
}
|
|
@Override // org.springblade.modules.visual.dynamic.provider.CheckSqlProvider
|
public Boolean support(DbType dbType) {
|
return Boolean.valueOf(DbType.MYSQL.equals(dbType));
|
}
|
}
|
