Skip to content
项目
群组
代码片段
帮助
正在加载...
帮助
为 GitLab 提交贡献
登录/注册
切换导航
H
h2database
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分枝图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
计划
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
分枝图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
Administrator
h2database
Commits
1393df91
Unverified
提交
1393df91
authored
8月 17, 2018
作者:
Noel Grandin
提交者:
GitHub
8月 17, 2018
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #1385 from grandinj/split_up_value_convert
split up the rather large convertTo method
上级
8ea97a61
a273cb37
显示空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
559 行增加
和
556 行删除
+559
-556
Value.java
h2/src/main/org/h2/value/Value.java
+559
-556
没有找到文件。
h2/src/main/org/h2/value/Value.java
浏览文件 @
1393df91
...
...
@@ -716,9 +716,84 @@ public abstract class Value {
return
this
;
}
try
{
// decimal conversion
switch
(
targetType
)
{
case
BOOLEAN:
{
case
NULL:
return
ValueNull
.
INSTANCE
;
case
BOOLEAN:
return
convertToBoolean
();
case
BYTE:
return
convertToByte
(
column
);
case
SHORT:
return
convertToShort
(
column
);
case
INT:
return
convertToInt
(
column
);
case
LONG:
return
convertToLong
(
column
);
case
DECIMAL:
return
convertToDecimal
();
case
DOUBLE:
return
convertToDouble
();
case
FLOAT:
return
convertToFloat
();
case
DATE:
return
convertToDate
();
case
TIME:
return
convertToTime
();
case
TIMESTAMP:
return
convertToTimestamp
(
mode
);
case
TIMESTAMP_TZ:
return
convertToTimestampTimeZone
();
case
BYTES:
return
convertToBytes
(
mode
);
case
STRING:
return
convertToString
(
mode
);
case
STRING_IGNORECASE:
return
convertToStringIgnoreCase
(
mode
);
case
STRING_FIXED:
return
convertToStringFixed
(
precision
,
mode
);
case
JAVA_OBJECT:
return
convertToJavaObject
();
case
ENUM:
return
convertToEnumInternal
(
enumerators
);
case
BLOB:
return
convertToBlob
();
case
CLOB:
return
convertToClob
();
case
UUID:
return
convertToUuid
();
case
GEOMETRY:
return
convertToGeometry
();
case
Value
.
INTERVAL_YEAR
:
case
Value
.
INTERVAL_MONTH
:
case
Value
.
INTERVAL_YEAR_TO_MONTH
:
return
convertToIntervalYearMonth
(
targetType
);
case
Value
.
INTERVAL_DAY
:
case
Value
.
INTERVAL_HOUR
:
case
Value
.
INTERVAL_MINUTE
:
case
Value
.
INTERVAL_SECOND
:
case
Value
.
INTERVAL_DAY_TO_HOUR
:
case
Value
.
INTERVAL_DAY_TO_MINUTE
:
case
Value
.
INTERVAL_DAY_TO_SECOND
:
case
Value
.
INTERVAL_HOUR_TO_MINUTE
:
case
Value
.
INTERVAL_HOUR_TO_SECOND
:
case
Value
.
INTERVAL_MINUTE_TO_SECOND
:
return
convertToIntervalDayTime
(
targetType
);
case
ARRAY:
return
convertToArray
();
case
RESULT_SET:
return
convertToResultSet
();
default
:
if
(
JdbcUtils
.
customDataTypesHandler
!=
null
)
{
return
JdbcUtils
.
customDataTypesHandler
.
convert
(
this
,
targetType
);
}
throw
getDataConversionError
(
targetType
);
}
}
catch
(
NumberFormatException
e
)
{
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
e
,
getString
());
}
}
private
ValueBoolean
convertToBoolean
()
{
switch
(
getType
())
{
case
BYTE:
case
SHORT:
...
...
@@ -736,12 +811,22 @@ public abstract class Value {
case
JAVA_OBJECT:
case
UUID:
case
ENUM:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
BOOLEAN
);
}
String
s
=
getString
();
if
(
s
.
equalsIgnoreCase
(
"true"
)
||
s
.
equalsIgnoreCase
(
"t"
)
||
s
.
equalsIgnoreCase
(
"yes"
)
||
s
.
equalsIgnoreCase
(
"y"
))
{
return
ValueBoolean
.
TRUE
;
}
else
if
(
s
.
equalsIgnoreCase
(
"false"
)
||
s
.
equalsIgnoreCase
(
"f"
)
||
s
.
equalsIgnoreCase
(
"no"
)
||
s
.
equalsIgnoreCase
(
"n"
))
{
return
ValueBoolean
.
FALSE
;
}
else
{
// convert to a number, and if it is not 0 then it is true
return
ValueBoolean
.
get
(
new
BigDecimal
(
s
).
signum
()
!=
0
);
}
break
;
}
case
BYTE:
{
private
ValueByte
convertToByte
(
Object
column
)
{
switch
(
getType
())
{
case
BOOLEAN:
return
ValueByte
.
get
(
getBoolean
()
?
(
byte
)
1
:
(
byte
)
0
);
...
...
@@ -760,12 +845,12 @@ public abstract class Value {
case
BYTES:
return
ValueByte
.
get
((
byte
)
Integer
.
parseInt
(
getString
(),
16
));
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
BYTE
);
}
break
;
return
ValueByte
.
get
(
Byte
.
parseByte
(
getString
().
trim
()))
;
}
case
SHORT:
{
private
ValueShort
convertToShort
(
Object
column
)
{
switch
(
getType
())
{
case
BOOLEAN:
return
ValueShort
.
get
(
getBoolean
()
?
(
short
)
1
:
(
short
)
0
);
...
...
@@ -785,12 +870,12 @@ public abstract class Value {
case
BYTES:
return
ValueShort
.
get
((
short
)
Integer
.
parseInt
(
getString
(),
16
));
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
SHORT
);
}
break
;
return
ValueShort
.
get
(
Short
.
parseShort
(
getString
().
trim
()))
;
}
case
INT:
{
private
ValueInt
convertToInt
(
Object
column
)
{
switch
(
getType
())
{
case
BOOLEAN:
return
ValueInt
.
get
(
getBoolean
()
?
1
:
0
);
...
...
@@ -809,12 +894,12 @@ public abstract class Value {
case
BYTES:
return
ValueInt
.
get
((
int
)
Long
.
parseLong
(
getString
(),
16
));
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
INT
);
}
break
;
return
ValueInt
.
get
(
Integer
.
parseInt
(
getString
().
trim
()))
;
}
case
LONG:
{
private
ValueLong
convertToLong
(
Object
column
)
{
switch
(
getType
())
{
case
BOOLEAN:
return
ValueLong
.
get
(
getBoolean
()
?
1
:
0
);
...
...
@@ -838,12 +923,12 @@ public abstract class Value {
return
ValueLong
.
get
(
Long
.
parseLong
(
getString
(),
16
));
}
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
LONG
);
}
break
;
return
ValueLong
.
get
(
Long
.
parseLong
(
getString
().
trim
()))
;
}
case
DECIMAL:
{
private
ValueDecimal
convertToDecimal
()
{
switch
(
getType
())
{
case
BOOLEAN:
return
(
ValueDecimal
)
(
getBoolean
()
?
ValueDecimal
.
ONE
:
ValueDecimal
.
ZERO
);
...
...
@@ -857,27 +942,25 @@ public abstract class Value {
case
DOUBLE:
{
double
d
=
getDouble
();
if
(
Double
.
isInfinite
(
d
)
||
Double
.
isNaN
(
d
))
{
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
Double
.
toString
(
d
));
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
Double
.
toString
(
d
));
}
return
ValueDecimal
.
get
(
BigDecimal
.
valueOf
(
d
));
}
case
FLOAT:
{
float
f
=
getFloat
();
if
(
Float
.
isInfinite
(
f
)
||
Float
.
isNaN
(
f
))
{
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
Float
.
toString
(
f
));
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
Float
.
toString
(
f
));
}
// better rounding behavior than BigDecimal.valueOf(f)
return
ValueDecimal
.
get
(
new
BigDecimal
(
Float
.
toString
(
f
)));
}
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
DECIMAL
);
}
break
;
return
ValueDecimal
.
get
(
new
BigDecimal
(
getString
().
trim
()))
;
}
case
DOUBLE:
{
private
ValueDouble
convertToDouble
()
{
switch
(
getType
())
{
case
BOOLEAN:
return
ValueDouble
.
get
(
getBoolean
()
?
1
:
0
);
...
...
@@ -893,12 +976,12 @@ public abstract class Value {
return
ValueDouble
.
get
(
getFloat
());
case
ENUM:
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
DOUBLE
);
}
break
;
return
ValueDouble
.
get
(
Double
.
parseDouble
(
getString
().
trim
()))
;
}
case
FLOAT:
{
private
ValueFloat
convertToFloat
()
{
switch
(
getType
())
{
case
BOOLEAN:
return
ValueFloat
.
get
(
getBoolean
()
?
1
:
0
);
...
...
@@ -914,20 +997,19 @@ public abstract class Value {
return
ValueFloat
.
get
((
float
)
getDouble
());
case
ENUM:
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
FLOAT
);
}
break
;
return
ValueFloat
.
get
(
Float
.
parseFloat
(
getString
().
trim
()))
;
}
case
DATE:
{
private
ValueDate
convertToDate
()
{
switch
(
getType
())
{
case
TIME:
// because the time has set the date to 1970-01-01,
// this will be the result
return
ValueDate
.
fromDateValue
(
DateTimeUtils
.
EPOCH_DATE_VALUE
);
case
TIMESTAMP:
return
ValueDate
.
fromDateValue
(
((
ValueTimestamp
)
this
).
getDateValue
());
return
ValueDate
.
fromDateValue
(((
ValueTimestamp
)
this
).
getDateValue
());
case
TIMESTAMP_TZ:
{
ValueTimestampTimeZone
ts
=
(
ValueTimestampTimeZone
)
this
;
long
dateValue
=
ts
.
getDateValue
(),
timeNanos
=
ts
.
getTimeNanos
();
...
...
@@ -935,20 +1017,19 @@ public abstract class Value {
return
ValueDate
.
fromMillis
(
millis
);
}
case
ENUM:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
DATE
);
}
break
;
return
ValueDate
.
parse
(
getString
().
trim
())
;
}
case
TIME:
{
private
ValueTime
convertToTime
()
{
switch
(
getType
())
{
case
DATE:
// need to normalize the year, month and day because a date
// has the time set to 0, the result will be 0
return
ValueTime
.
fromNanos
(
0
);
case
TIMESTAMP:
return
ValueTime
.
fromNanos
(
((
ValueTimestamp
)
this
).
getTimeNanos
());
return
ValueTime
.
fromNanos
(((
ValueTimestamp
)
this
).
getTimeNanos
());
case
TIMESTAMP_TZ:
{
ValueTimestampTimeZone
ts
=
(
ValueTimestampTimeZone
)
this
;
long
dateValue
=
ts
.
getDateValue
(),
timeNanos
=
ts
.
getTimeNanos
();
...
...
@@ -956,19 +1037,17 @@ public abstract class Value {
return
ValueTime
.
fromNanos
(
DateTimeUtils
.
nanosFromDate
(
millis
)
+
timeNanos
%
1_000_000
);
}
case
ENUM:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
TIME
);
}
break
;
return
ValueTime
.
parse
(
getString
().
trim
())
;
}
case
TIMESTAMP:
{
private
ValueTimestamp
convertToTimestamp
(
Mode
mode
)
{
switch
(
getType
())
{
case
TIME:
return
DateTimeUtils
.
normalizeTimestamp
(
0
,
((
ValueTime
)
this
).
getNanos
());
return
DateTimeUtils
.
normalizeTimestamp
(
0
,
((
ValueTime
)
this
).
getNanos
());
case
DATE:
return
ValueTimestamp
.
fromDateValueAndNanos
(
((
ValueDate
)
this
).
getDateValue
(),
0
);
return
ValueTimestamp
.
fromDateValueAndNanos
(((
ValueDate
)
this
).
getDateValue
(),
0
);
case
TIMESTAMP_TZ:
{
ValueTimestampTimeZone
ts
=
(
ValueTimestampTimeZone
)
this
;
long
dateValue
=
ts
.
getDateValue
(),
timeNanos
=
ts
.
getTimeNanos
();
...
...
@@ -976,33 +1055,30 @@ public abstract class Value {
return
ValueTimestamp
.
fromMillisNanos
(
millis
,
(
int
)
(
timeNanos
%
1_000_000
));
}
case
ENUM:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
TIMESTAMP
);
}
break
;
return
ValueTimestamp
.
parse
(
getString
().
trim
(),
mode
)
;
}
case
TIMESTAMP_TZ:
{
private
ValueTimestampTimeZone
convertToTimestampTimeZone
()
{
switch
(
getType
())
{
case
TIME:
{
ValueTimestamp
ts
=
DateTimeUtils
.
normalizeTimestamp
(
0
,
((
ValueTime
)
this
).
getNanos
());
return
DateTimeUtils
.
timestampTimeZoneFromLocalDateValueAndNanos
(
ts
.
getDateValue
(),
ts
.
getTimeNanos
());
return
DateTimeUtils
.
timestampTimeZoneFromLocalDateValueAndNanos
(
ts
.
getDateValue
(),
ts
.
getTimeNanos
());
}
case
DATE:
return
DateTimeUtils
.
timestampTimeZoneFromLocalDateValueAndNanos
(
((
ValueDate
)
this
).
getDateValue
(),
0
);
return
DateTimeUtils
.
timestampTimeZoneFromLocalDateValueAndNanos
(((
ValueDate
)
this
).
getDateValue
(),
0
);
case
TIMESTAMP:
{
ValueTimestamp
ts
=
(
ValueTimestamp
)
this
;
return
DateTimeUtils
.
timestampTimeZoneFromLocalDateValueAndNanos
(
ts
.
getDateValue
(),
ts
.
getTimeNanos
());
return
DateTimeUtils
.
timestampTimeZoneFromLocalDateValueAndNanos
(
ts
.
getDateValue
(),
ts
.
getTimeNanos
());
}
case
ENUM:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
TIMESTAMP_TZ
);
}
break
;
return
ValueTimestampTimeZone
.
parse
(
getString
().
trim
())
;
}
case
BYTES:
{
private
ValueBytes
convertToBytes
(
Mode
mode
)
{
switch
(
getType
())
{
case
JAVA_OBJECT:
case
BLOB:
...
...
@@ -1011,13 +1087,10 @@ public abstract class Value {
case
GEOMETRY:
return
ValueBytes
.
getNoCopy
(
getBytes
());
case
BYTE:
return
ValueBytes
.
getNoCopy
(
new
byte
[]{
getByte
()
});
return
ValueBytes
.
getNoCopy
(
new
byte
[]
{
getByte
()
});
case
SHORT:
{
int
x
=
getShort
();
return
ValueBytes
.
getNoCopy
(
new
byte
[]{
(
byte
)
(
x
>>
8
),
(
byte
)
x
});
return
ValueBytes
.
getNoCopy
(
new
byte
[]
{
(
byte
)
(
x
>>
8
),
(
byte
)
x
});
}
case
INT:
{
byte
[]
b
=
new
byte
[
4
];
...
...
@@ -1031,12 +1104,14 @@ public abstract class Value {
}
case
ENUM:
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
BYTES
);
}
break
;
String
s
=
getString
();
return
ValueBytes
.
getNoCopy
(
mode
!=
null
&&
mode
.
charToBinaryInUtf8
?
s
.
getBytes
(
StandardCharsets
.
UTF_8
)
:
StringUtils
.
convertHexToBytes
(
s
.
trim
()));
}
case
STRING:
{
private
ValueString
convertToString
(
Mode
mode
)
{
String
s
;
if
(
getType
()
==
BYTES
&&
mode
!=
null
&&
mode
.
charToBinaryInUtf8
)
{
// Bugfix - Can't use the locale encoding when enabling
...
...
@@ -1047,9 +1122,10 @@ public abstract class Value {
}
else
{
s
=
getString
();
}
return
ValueString
.
get
(
s
);
return
(
ValueString
)
ValueString
.
get
(
s
);
}
case
STRING_IGNORECASE:
{
private
ValueString
convertToStringIgnoreCase
(
Mode
mode
)
{
String
s
;
if
(
getType
()
==
BYTES
&&
mode
!=
null
&&
mode
.
charToBinaryInUtf8
)
{
s
=
new
String
(
getBytesNoCopy
(),
StandardCharsets
.
UTF_8
);
...
...
@@ -1058,7 +1134,8 @@ public abstract class Value {
}
return
ValueStringIgnoreCase
.
get
(
s
);
}
case
STRING_FIXED:
{
private
ValueString
convertToStringFixed
(
int
precision
,
Mode
mode
)
{
String
s
;
if
(
getType
()
==
BYTES
&&
mode
!=
null
&&
mode
.
charToBinaryInUtf8
)
{
s
=
new
String
(
getBytesNoCopy
(),
StandardCharsets
.
UTF_8
);
...
...
@@ -1067,20 +1144,20 @@ public abstract class Value {
}
return
ValueStringFixed
.
get
(
s
,
precision
,
mode
);
}
case
JAVA_OBJECT:
{
private
ValueJavaObject
convertToJavaObject
()
{
switch
(
getType
())
{
case
BYTES:
case
BLOB:
return
ValueJavaObject
.
getNoCopy
(
null
,
getBytesNoCopy
(),
getDataHandler
());
return
ValueJavaObject
.
getNoCopy
(
null
,
getBytesNoCopy
(),
getDataHandler
());
case
ENUM:
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
JAVA_OBJECT
);
}
break
;
return
ValueJavaObject
.
getNoCopy
(
null
,
StringUtils
.
convertHexToBytes
(
getString
().
trim
()),
getDataHandler
())
;
}
case
ENUM:
{
private
ValueEnum
convertToEnumInternal
(
String
[]
enumerators
)
{
switch
(
getType
())
{
case
BYTE:
case
SHORT:
...
...
@@ -1093,48 +1170,48 @@ public abstract class Value {
case
STRING_FIXED:
return
ValueEnum
.
get
(
enumerators
,
getString
());
case
JAVA_OBJECT:
Object
object
=
JdbcUtils
.
deserialize
(
getBytesNoCopy
(),
getDataHandler
());
Object
object
=
JdbcUtils
.
deserialize
(
getBytesNoCopy
(),
getDataHandler
());
if
(
object
instanceof
String
)
{
return
ValueEnum
.
get
(
enumerators
,
(
String
)
object
);
}
else
if
(
object
instanceof
Integer
)
{
return
ValueEnum
.
get
(
enumerators
,
(
int
)
object
);
}
//$FALL-THROUGH$
default
:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
}
throw
getDataConversionError
(
ENUM
);
}
case
BLOB:
{
private
ValueLobDb
convertToBlob
()
{
switch
(
getType
())
{
case
BYTES:
return
ValueLobDb
.
createSmallLob
(
Value
.
BLOB
,
getBytesNoCopy
());
return
ValueLobDb
.
createSmallLob
(
Value
.
BLOB
,
getBytesNoCopy
());
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
BLOB
);
}
break
;
return
ValueLobDb
.
createSmallLob
(
BLOB
,
StringUtils
.
convertHexToBytes
(
getString
().
trim
()));
}
private
ValueLobDb
convertToClob
()
{
return
ValueLobDb
.
createSmallLob
(
CLOB
,
getString
().
getBytes
(
StandardCharsets
.
UTF_8
));
}
case
UUID:
{
private
ValueUuid
convertToUuid
()
{
switch
(
getType
())
{
case
BYTES:
return
ValueUuid
.
get
(
getBytesNoCopy
());
case
JAVA_OBJECT:
Object
object
=
JdbcUtils
.
deserialize
(
getBytesNoCopy
(),
getDataHandler
());
Object
object
=
JdbcUtils
.
deserialize
(
getBytesNoCopy
(),
getDataHandler
());
if
(
object
instanceof
java
.
util
.
UUID
)
{
return
ValueUuid
.
get
((
java
.
util
.
UUID
)
object
);
}
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
//$FALL-THROUGH$
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
UUID
);
}
break
;
return
ValueUuid
.
get
(
getString
())
;
}
case
GEOMETRY:
{
private
ValueGeometry
convertToGeometry
()
{
switch
(
getType
())
{
case
BYTES:
return
ValueGeometry
.
get
(
getBytesNoCopy
());
...
...
@@ -1145,22 +1222,20 @@ public abstract class Value {
}
//$FALL-THROUGH$
case
TIMESTAMP_TZ:
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
getString
());
throw
getDataConversionError
(
GEOMETRY
);
}
break
;
return
ValueGeometry
.
get
(
getString
())
;
}
case
Value
.
INTERVAL_YEAR
:
case
Value
.
INTERVAL_MONTH
:
case
Value
.
INTERVAL_YEAR_TO_MONTH
:
private
ValueInterval
convertToIntervalYearMonth
(
int
targetType
)
{
switch
(
getType
())
{
case
Value
.
STRING
:
case
Value
.
STRING_IGNORECASE
:
case
Value
.
STRING_FIXED
:
{
String
s
=
getString
();
try
{
return
DateTimeUtils
.
parseFormattedInterval
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
s
)
return
(
ValueInterval
)
DateTimeUtils
.
parseFormattedInterval
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
s
)
.
convertTo
(
targetType
);
}
catch
(
Exception
e
)
{
throw
DbException
.
get
(
ErrorCode
.
INVALID_DATETIME_CONSTANT_2
,
e
,
"INTERVAL"
,
s
);
...
...
@@ -1169,29 +1244,21 @@ public abstract class Value {
case
Value
.
INTERVAL_YEAR
:
case
Value
.
INTERVAL_MONTH
:
case
Value
.
INTERVAL_YEAR_TO_MONTH
:
return
DateTimeUtils
.
intervalFromAbsolute
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
return
DateTimeUtils
.
intervalFromAbsolute
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
DateTimeUtils
.
intervalToAbsolute
((
ValueInterval
)
this
));
}
break
;
case
Value
.
INTERVAL_DAY
:
case
Value
.
INTERVAL_HOUR
:
case
Value
.
INTERVAL_MINUTE
:
case
Value
.
INTERVAL_SECOND
:
case
Value
.
INTERVAL_DAY_TO_HOUR
:
case
Value
.
INTERVAL_DAY_TO_MINUTE
:
case
Value
.
INTERVAL_DAY_TO_SECOND
:
case
Value
.
INTERVAL_HOUR_TO_MINUTE
:
case
Value
.
INTERVAL_HOUR_TO_SECOND
:
case
Value
.
INTERVAL_MINUTE_TO_SECOND
:
throw
getDataConversionError
(
targetType
);
}
private
ValueInterval
convertToIntervalDayTime
(
int
targetType
)
{
switch
(
getType
())
{
case
Value
.
STRING
:
case
Value
.
STRING_IGNORECASE
:
case
Value
.
STRING_FIXED
:
{
String
s
=
getString
();
try
{
return
DateTimeUtils
.
parseFormattedInterval
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
s
)
return
(
ValueInterval
)
DateTimeUtils
.
parseFormattedInterval
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
s
)
.
convertTo
(
targetType
);
}
catch
(
Exception
e
)
{
throw
DbException
.
get
(
ErrorCode
.
INVALID_DATETIME_CONSTANT_2
,
e
,
"INTERVAL"
,
s
);
...
...
@@ -1207,94 +1274,30 @@ public abstract class Value {
case
Value
.
INTERVAL_HOUR_TO_MINUTE
:
case
Value
.
INTERVAL_HOUR_TO_SECOND
:
case
Value
.
INTERVAL_MINUTE_TO_SECOND
:
return
DateTimeUtils
.
intervalFromAbsolute
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
return
DateTimeUtils
.
intervalFromAbsolute
(
IntervalQualifier
.
valueOf
(
targetType
-
Value
.
INTERVAL_YEAR
),
DateTimeUtils
.
intervalToAbsolute
((
ValueInterval
)
this
));
}
break
;
}
// conversion by parsing the string value
String
s
=
getString
();
switch
(
targetType
)
{
case
NULL:
return
ValueNull
.
INSTANCE
;
case
BOOLEAN:
{
if
(
s
.
equalsIgnoreCase
(
"true"
)
||
s
.
equalsIgnoreCase
(
"t"
)
||
s
.
equalsIgnoreCase
(
"yes"
)
||
s
.
equalsIgnoreCase
(
"y"
))
{
return
ValueBoolean
.
TRUE
;
}
else
if
(
s
.
equalsIgnoreCase
(
"false"
)
||
s
.
equalsIgnoreCase
(
"f"
)
||
s
.
equalsIgnoreCase
(
"no"
)
||
s
.
equalsIgnoreCase
(
"n"
))
{
return
ValueBoolean
.
FALSE
;
}
else
{
// convert to a number, and if it is not 0 then it is true
return
ValueBoolean
.
get
(
new
BigDecimal
(
s
).
signum
()
!=
0
);
throw
getDataConversionError
(
targetType
);
}
private
ValueArray
convertToArray
()
{
return
ValueArray
.
get
(
new
Value
[]
{
ValueString
.
get
(
getString
())
});
}
case
BYTE:
return
ValueByte
.
get
(
Byte
.
parseByte
(
s
.
trim
()));
case
SHORT:
return
ValueShort
.
get
(
Short
.
parseShort
(
s
.
trim
()));
case
INT:
return
ValueInt
.
get
(
Integer
.
parseInt
(
s
.
trim
()));
case
LONG:
return
ValueLong
.
get
(
Long
.
parseLong
(
s
.
trim
()));
case
DECIMAL:
return
ValueDecimal
.
get
(
new
BigDecimal
(
s
.
trim
()));
case
TIME:
return
ValueTime
.
parse
(
s
.
trim
());
case
DATE:
return
ValueDate
.
parse
(
s
.
trim
());
case
TIMESTAMP:
return
ValueTimestamp
.
parse
(
s
.
trim
(),
mode
);
case
TIMESTAMP_TZ:
return
ValueTimestampTimeZone
.
parse
(
s
.
trim
());
case
BYTES:
return
ValueBytes
.
getNoCopy
(
mode
!=
null
&&
mode
.
charToBinaryInUtf8
?
s
.
getBytes
(
StandardCharsets
.
UTF_8
):
StringUtils
.
convertHexToBytes
(
s
.
trim
()));
case
JAVA_OBJECT:
return
ValueJavaObject
.
getNoCopy
(
null
,
StringUtils
.
convertHexToBytes
(
s
.
trim
()),
getDataHandler
());
case
DOUBLE:
return
ValueDouble
.
get
(
Double
.
parseDouble
(
s
.
trim
()));
case
FLOAT:
return
ValueFloat
.
get
(
Float
.
parseFloat
(
s
.
trim
()));
case
CLOB:
return
ValueLobDb
.
createSmallLob
(
CLOB
,
s
.
getBytes
(
StandardCharsets
.
UTF_8
));
case
BLOB:
return
ValueLobDb
.
createSmallLob
(
BLOB
,
StringUtils
.
convertHexToBytes
(
s
.
trim
()));
case
ARRAY:
return
ValueArray
.
get
(
new
Value
[]{
ValueString
.
get
(
s
)});
case
RESULT_SET:
{
private
ValueResultSet
convertToResultSet
()
{
String
s
=
getString
();
SimpleResultSet
rs
=
new
SimpleResultSet
();
rs
.
setAutoClose
(
false
);
rs
.
addColumn
(
"X"
,
Types
.
VARCHAR
,
s
.
length
(),
0
);
rs
.
addRow
(
s
);
return
ValueResultSet
.
get
(
rs
);
}
case
UUID:
return
ValueUuid
.
get
(
s
);
case
GEOMETRY:
return
ValueGeometry
.
get
(
s
);
default
:
if
(
JdbcUtils
.
customDataTypesHandler
!=
null
)
{
return
JdbcUtils
.
customDataTypesHandler
.
convert
(
this
,
targetType
);
}
private
DbException
getDataConversionError
(
int
targetType
)
{
DataType
from
=
DataType
.
getDataType
(
getType
());
DataType
to
=
DataType
.
getDataType
(
targetType
);
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
(
from
!=
null
?
from
.
name
:
"type="
+
getType
())
+
" to "
+
(
to
!=
null
?
to
.
name
:
"type="
+
targetType
));
}
}
catch
(
NumberFormatException
e
)
{
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
e
,
getString
());
}
throw
DbException
.
get
(
ErrorCode
.
DATA_CONVERSION_ERROR_1
,
(
from
!=
null
?
from
.
name
:
"type="
+
getType
())
+
" to "
+
(
to
!=
null
?
to
.
name
:
"type="
+
targetType
));
}
/**
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论