提交 80501d18 authored 作者: Evgenij Ryazanov's avatar Evgenij Ryazanov

Do not use concatenation with "" for converting non-constant numbers

上级 d655ba0f
......@@ -2062,7 +2062,7 @@ public class ErrorCode {
case FEATURE_NOT_SUPPORTED_1: return "HYC00";
case LOCK_TIMEOUT_1: return "HYT00";
default:
return "" + errorCode;
return Integer.toString(errorCode);
}
}
......
......@@ -520,7 +520,7 @@ public abstract class Query extends Prepared {
}
idx -= 1;
if (idx < 0 || idx >= expressionCount) {
throw DbException.get(ErrorCode.ORDER_BY_NOT_IN_RESULT, "" + (idx + 1));
throw DbException.get(ErrorCode.ORDER_BY_NOT_IN_RESULT, Integer.toString(idx + 1));
}
}
index[i] = idx;
......
......@@ -411,7 +411,7 @@ public class Database implements DataHandler {
if (now > reconnectCheckNext) {
if (pending) {
String pos = pageStore == null ?
null : "" + pageStore.getWriteCountTotal();
null : Long.toString(pageStore.getWriteCountTotal());
lock.setProperty("logPos", pos);
lock.save();
}
......@@ -433,7 +433,7 @@ public class Database implements DataHandler {
}
}
String pos = pageStore == null ?
null : "" + pageStore.getWriteCountTotal();
null : Long.toString(pageStore.getWriteCountTotal());
lock.setProperty("logPos", pos);
if (pending) {
lock.setProperty("changePending", "true-" + Math.random());
......@@ -2646,7 +2646,7 @@ public class Database implements DataHandler {
long now = System.nanoTime();
if (now > reconnectCheckNext + reconnectCheckDelayNs) {
if (SysProperties.CHECK && checkpointAllowed < 0) {
DbException.throwInternalError("" + checkpointAllowed);
DbException.throwInternalError(Integer.toString(checkpointAllowed));
}
synchronized (reconnectSync) {
if (checkpointAllowed > 0) {
......@@ -2716,7 +2716,7 @@ public class Database implements DataHandler {
if (reconnectModified(true)) {
checkpointAllowed++;
if (SysProperties.CHECK && checkpointAllowed > 20) {
throw DbException.throwInternalError("" + checkpointAllowed);
throw DbException.throwInternalError(Integer.toString(checkpointAllowed));
}
return true;
}
......@@ -2738,7 +2738,7 @@ public class Database implements DataHandler {
checkpointAllowed--;
}
if (SysProperties.CHECK && checkpointAllowed < 0) {
throw DbException.throwInternalError("" + checkpointAllowed);
throw DbException.throwInternalError(Integer.toString(checkpointAllowed));
}
}
......
......@@ -75,7 +75,7 @@ public class Right extends DbObjectBase {
public Right(Database db, int id, RightOwner grantee, int grantedRight,
DbObject grantedObject) {
initDbObjectBase(db, id, "" + id, Trace.USER);
initDbObjectBase(db, id, Integer.toString(id), Trace.USER);
this.grantee = grantee;
this.grantedRight = grantedRight;
this.grantedObject = grantedObject;
......
......@@ -47,7 +47,7 @@ public class SettingsBase {
* @return the setting
*/
protected int get(String key, int defaultValue) {
String s = get(key, "" + defaultValue);
String s = get(key, Integer.toString(defaultValue));
try {
return Integer.decode(s);
} catch (NumberFormatException e) {
......
......@@ -333,7 +333,7 @@ public class CompareLike extends Condition {
}
return false;
default:
DbException.throwInternalError("" + types[pi]);
DbException.throwInternalError(Integer.toString(types[pi]));
}
}
return si == sLen;
......
......@@ -557,7 +557,7 @@ public class Function extends Expression implements FunctionCall {
} else {
if (index >= args.length) {
throw DbException.get(ErrorCode.INVALID_PARAMETER_COUNT_2,
info.name, "" + args.length);
info.name, Integer.toString(args.length));
}
args[index] = param;
}
......@@ -2165,7 +2165,7 @@ public class Function extends Expression implements FunctionCall {
if (len > 0 && args[len - 1] == null) {
throw DbException.get(
ErrorCode.INVALID_PARAMETER_COUNT_2,
info.name, "" + len);
info.name, Integer.toString(len));
}
}
}
......
......@@ -100,7 +100,7 @@ public class Wildcard extends Expression {
if (visitor.getType() == ExpressionVisitor.QUERY_COMPARABLE) {
return true;
}
throw DbException.throwInternalError("" + visitor.getType());
throw DbException.throwInternalError(Integer.toString(visitor.getType()));
}
@Override
......
......@@ -176,7 +176,7 @@ public class PageBtreeLeaf extends PageBtree {
written = false;
changeCount = index.getPageStore().getChangeCount();
if (entryCount <= 0) {
DbException.throwInternalError("" + entryCount);
DbException.throwInternalError(Integer.toString(entryCount));
}
int startNext = at > 0 ? offsets[at - 1] : index.getPageStore().getPageSize();
int rowLength = startNext - offsets[at];
......
......@@ -474,7 +474,7 @@ public class PageBtreeNode extends PageBtree {
written = false;
changeCount = index.getPageStore().getChangeCount();
if (entryCount < 0) {
DbException.throwInternalError("" + entryCount);
DbException.throwInternalError(Integer.toString(entryCount));
}
if (entryCount > i) {
int startNext = i > 0 ? offsets[i - 1] : index.getPageStore().getPageSize();
......
......@@ -220,7 +220,7 @@ public class PageDataLeaf extends PageData {
if (offset < start) {
writtenData = false;
if (entryCount > 1) {
DbException.throwInternalError("" + entryCount);
DbException.throwInternalError(Integer.toString(entryCount));
}
// need to write the overflow page id
start += 4;
......@@ -283,7 +283,7 @@ public class PageDataLeaf extends PageData {
}
entryCount--;
if (entryCount < 0) {
DbException.throwInternalError("" + entryCount);
DbException.throwInternalError(Integer.toString(entryCount));
}
if (firstOverflowPageId != 0) {
start -= 4;
......
......@@ -388,7 +388,7 @@ public class PageDataNode extends PageData {
entryCount--;
length -= 4 + Data.getVarLongLen(keys[removedKeyIndex]);
if (entryCount < 0) {
DbException.throwInternalError("" + entryCount);
DbException.throwInternalError(Integer.toString(entryCount));
}
keys = remove(keys, entryCount + 1, removedKeyIndex);
childPageIds = remove(childPageIds, entryCount + 2, i);
......
......@@ -91,15 +91,15 @@ public class TcpServerThread implements Runnable {
int minClientVersion = transfer.readInt();
if (minClientVersion < 6) {
throw DbException.get(ErrorCode.DRIVER_VERSION_ERROR_2,
"" + minClientVersion, "" + Constants.TCP_PROTOCOL_VERSION_MIN_SUPPORTED);
Integer.toString(minClientVersion), "" + Constants.TCP_PROTOCOL_VERSION_MIN_SUPPORTED);
}
int maxClientVersion = transfer.readInt();
if (maxClientVersion < Constants.TCP_PROTOCOL_VERSION_MIN_SUPPORTED) {
throw DbException.get(ErrorCode.DRIVER_VERSION_ERROR_2,
"" + maxClientVersion, "" + Constants.TCP_PROTOCOL_VERSION_MIN_SUPPORTED);
Integer.toString(maxClientVersion), "" + Constants.TCP_PROTOCOL_VERSION_MIN_SUPPORTED);
} else if (minClientVersion > Constants.TCP_PROTOCOL_VERSION_MAX_SUPPORTED) {
throw DbException.get(ErrorCode.DRIVER_VERSION_ERROR_2,
"" + minClientVersion, "" + Constants.TCP_PROTOCOL_VERSION_MAX_SUPPORTED);
Integer.toString(minClientVersion), "" + Constants.TCP_PROTOCOL_VERSION_MAX_SUPPORTED);
}
if (maxClientVersion >= Constants.TCP_PROTOCOL_VERSION_MAX_SUPPORTED) {
clientVersion = Constants.TCP_PROTOCOL_VERSION_MAX_SUPPORTED;
......
......@@ -338,8 +338,8 @@ public class WebApp {
}
private String admin() {
session.put("port", "" + server.getPort());
session.put("allowOthers", "" + server.getAllowOthers());
session.put("port", Integer.toString(server.getPort()));
session.put("allowOthers", Boolean.toString(server.getAllowOthers()));
session.put("ssl", String.valueOf(server.getSSL()));
session.put("sessions", server.getSessions());
return "admin.jsp";
......@@ -1172,16 +1172,16 @@ public class WebApp {
SimpleResultSet rs = new SimpleResultSet();
rs.addColumn("Type", Types.VARCHAR, 0, 0);
rs.addColumn("KB", Types.VARCHAR, 0, 0);
rs.addRow("Used Memory", "" + Utils.getMemoryUsed());
rs.addRow("Free Memory", "" + Utils.getMemoryFree());
rs.addRow("Used Memory", Integer.toString(Utils.getMemoryUsed()));
rs.addRow("Free Memory", Integer.toString(Utils.getMemoryFree()));
return rs;
} else if (isBuiltIn(sql, "@info")) {
SimpleResultSet rs = new SimpleResultSet();
rs.addColumn("KEY", Types.VARCHAR, 0, 0);
rs.addColumn("VALUE", Types.VARCHAR, 0, 0);
rs.addRow("conn.getCatalog", conn.getCatalog());
rs.addRow("conn.getAutoCommit", "" + conn.getAutoCommit());
rs.addRow("conn.getTransactionIsolation", "" + conn.getTransactionIsolation());
rs.addRow("conn.getAutoCommit", Boolean.toString(conn.getAutoCommit()));
rs.addRow("conn.getTransactionIsolation", Integer.toString(conn.getTransactionIsolation()));
rs.addRow("conn.getWarnings", "" + conn.getWarnings());
String map;
try {
......@@ -1190,8 +1190,8 @@ public class WebApp {
map = e.toString();
}
rs.addRow("conn.getTypeMap", "" + map);
rs.addRow("conn.isReadOnly", "" + conn.isReadOnly());
rs.addRow("conn.getHoldability", "" + conn.getHoldability());
rs.addRow("conn.isReadOnly", Boolean.toString(conn.isReadOnly()));
rs.addRow("conn.getHoldability", Integer.toString(conn.getHoldability()));
addDatabaseMetaData(rs, meta);
return rs;
} else if (isBuiltIn(sql, "@attributes")) {
......@@ -1328,7 +1328,7 @@ public class WebApp {
} else if (isBuiltIn(sql, "@maxrows")) {
int maxrows = (int) Double.parseDouble(
sql.substring("@maxrows".length()).trim());
session.put("maxrows", "" + maxrows);
session.put("maxrows", Integer.toString(maxrows));
return "${text.result.maxrowsSet}";
} else if (isBuiltIn(sql, "@parameter_meta")) {
sql = sql.substring("@parameter_meta".length()).trim();
......
......@@ -672,14 +672,11 @@ public class WebServer implements Service {
Properties old = loadProperties();
prop = new SortedProperties();
prop.setProperty("webPort",
"" + SortedProperties.getIntProperty(old,
"webPort", port));
Integer.toString(SortedProperties.getIntProperty(old, "webPort", port)));
prop.setProperty("webAllowOthers",
"" + SortedProperties.getBooleanProperty(old,
"webAllowOthers", allowOthers));
Boolean.toString(SortedProperties.getBooleanProperty(old, "webAllowOthers", allowOthers)));
prop.setProperty("webSSL",
"" + SortedProperties.getBooleanProperty(old,
"webSSL", ssl));
Boolean.toString(SortedProperties.getBooleanProperty(old, "webSSL", ssl)));
if (commandHistoryString != null) {
prop.setProperty(COMMAND_HISTORY, commandHistoryString);
}
......
......@@ -12,6 +12,7 @@ import java.io.Reader;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.Timestamp;
import java.sql.Types;
import java.text.Collator;
import java.util.ArrayList;
import java.util.Collections;
......@@ -797,15 +798,15 @@ public class MetaTable extends Table {
// REMARKS
replaceNullWithEmpty(table.getComment()),
// LAST_MODIFICATION
"" + table.getMaxDataModificationId(),
Long.toString(table.getMaxDataModificationId()),
// ID
"" + table.getId(),
Integer.toString(table.getId()),
// TYPE_NAME
null,
// TABLE_CLASS
table.getClass().getName(),
// ROW_COUNT_ESTIMATE
"" + table.getRowCountApproximation()
Long.toString(table.getRowCountApproximation())
);
}
break;
......@@ -833,6 +834,7 @@ public class MetaTable extends Table {
for (int j = 0; j < cols.length; j++) {
Column c = cols[j];
DataType dataType = c.getDataType();
String precision = Integer.toString(c.getPrecisionAsInt());
Sequence sequence = c.getSequence();
add(rows,
// TABLE_CATALOG
......@@ -850,17 +852,17 @@ public class MetaTable extends Table {
// IS_NULLABLE
c.isNullable() ? "YES" : "NO",
// DATA_TYPE
"" + dataType.sqlType,
Integer.toString(dataType.sqlType),
// CHARACTER_MAXIMUM_LENGTH
"" + c.getPrecisionAsInt(),
precision,
// CHARACTER_OCTET_LENGTH
"" + c.getPrecisionAsInt(),
precision,
// NUMERIC_PRECISION
"" + c.getPrecisionAsInt(),
precision,
// NUMERIC_PRECISION_RADIX
"10",
// NUMERIC_SCALE
"" + c.getScale(),
Integer.toString(c.getScale()),
// CHARACTER_SET_NAME
CHARACTER_SET_NAME,
// COLLATION_NAME
......@@ -868,13 +870,13 @@ public class MetaTable extends Table {
// TYPE_NAME
identifier(dataType.name),
// NULLABLE
"" + (c.isNullable() ?
DatabaseMetaData.columnNullable :
DatabaseMetaData.columnNoNulls) ,
c.isNullable() ?
"" + DatabaseMetaData.columnNullable :
"" + DatabaseMetaData.columnNoNulls,
// IS_COMPUTED
"" + (c.getComputed() ? "TRUE" : "FALSE"),
c.getComputed() ? "TRUE" : "FALSE",
// SELECTIVITY
"" + (c.getSelectivity()),
Integer.toString(c.getSelectivity()),
// CHECK_CONSTRAINT
c.getCheckConstraintSQL(session, c.getName()),
// SEQUENCE_NAME
......@@ -954,7 +956,7 @@ public class MetaTable extends Table {
// INDEX_NAME
identifier(index.getName()),
// ORDINAL_POSITION
"" + (k+1),
Integer.toString(k + 1),
// COLUMN_NAME
identifier(column.getName()),
// CARDINALITY
......@@ -981,9 +983,9 @@ public class MetaTable extends Table {
// SQL
index.getCreateSQL(),
// ID
"" + index.getId(),
Integer.toString(index.getId()),
// SORT_TYPE
"" + idxCol.sortType,
Integer.toString(idxCol.sortType),
// CONSTRAINT_NAME
constraintName,
// INDEX_CLASS
......@@ -1013,7 +1015,7 @@ public class MetaTable extends Table {
for (Setting s : database.getAllSettings()) {
String value = s.getStringValue();
if (value == null) {
value = "" + s.getIntValue();
value = Integer.toString(s.getIntValue());
}
add(rows,
identifier(s.getName()),
......@@ -1023,7 +1025,7 @@ public class MetaTable extends Table {
add(rows, "info.BUILD_ID", "" + Constants.BUILD_ID);
add(rows, "info.VERSION_MAJOR", "" + Constants.VERSION_MAJOR);
add(rows, "info.VERSION_MINOR", "" + Constants.VERSION_MINOR);
add(rows, "info.VERSION", "" + Constants.getFullVersion());
add(rows, "info.VERSION", Constants.getFullVersion());
if (admin) {
String[] settings = {
"java.runtime.version", "java.vm.name",
......@@ -1040,9 +1042,9 @@ public class MetaTable extends Table {
add(rows, "MODE", database.getMode().getName());
add(rows, "MULTI_THREADED", database.isMultiThreaded() ? "1" : "0");
add(rows, "MVCC", database.isMultiVersion() ? "TRUE" : "FALSE");
add(rows, "QUERY_TIMEOUT", "" + session.getQueryTimeout());
add(rows, "RETENTION_TIME", "" + database.getRetentionTime());
add(rows, "LOG", "" + database.getLogMode());
add(rows, "QUERY_TIMEOUT", Integer.toString(session.getQueryTimeout()));
add(rows, "RETENTION_TIME", Integer.toString(database.getRetentionTime()));
add(rows, "LOG", Integer.toString(database.getLogMode()));
// database settings
ArrayList<String> settingNames = Utils.newSmallArrayList();
HashMap<String, String> s = database.getSettings().getSettings();
......@@ -1055,27 +1057,27 @@ public class MetaTable extends Table {
PageStore store = database.getPageStore();
if (store != null) {
add(rows, "info.FILE_WRITE_TOTAL",
"" + store.getWriteCountTotal());
Long.toString(store.getWriteCountTotal()));
add(rows, "info.FILE_WRITE",
"" + store.getWriteCount());
Long.toString(store.getWriteCount()));
add(rows, "info.FILE_READ",
"" + store.getReadCount());
Long.toString(store.getReadCount()));
add(rows, "info.PAGE_COUNT",
"" + store.getPageCount());
Integer.toString(store.getPageCount()));
add(rows, "info.PAGE_SIZE",
"" + store.getPageSize());
Integer.toString(store.getPageSize()));
add(rows, "info.CACHE_MAX_SIZE",
"" + store.getCache().getMaxMemory());
Integer.toString(store.getCache().getMaxMemory()));
add(rows, "info.CACHE_SIZE",
"" + store.getCache().getMemory());
Integer.toString(store.getCache().getMemory()));
}
Store mvStore = database.getMvStore();
if (mvStore != null) {
FileStore fs = mvStore.getStore().getFileStore();
add(rows, "info.FILE_WRITE", "" +
fs.getWriteCount());
add(rows, "info.FILE_READ", "" +
fs.getReadCount());
add(rows, "info.FILE_WRITE",
Long.toString(fs.getWriteCount()));
add(rows, "info.FILE_READ",
Long.toString(fs.getReadCount()));
long size;
try {
size = fs.getFile().size();
......@@ -1084,14 +1086,14 @@ public class MetaTable extends Table {
}
int pageSize = 4 * 1024;
long pageCount = size / pageSize;
add(rows, "info.PAGE_COUNT", "" +
pageCount);
add(rows, "info.PAGE_SIZE", "" +
pageSize);
add(rows, "info.CACHE_MAX_SIZE", "" +
mvStore.getStore().getCacheSize());
add(rows, "info.CACHE_SIZE", "" +
mvStore.getStore().getCacheSizeUsed());
add(rows, "info.PAGE_COUNT",
Long.toString(pageCount));
add(rows, "info.PAGE_SIZE",
Integer.toString(pageSize));
add(rows, "info.CACHE_MAX_SIZE",
Integer.toString(mvStore.getStore().getCacheSize()));
add(rows, "info.CACHE_SIZE",
Integer.toString(mvStore.getStore().getCacheSizeUsed()));
}
}
break;
......@@ -1190,7 +1192,7 @@ public class MetaTable extends Table {
// IS_CYCLE
s.getCycle() ? "TRUE" : "FALSE",
// ID
"" + s.getId()
Integer.toString(s.getId())
);
}
break;
......@@ -1206,7 +1208,7 @@ public class MetaTable extends Table {
// REMARKS
replaceNullWithEmpty(u.getComment()),
// ID
"" + u.getId()
Integer.toString(u.getId())
);
}
}
......@@ -1221,7 +1223,7 @@ public class MetaTable extends Table {
// REMARKS
replaceNullWithEmpty(r.getComment()),
// ID
"" + r.getId()
Integer.toString(r.getId())
);
}
}
......@@ -1265,7 +1267,7 @@ public class MetaTable extends Table {
// TABLE_NAME
tableName,
// ID
"" + r.getId()
Integer.toString(r.getId())
);
} else {
add(rows,
......@@ -1282,7 +1284,7 @@ public class MetaTable extends Table {
// TABLE_NAME
"",
// ID
"" + r.getId()
Integer.toString(r.getId())
);
}
}
......@@ -1315,17 +1317,17 @@ public class MetaTable extends Table {
// JAVA_METHOD
alias.getJavaMethodName(),
// DATA_TYPE
"" + DataType.convertTypeToSQLType(method.getDataType()),
Integer.toString(DataType.convertTypeToSQLType(method.getDataType())),
// TYPE_NAME
DataType.getDataType(method.getDataType()).name,
// COLUMN_COUNT INT
"" + method.getParameterCount(),
Integer.toString(method.getParameterCount()),
// RETURNS_RESULT SMALLINT
"" + returnsResult,
Integer.toString(returnsResult),
// REMARKS
replaceNullWithEmpty(alias.getComment()),
// ID
"" + alias.getId(),
Integer.toString(alias.getId()),
// SOURCE
alias.getSource()
// when adding more columns, see also below
......@@ -1346,17 +1348,17 @@ public class MetaTable extends Table {
// JAVA_METHOD
"",
// DATA_TYPE
"" + DataType.convertTypeToSQLType(Value.NULL),
"" + Types.NULL,
// TYPE_NAME
DataType.getDataType(Value.NULL).name,
// COLUMN_COUNT INT
"1",
// RETURNS_RESULT SMALLINT
"" + returnsResult,
Integer.toString(returnsResult),
// REMARKS
replaceNullWithEmpty(agg.getComment()),
// ID
"" + agg.getId(),
Integer.toString(agg.getId()),
// SOURCE
""
// when adding more columns, see also below
......@@ -1390,19 +1392,19 @@ public class MetaTable extends Table {
// JAVA_METHOD
alias.getJavaMethodName(),
// COLUMN_COUNT
"" + method.getParameterCount(),
Integer.toString(method.getParameterCount()),
// POS INT
"0",
// COLUMN_NAME
"P0",
// DATA_TYPE
"" + DataType.convertTypeToSQLType(method.getDataType()),
Integer.toString(DataType.convertTypeToSQLType(method.getDataType())),
// TYPE_NAME
dt.name,
// PRECISION INT
"" + MathUtils.convertLongToInt(dt.defaultPrecision),
Integer.toString(MathUtils.convertLongToInt(dt.defaultPrecision)),
// SCALE
"" + dt.defaultScale,
Integer.toString(dt.defaultScale),
// RADIX
"10",
// NULLABLE SMALLINT
......@@ -1437,23 +1439,23 @@ public class MetaTable extends Table {
// JAVA_METHOD
alias.getJavaMethodName(),
// COLUMN_COUNT
"" + method.getParameterCount(),
Integer.toString(method.getParameterCount()),
// POS INT
"" + (k + (method.hasConnectionParam() ? 0 : 1)),
Integer.toString(k + (method.hasConnectionParam() ? 0 : 1)),
// COLUMN_NAME
"P" + (k + 1),
// DATA_TYPE
"" + DataType.convertTypeToSQLType(dt.type),
Integer.toString(DataType.convertTypeToSQLType(dt.type)),
// TYPE_NAME
dt.name,
// PRECISION INT
"" + MathUtils.convertLongToInt(dt.defaultPrecision),
Integer.toString(MathUtils.convertLongToInt(dt.defaultPrecision)),
// SCALE
"" + dt.defaultScale,
Integer.toString(dt.defaultScale),
// RADIX
"10",
// NULLABLE SMALLINT
"" + nullable,
Integer.toString(nullable),
// COLUMN_TYPE
"" + DatabaseMetaData.procedureColumnIn,
// REMARKS
......@@ -1486,7 +1488,7 @@ public class MetaTable extends Table {
// REMARKS
replaceNullWithEmpty(schema.getComment()),
// ID
"" + schema.getId()
Integer.toString(schema.getId())
);
}
break;
......@@ -1572,7 +1574,7 @@ public class MetaTable extends Table {
// REMARKS
replaceNullWithEmpty(view.getComment()),
// ID
"" + view.getId()
Integer.toString(view.getId())
);
}
break;
......@@ -1708,7 +1710,7 @@ public class MetaTable extends Table {
// SQL
constraint.getCreateSQL(),
// ID
"" + constraint.getId()
Integer.toString(constraint.getId())
);
}
break;
......@@ -1726,13 +1728,13 @@ public class MetaTable extends Table {
// CONSTANT_NAME
identifier(constant.getName()),
// CONSTANT_TYPE
"" + DataType.convertTypeToSQLType(expr.getType()),
Integer.toString(DataType.convertTypeToSQLType(expr.getType())),
// REMARKS
replaceNullWithEmpty(constant.getComment()),
// SQL
expr.getSQL(),
// ID
"" + constant.getId()
Integer.toString(constant.getId())
);
}
break;
......@@ -1752,15 +1754,15 @@ public class MetaTable extends Table {
// IS_NULLABLE
col.isNullable() ? "YES" : "NO",
// DATA_TYPE
"" + col.getDataType().sqlType,
Integer.toString(col.getDataType().sqlType),
// PRECISION INT
"" + col.getPrecisionAsInt(),
Integer.toString(col.getPrecisionAsInt()),
// SCALE INT
"" + col.getScale(),
Integer.toString(col.getScale()),
// TYPE_NAME
col.getDataType().name,
// SELECTIVITY INT
"" + col.getSelectivity(),
Integer.toString(col.getSelectivity()),
// CHECK_CONSTRAINT
"" + col.getCheckConstraintSQL(session, "VALUE"),
// REMARKS
......@@ -1768,7 +1770,7 @@ public class MetaTable extends Table {
// SQL
"" + dt.getCreateSQL(),
// ID
"" + dt.getId()
Integer.toString(dt.getId())
);
}
break;
......@@ -1794,19 +1796,19 @@ public class MetaTable extends Table {
// TABLE_NAME
identifier(table.getName()),
// BEFORE BIT
"" + trigger.isBefore(),
Boolean.toString(trigger.isBefore()),
// JAVA_CLASS
trigger.getTriggerClassName(),
// QUEUE_SIZE INT
"" + trigger.getQueueSize(),
Integer.toString(trigger.getQueueSize()),
// NO_WAIT BIT
"" + trigger.isNoWait(),
Boolean.toString(trigger.isNoWait()),
// REMARKS
replaceNullWithEmpty(trigger.getComment()),
// SQL
trigger.getCreateSQL(),
// ID
"" + trigger.getId()
Integer.toString(trigger.getId())
);
}
break;
......@@ -1822,7 +1824,7 @@ public class MetaTable extends Table {
}
add(rows,
// ID
"" + s.getId(),
Integer.toString(s.getId()),
// USER_NAME
s.getUser().getName(),
// SESSION_START
......@@ -1832,7 +1834,7 @@ public class MetaTable extends Table {
// STATEMENT_START
new Timestamp(start).toString(),
// CONTAINS_UNCOMMITTED
"" + s.containsUncommitted()
Boolean.toString(s.containsUncommitted())
);
}
}
......@@ -1848,7 +1850,7 @@ public class MetaTable extends Table {
// TABLE_NAME
table.getName(),
// SESSION_ID
"" + s.getId(),
Integer.toString(s.getId()),
// LOCK_TYPE
table.isLockedExclusivelyBy(s) ? "WRITE" : "READ"
);
......@@ -1909,27 +1911,27 @@ public class MetaTable extends Table {
// SQL_STATEMENT
entry.sqlStatement,
// EXECUTION_COUNT
"" + entry.count,
Integer.toString(entry.count),
// MIN_EXECUTION_TIME
"" + entry.executionTimeMinNanos / 1000d / 1000,
Double.toString(entry.executionTimeMinNanos / 1_000_000d),
// MAX_EXECUTION_TIME
"" + entry.executionTimeMaxNanos / 1000d / 1000,
Double.toString(entry.executionTimeMaxNanos / 1_000_000d),
// CUMULATIVE_EXECUTION_TIME
"" + entry.executionTimeCumulativeNanos / 1000d / 1000,
Double.toString(entry.executionTimeCumulativeNanos / 1_000_000d),
// AVERAGE_EXECUTION_TIME
"" + entry.executionTimeMeanNanos / 1000d / 1000,
Double.toString(entry.executionTimeMeanNanos / 1_000_000d),
// STD_DEV_EXECUTION_TIME
"" + entry.getExecutionTimeStandardDeviation() / 1000d / 1000,
Double.toString(entry.getExecutionTimeStandardDeviation() / 1_000_000d),
// MIN_ROW_COUNT
"" + entry.rowCountMin,
Integer.toString(entry.rowCountMin),
// MAX_ROW_COUNT
"" + entry.rowCountMax,
Integer.toString(entry.rowCountMax),
// CUMULATIVE_ROW_COUNT
"" + entry.rowCountCumulative,
Long.toString(entry.rowCountCumulative),
// AVERAGE_ROW_COUNT
"" + entry.rowCountMean,
Double.toString(entry.rowCountMean),
// STD_DEV_ROW_COUNT
"" + entry.getRowCountStandardDeviation()
Double.toString(entry.getRowCountStandardDeviation())
);
}
}
......@@ -1955,7 +1957,7 @@ public class MetaTable extends Table {
// REMARKS
replaceNullWithEmpty(synonym.getComment()),
// ID
"" + synonym.getId()
Integer.toString(synonym.getId())
);
}
break;
......
......@@ -808,7 +808,7 @@ public class TableFilter implements ColumnResolver {
IndexLookupBatch lookupBatch = joinBatch.getLookupBatch(joinFilterId);
if (lookupBatch == null) {
if (joinFilterId != 0) {
throw DbException.throwInternalError("" + joinFilterId);
throw DbException.throwInternalError(Integer.toString(joinFilterId));
}
} else {
planBuff.append("batched:");
......
......@@ -264,7 +264,7 @@ public class CompressTool {
default:
throw DbException.get(
ErrorCode.UNSUPPORTED_COMPRESSION_ALGORITHM_1,
"" + algorithm);
Integer.toString(algorithm));
}
}
......
......@@ -65,7 +65,7 @@ public class MultiDimension implements Comparator<long[]> {
*/
public int getMaxValue(int dimensions) {
if (dimensions < 2 || dimensions > 32) {
throw new IllegalArgumentException("" + dimensions);
throw new IllegalArgumentException(Integer.toString(dimensions));
}
int bitsPerValue = getBitsPerValue(dimensions);
return (int) ((1L << bitsPerValue) - 1);
......@@ -270,18 +270,18 @@ public class MultiDimension implements Comparator<long[]> {
private void addMortonRanges(ArrayList<long[]> list, int[] min, int[] max,
int len, int level) {
if (level > 100) {
throw new IllegalArgumentException("" + level);
throw new IllegalArgumentException(Integer.toString(level));
}
int largest = 0, largestDiff = 0;
long size = 1;
for (int i = 0; i < len; i++) {
int diff = max[i] - min[i];
if (diff < 0) {
throw new IllegalArgumentException(""+ diff);
throw new IllegalArgumentException(Integer.toString(diff));
}
size *= diff + 1;
if (size < 0) {
throw new IllegalArgumentException("" + size);
throw new IllegalArgumentException(Long.toString(size));
}
if (diff > largestDiff) {
largestDiff = diff;
......
......@@ -102,7 +102,8 @@ public class ColumnNamer {
}
// go with a innocuous default name pattern
if (columnName == null) {
columnName = configuration.getDefaultColumnNamePattern().replace("$$", "" + (indexOfColumn + 1));
columnName = configuration.getDefaultColumnNamePattern()
.replace("$$", Integer.toString(indexOfColumn + 1));
}
if (existingColumnNames.contains(columnName) && configuration.isGenerateUniqueColumnNames()) {
columnName = generateUniqueName(columnName);
......
......@@ -86,7 +86,7 @@ public abstract class LazyFuture<T> implements Future<T> {
case S_CANCELED:
throw new CancellationException();
default:
throw DbException.throwInternalError("" + state);
throw DbException.throwInternalError(Integer.toString(state));
}
}
......
......@@ -178,7 +178,7 @@ public class NetUtils {
return new ServerSocket(port, 0, bindAddress);
} catch (BindException be) {
throw DbException.get(ErrorCode.EXCEPTION_OPENING_PORT_2,
be, "" + port, be.toString());
be, Integer.toString(port), be.toString());
} catch (IOException e) {
throw DbException.convertIOException(e, "port: " + port + " ssl: " + ssl);
}
......
......@@ -207,7 +207,7 @@ public class Profiler implements Runnable {
private static List<Object[]> readRunnableStackTraces(int pid) {
try {
String jstack = exec("jstack", "" + pid);
String jstack = exec("jstack", Integer.toString(pid));
LineNumberReader r = new LineNumberReader(
new StringReader(jstack));
return readStackTrace(r);
......
......@@ -69,7 +69,7 @@ public class SortedProperties extends Properties {
* @return the value if set, or the default value if not
*/
public static int getIntProperty(Properties prop, String key, int def) {
String value = prop.getProperty(key, "" + def);
String value = prop.getProperty(key, Integer.toString(def));
try {
return Integer.decode(value);
} catch (Exception e) {
......
......@@ -948,7 +948,7 @@ public class DataType {
return Value.RESULT_SET;
default:
throw DbException.get(
ErrorCode.UNKNOWN_DATA_TYPE_1, "" + sqlType);
ErrorCode.UNKNOWN_DATA_TYPE_1, Integer.toString(sqlType));
}
}
......
......@@ -779,7 +779,7 @@ public abstract class Value {
double d = getDouble();
if (Double.isInfinite(d) || Double.isNaN(d)) {
throw DbException.get(
ErrorCode.DATA_CONVERSION_ERROR_1, "" + d);
ErrorCode.DATA_CONVERSION_ERROR_1, Double.toString(d));
}
return ValueDecimal.get(BigDecimal.valueOf(d));
}
......@@ -787,7 +787,7 @@ public abstract class Value {
float f = getFloat();
if (Float.isInfinite(f) || Float.isNaN(f)) {
throw DbException.get(
ErrorCode.DATA_CONVERSION_ERROR_1, "" + f);
ErrorCode.DATA_CONVERSION_ERROR_1, Float.toString(f));
}
// better rounding behavior than BigDecimal.valueOf(f)
return ValueDecimal.get(new BigDecimal(Float.toString(f)));
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论