first commit

This commit is contained in:
2023-07-02 21:43:18 +08:00
parent 71125d997e
commit 6c36460d89
37 changed files with 943 additions and 111 deletions

View File

@ -0,0 +1,26 @@
package com.qiaoba.common.base.utils;
import cn.hutool.core.util.StrUtil;
import java.util.Objects;
/**
* ArrayUtil
*
* @author ailanyin
* @version 1.0
* @since 2023/5/22 16:41
*/
public class ArrayUtil extends cn.hutool.core.util.ArrayUtil {
public static boolean containsValueIgnoreCase(CharSequence[] array, CharSequence value) {
if (Objects.nonNull(array)) {
for (CharSequence charSequence : array) {
if (StrUtil.containsIgnoreCase(value, charSequence)) {
return true;
}
}
}
return false;
}
}

View File

@ -31,7 +31,7 @@ public class MybatisPlusConfig {
/**
* 不需要拼接租户ID的表 租户表/租户数据源表
*/
private static final List<String> IGNORE_TABLES = ListUtil.toList("sys_tenant", "sys_tenant_datasource");
private static final List<String> IGNORE_TABLES = ListUtil.toList("sys_tenant", "sys_tenant_datasource", "generator_table", "generator_table_column");
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {

View File

@ -27,6 +27,7 @@ public class DynamicDataSourceFactory {
public void setSchemaPrefix() {
TenantSchema.setSchemaPrefix(schemaPrefix);
}
@Bean
public DynamicDataSourceContext dataSource() {
return new DynamicDataSourceContext();

View File

@ -2,7 +2,6 @@ package com.qiaoba.common.database.interceptors;
import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor;
import com.qiaoba.common.base.context.BaseContext;
import com.qiaoba.common.base.enums.DataBaseEnum;
import com.qiaoba.common.database.context.TenantDbTypeContext;
import com.qiaoba.common.database.properties.TenantSchema;
import com.qiaoba.common.database.utils.DbUtil;

View File

@ -76,21 +76,4 @@ public class DbUtil {
}
}
public static void main(String[] args) {
Connection connection = null;
try {
connection = JdbcUtil.getConnection(
DataBaseEnum.getDriver("Oracle"),
"jdbc:oracle:thin:@//192.168.0.205:1521/ORCL",
"system",
"root"
);
setSchema("Oracle", connection, "QIAOBA1");
runSql(connection, "delete FROM SYS_USER where user_id = '1'");
} catch (SQLException e) {
System.out.println(e.getMessage());
} finally {
IoUtil.close(connection);
}
}
}

View File

@ -82,9 +82,4 @@ public class JdbcUtil {
return DriverManager.getConnection(url, username, password);
}
public static void main(String[] args) throws Exception {
Connection connection = getConnection("oracle.jdbc.OracleDriver", "jdbc:oracle:thin:@//192.168.0.205:1521/ORCL", "QIAOBA-BOOT-1", "123456");
DbUtil.runSql(connection, "delete from sys_post where post_id = '1'");
}
}