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.

Sign up for GitHub

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

Performance | Improve performance of SQLServerDataTable.internalAddRow() function #990

Merged
merged 15 commits into from
May 22, 2019
Merged

Performance | Improve performance of SQLServerDataTable.internalAddRow() function #990

Show file tree
Hide file tree
Changes from 6 commits
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
a904477
Improve performance of SQLServerDataTable.internalAddRow() function
cheenamalhotra Mar 14, 2019
19a7ce4
Add tests + improve code
cheenamalhotra Mar 14, 2019
e098c78
Line spacings
cheenamalhotra Mar 14, 2019
031d362
Merge branch 'dev' into issue531
cheenamalhotra Mar 18, 2019
08f6bf4
Remove unwanted casting + UUID placement
cheenamalhotra Mar 23, 2019
0303b98
Quick change
cheenamalhotra Mar 23, 2019
a0d4caf
Merge branch 'ms-dev' into issue531
cheenamalhotra Apr 22, 2019
2e61d0d
Merge branch 'ms-dev' into issue531
cheenamalhotra Apr 30, 2019
0c08d78
Apply review comments
cheenamalhotra Apr 30, 2019
8423d41
Add fail messages
cheenamalhotra May 14, 2019
e0cc2e6
Merge branch 'ms-dev' into issue531
cheenamalhotra May 14, 2019
a2ac38d
Merge branch 'ms-dev' into issue531
cheenamalhotra May 15, 2019
f675da2
Reflect comments
cheenamalhotra May 15, 2019
0e8bb83
Merge branch 'ms-dev' into issue531
cheenamalhotra May 19, 2019
7595479
Remove unwanted set
cheenamalhotra May 19, 2019
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
228 changes: 116 additions & 112 deletions src/main/java/com/microsoft/sqlserver/jdbc/SQLServerDataTable.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -155,33 +155,43 @@ public synchronized void addRow(Object... values) throws SQLServerException {
*/
private void internalAddrow(JDBCType jdbcType, Object val, Object[] rowValues,
Map.Entry<Integer, SQLServerDataColumn> pair) throws SQLServerException {
if (null != val) {
SQLServerDataColumn currentColumnMetadata = pair.getValue();
int nValueLen;
switch (jdbcType) {
case BIGINT:
rowValues[pair.getKey()] = (val instanceof Long) ? val : Long.parseLong(val.toString());
break;

case BIT:
if (val instanceof Boolean) {
rowValues[pair.getKey()] = val;
} else if (val.toString().equals("0")
|| val.toString().equalsIgnoreCase(Boolean.FALSE.toString())) {
rowValues[pair.getKey()] = Boolean.FALSE;
} else if (val.toString().equals("1") || val.toString().equalsIgnoreCase(Boolean.TRUE.toString())) {
cheenamalhotra marked this conversation as resolved.
Show resolved Hide resolved
rowValues[pair.getKey()] = Boolean.TRUE;
} else {
MessageFormat form = new MessageFormat(
SQLServerException.getErrString("R_TVPInvalidColumnValue"));
Object[] msgArgs = {jdbcType};
throw new SQLServerException(null, form.format(msgArgs), null, 0, false);
}
break;

case INTEGER:
rowValues[pair.getKey()] = (val instanceof Integer) ? val : Integer.parseInt(val.toString());
break;

case SMALLINT:
case TINYINT:
rowValues[pair.getKey()] = (val instanceof Short) ? val : Short.parseShort(val.toString());
break;

SQLServerDataColumn currentColumnMetadata = pair.getValue();
boolean isColumnMetadataUpdated = false;
boolean bValueNull;
int nValueLen;
switch (jdbcType) {
case BIGINT:
rowValues[pair.getKey()] = (null == val) ? null : Long.parseLong(val.toString());
break;

case BIT:
rowValues[pair.getKey()] = (null == val) ? null : Boolean.parseBoolean(val.toString());
break;

case INTEGER:
rowValues[pair.getKey()] = (null == val) ? null : Integer.parseInt(val.toString());
break;

case SMALLINT:
case TINYINT:
rowValues[pair.getKey()] = (null == val) ? null : Short.parseShort(val.toString());
break;

case DECIMAL:
case NUMERIC:
BigDecimal bd = null;
if (null != val) {
case DECIMAL:
case NUMERIC:
BigDecimal bd = null;
boolean isColumnMetadataUpdated = false;
bd = new BigDecimal(val.toString());
// BigDecimal#precision returns number of digits in the unscaled value.
// Say, for value 0.01, it returns 1 but the precision should be 3 for SQLServer
Expand All @@ -207,92 +217,86 @@ private void internalAddrow(JDBCType jdbcType, Object val, Object[] rowValues,
+ currentColumnMetadata.numberOfDigitsIntegerPart;
columnMetadata.put(pair.getKey(), currentColumnMetadata);
}
}
rowValues[pair.getKey()] = bd;
break;

case DOUBLE:
rowValues[pair.getKey()] = (null == val) ? null : Double.parseDouble(val.toString());
break;

case FLOAT:
case REAL:
rowValues[pair.getKey()] = (null == val) ? null : Float.parseFloat(val.toString());
break;

case TIMESTAMP_WITH_TIMEZONE:
case TIME_WITH_TIMEZONE:
case DATE:
case TIME:
case TIMESTAMP:
case DATETIMEOFFSET:
case DATETIME:
case SMALLDATETIME:
// Sending temporal types as string. Error from database is thrown if parsing fails
// no need to send precision for temporal types, string literal will never exceed
// DataTypes.SHORT_VARTYPE_MAX_BYTES

if (null == val)
rowValues[pair.getKey()] = null;
// java.sql.Date, java.sql.Time and java.sql.Timestamp are subclass of java.util.Date
else if (val instanceof java.util.Date)
rowValues[pair.getKey()] = val.toString();
else if (val instanceof microsoft.sql.DateTimeOffset)
rowValues[pair.getKey()] = val.toString();
else if (val instanceof OffsetDateTime)
rowValues[pair.getKey()] = val.toString();
else if (val instanceof OffsetTime)
rowValues[pair.getKey()] = val.toString();
else
rowValues[pair.getKey()] = (String) val;
break;

case BINARY:
case VARBINARY:
case LONGVARBINARY:
bValueNull = (null == val);
nValueLen = bValueNull ? 0 : ((byte[]) val).length;

if (nValueLen > currentColumnMetadata.precision) {
currentColumnMetadata.precision = nValueLen;
columnMetadata.put(pair.getKey(), currentColumnMetadata);
}
rowValues[pair.getKey()] = (bValueNull) ? null : (byte[]) val;

break;

case CHAR:
if (val instanceof UUID && (val != null))
val = val.toString();
case VARCHAR:
case NCHAR:
case NVARCHAR:
case LONGVARCHAR:
case LONGNVARCHAR:
case SQLXML:
bValueNull = (null == val);
nValueLen = bValueNull ? 0 : (2 * ((String) val).length());

if (nValueLen > currentColumnMetadata.precision) {
currentColumnMetadata.precision = nValueLen;
columnMetadata.put(pair.getKey(), currentColumnMetadata);
}
rowValues[pair.getKey()] = (bValueNull) ? null : (String) val;
break;
case SQL_VARIANT:
JDBCType internalJDBCType;
if (null == val) { // TODO:Check this later
throw new SQLServerException(SQLServerException.getErrString("R_invalidValueForTVPWithSQLVariant"),
null);
}
JavaType javaType = JavaType.of(val);
internalJDBCType = javaType.getJDBCType(SSType.UNKNOWN, jdbcType);
internalAddrow(internalJDBCType, val, rowValues, pair);
break;
default:
MessageFormat form = new MessageFormat(SQLServerException.getErrString("R_unsupportedDataTypeTVP"));
Object[] msgArgs = {jdbcType};
throw new SQLServerException(null, form.format(msgArgs), null, 0, false);
rowValues[pair.getKey()] = bd;
break;

case DOUBLE:
rowValues[pair.getKey()] = (val instanceof Double) ? val : Double.parseDouble(val.toString());
break;

case FLOAT:
case REAL:
rowValues[pair.getKey()] = (val instanceof Float) ? val : Float.parseFloat(val.toString());
break;

case TIMESTAMP_WITH_TIMEZONE:
case TIME_WITH_TIMEZONE:
case DATE:
case TIME:
case TIMESTAMP:
case DATETIMEOFFSET:
case DATETIME:
case SMALLDATETIME:
// Sending temporal types as string. Error from database is thrown if parsing fails
// no need to send precision for temporal types, string literal will never exceed
// DataTypes.SHORT_VARTYPE_MAX_BYTES

// java.sql.Date, java.sql.Time and java.sql.Timestamp are subclass of java.util.Date
if (val instanceof java.util.Date || val instanceof microsoft.sql.DateTimeOffset
|| val instanceof OffsetDateTime || val instanceof OffsetTime)
rowValues[pair.getKey()] = val.toString();
else
rowValues[pair.getKey()] = val;
peterbae marked this conversation as resolved.
Show resolved Hide resolved
break;

case BINARY:
case VARBINARY:
case LONGVARBINARY:
nValueLen = ((byte[]) val).length;

if (nValueLen > currentColumnMetadata.precision) {
currentColumnMetadata.precision = nValueLen;
columnMetadata.put(pair.getKey(), currentColumnMetadata);
}
rowValues[pair.getKey()] = val;
peterbae marked this conversation as resolved.
Show resolved Hide resolved
break;

case CHAR:
case VARCHAR:
case NCHAR:
case NVARCHAR:
case LONGVARCHAR:
case LONGNVARCHAR:
case SQLXML:
if (val instanceof UUID)
val = val.toString();
nValueLen = (2 * ((String) val).length());
cheenamalhotra marked this conversation as resolved.
Show resolved Hide resolved

if (nValueLen > currentColumnMetadata.precision) {
currentColumnMetadata.precision = nValueLen;
columnMetadata.put(pair.getKey(), currentColumnMetadata);
}
rowValues[pair.getKey()] = val;
break;

case SQL_VARIANT:
JDBCType internalJDBCType;
JavaType javaType = JavaType.of(val);
internalJDBCType = javaType.getJDBCType(SSType.UNKNOWN, jdbcType);
internalAddrow(internalJDBCType, val, rowValues, pair);
break;

default:
MessageFormat form = new MessageFormat(SQLServerException.getErrString("R_unsupportedDataTypeTVP"));
Object[] msgArgs = {jdbcType};
throw new SQLServerException(null, form.format(msgArgs), null, 0, false);
}
} else {
rowValues[pair.getKey()] = null;
if (jdbcType == JDBCType.SQL_VARIANT) {
throw new SQLServerException(SQLServerException.getErrString("R_invalidValueForTVPWithSQLVariant"),
null);
}
}
}

Expand Down
1 change: 1 addition & 0 deletions src/test/java/com/microsoft/sqlserver/jdbc/TestResource.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -173,6 +173,7 @@ protected Object[][] getContents() {
"Column name or number of supplied values does not match table definition."},
{"R_incorrectSyntaxTable", "Incorrect syntax near the keyword 'table'."},
{"R_incorrectSyntaxTableDW", "Incorrect syntax near 'table'."},
{"R_TVPIncorrectColumnValue","Input data is not in correct format"},
cheenamalhotra marked this conversation as resolved.
Show resolved Hide resolved
{"R_ConnectionStringNull", "Connection String should not be null"},
{"R_OperandTypeClash", "Operand type clash"}};
}
Loading