| | |
|---|
| | | |
|---|
| | | import cn.hutool.core.convert.Convert; |
|---|
| | | import com.baomidou.dynamic.datasource.DynamicRoutingDataSource; |
|---|
| | | import lombok.AccessLevel; |
|---|
| | | import lombok.NoArgsConstructor; |
|---|
| | | import org.dromara.common.core.exception.ServiceException; |
|---|
| | | import org.dromara.common.core.utils.SpringUtils; |
|---|
| | | import org.dromara.common.mybatis.enums.DataBaseType; |
|---|
| | | import lombok.AccessLevel; |
|---|
| | | import lombok.NoArgsConstructor; |
|---|
| | | |
|---|
| | | import javax.sql.DataSource; |
|---|
| | | import java.sql.Connection; |
|---|
| | | import java.sql.DatabaseMetaData; |
|---|
| | | import java.sql.SQLException; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 数据库助手 |
|---|
| | |
|---|
| | | // charindex(',100,' , ',0,100,101,') <> 0 |
|---|
| | | return "charindex(',%s,' , ','+%s+',') <> 0".formatted(var, var2); |
|---|
| | | } else if (dataBasyType == DataBaseType.POSTGRE_SQL) { |
|---|
| | | // (select position(',100,' in ',0,100,101,')) <> 0 |
|---|
| | | return "(select position(',%s,' in ','||%s||',')) <> 0".formatted(var, var2); |
|---|
| | | // (select strpos(',0,100,101,' , ',100,')) <> 0 |
|---|
| | | return "(select strpos(','||%s||',' , ',%s,')) <> 0".formatted(var2, var); |
|---|
| | | } else if (dataBasyType == DataBaseType.ORACLE) { |
|---|
| | | // instr(',0,100,101,' , ',100,') <> 0 |
|---|
| | | return "instr(','||%s||',' , ',%s,') <> 0".formatted(var2, var); |
|---|
| | |
|---|
| | | // find_in_set(100 , '0,100,101') |
|---|
| | | return "find_in_set('%s' , %s) <> 0".formatted(var, var2); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取当前加载的数据库名 |
|---|
| | | */ |
|---|
| | | public static List<String> getDataSourceNameList() { |
|---|
| | | return new ArrayList<>(DS.getDataSources().keySet()); |
|---|
| | | } |
|---|
| | | } |
|---|
