dromara/dbswitch
1
0
Fork 0
mirror of https://gitee.com/dromara/dbswitch.git synced 2025-10-15 14:20:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

修正issue的问题反馈

Browse Source
This commit is contained in:
inrgihc
2024-11-29 21:09:11 +08:00
parent 378d219869
commit 7f0139adad
2 changed files with 19 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dbswitch-common/src/main/java/com/gitee/dbswitch/common/type/ProductTypeEnum.java
View File

@@ -217,11 +217,11 @@ public enum ProductTypeEnum {
/**
* OceanBase数据库类型
*/
OCEANBASE(22, "`", "OceanBase", "com.oceanbase.jdbc.Driver", 2881,
"/* ping */ SELECT 1",
OCEANBASE(22, "", "OceanBase", "com.oceanbase.jdbc.Driver", 2881,
"/* ping */",
"jdbc:oceanbase://",
new String[]{"jdbc:oceanbase://{host}[:{port}]/[{database}][\\?{params}]"},
"jdbc:oceanbase://127.0.0.1:2881/test?pool=false&useUnicode=true&characterEncoding=utf-8&useSSL=false&"),
"jdbc:oceanbase://127.0.0.1:2881/test?pool=false&useUnicode=true&characterEncoding=utf-8&useSSL=false"),
;

18
dbswitch-product/dbswitch-product-oceanbase/src/main/java/com/gitee/dbswitch/product/oceanbase/OceanbaseMetadataQueryProvider.java
View File

@@ -9,6 +9,7 @@
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.product.oceanbase;
import cn.hutool.core.text.StrPool;
import com.gitee.dbswitch.common.type.ProductTypeEnum;
import com.gitee.dbswitch.product.mysql.MysqlMetadataQueryProvider;
import com.gitee.dbswitch.provider.ProductFactoryProvider;
@@ -21,6 +22,8 @@ import com.gitee.dbswitch.schema.SourceProperties;
import com.gitee.dbswitch.schema.TableDescription;
import java.sql.Connection;
import java.util.List;
import java.util.stream.Collectors;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
public class OceanbaseMetadataQueryProvider extends AbstractMetadataProvider {
@@ -127,7 +130,10 @@ public class OceanbaseMetadataQueryProvider extends AbstractMetadataProvider {
@Override
public void appendPrimaryKeyForCreateTableSql(StringBuilder builder, List<String> primaryKeys) {
this.delegate.appendPrimaryKeyForCreateTableSql(builder, primaryKeys);
if (CollectionUtils.isNotEmpty(primaryKeys)) {
String primaryKeyAsString = getPrimaryKeyAsString(primaryKeys);
builder.append(", PRIMARY KEY (").append(primaryKeyAsString).append(")");
}
}
@Override
@@ -138,7 +144,15 @@ public class OceanbaseMetadataQueryProvider extends AbstractMetadataProvider {
@Override
public String getPrimaryKeyAsString(List<String> pks) {
return this.delegate.getPrimaryKeyAsString(pks);
if (!pks.isEmpty()) {
return quoteName(
StringUtils.join(
pks.stream().distinct().collect(Collectors.toList())
, quoteName(StrPool.COMMA)
)
);
}
return StringUtils.EMPTY;
}
@Override