Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Improve][Connector] Add some sqlserver IDENTITY type for catalog #6822

Merged
merged 3 commits into from
May 9, 2024
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
[bugfix] add IDENTITY type for int
chl-wxp committed May 9, 2024

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
commit 381a6ac944bd1681a1a1c882a972bb69e849cb6f
Original file line number Diff line number Diff line change
@@ -39,11 +39,15 @@ public class SqlServerTypeConverter implements TypeConverter<BasicTypeDefine> {
// -------------------------number----------------------------
public static final String SQLSERVER_BIT = "BIT";
public static final String SQLSERVER_TINYINT = "TINYINT";
public static final String SQLSERVER_TINYINT_IDENTITY = "TINYINT IDENTITY";
public static final String SQLSERVER_SMALLINT = "SMALLINT";
public static final String SQLSERVER_SMALLINT_IDENTITY = "SMALLINT IDENTITY";
public static final String SQLSERVER_INTEGER = "INTEGER";
public static final String SQLSERVER_INTEGER_IDENTITY = "INTEGER IDENTITY";
public static final String SQLSERVER_INT = "INT";
private static final String SQLSERVER_INT_IDENTITY = "INT IDENTITY";
public static final String SQLSERVER_BIGINT = "BIGINT";
public static final String SQLSERVER_BIGINT_IDENTITY = "BIGINT IDENTITY";
public static final String SQLSERVER_DECIMAL = "DECIMAL";
public static final String SQLSERVER_FLOAT = "FLOAT";
public static final String SQLSERVER_REAL = "REAL";
@@ -111,20 +115,24 @@ public Column convert(BasicTypeDefine typeDefine) {
builder.dataType(BasicType.BOOLEAN_TYPE);
break;
case SQLSERVER_TINYINT:
case SQLSERVER_TINYINT_IDENTITY:
builder.sourceType(SQLSERVER_TINYINT);
builder.dataType(BasicType.SHORT_TYPE);
break;
case SQLSERVER_SMALLINT:
case SQLSERVER_SMALLINT_IDENTITY:
builder.sourceType(SQLSERVER_SMALLINT);
builder.dataType(BasicType.SHORT_TYPE);
break;
case SQLSERVER_INTEGER:
case SQLSERVER_INTEGER_IDENTITY:
case SQLSERVER_INT:
case SQLSERVER_INT_IDENTITY:
builder.sourceType(SQLSERVER_INT);
builder.dataType(BasicType.INT_TYPE);
break;
case SQLSERVER_BIGINT:
case SQLSERVER_BIGINT_IDENTITY:
builder.sourceType(SQLSERVER_BIGINT);
builder.dataType(BasicType.LONG_TYPE);
break;