Unverified 提交 94b736b5 authored 作者: Evgenij Ryazanov's avatar Evgenij Ryazanov 提交者: GitHub

Merge pull request #979 from katzyn/protocol

Remove support of TCP protocol versions 6 and 7
...@@ -45,18 +45,6 @@ public class Constants { ...@@ -45,18 +45,6 @@ public class Constants {
*/ */
public static final String BUILD_VENDOR_AND_VERSION = null; public static final String BUILD_VENDOR_AND_VERSION = null;
/**
* The TCP protocol version number 6.
* @since 1.0.72 (2008-05-10)
*/
public static final int TCP_PROTOCOL_VERSION_6 = 6;
/**
* The TCP protocol version number 7.
* @since 1.2.141 (2010-08-22)
*/
public static final int TCP_PROTOCOL_VERSION_7 = 7;
/** /**
* The TCP protocol version number 8. * The TCP protocol version number 8.
* @since 1.2.143 (2010-09-18) * @since 1.2.143 (2010-09-18)
...@@ -120,7 +108,7 @@ public class Constants { ...@@ -120,7 +108,7 @@ public class Constants {
/** /**
* Minimum supported version of TCP protocol. * Minimum supported version of TCP protocol.
*/ */
public static final int TCP_PROTOCOL_VERSION_MIN_SUPPORTED = TCP_PROTOCOL_VERSION_6; public static final int TCP_PROTOCOL_VERSION_MIN_SUPPORTED = TCP_PROTOCOL_VERSION_8;
/** /**
* Maximum supported version of TCP protocol. * Maximum supported version of TCP protocol.
......
...@@ -349,19 +349,15 @@ public class Transfer { ...@@ -349,19 +349,15 @@ public class Transfer {
case Value.TIME: case Value.TIME:
if (version >= Constants.TCP_PROTOCOL_VERSION_9) { if (version >= Constants.TCP_PROTOCOL_VERSION_9) {
writeLong(((ValueTime) v).getNanos()); writeLong(((ValueTime) v).getNanos());
} else if (version >= Constants.TCP_PROTOCOL_VERSION_7) {
writeLong(DateTimeUtils.getTimeLocalWithoutDst(v.getTime()));
} else { } else {
writeLong(v.getTime().getTime()); writeLong(DateTimeUtils.getTimeLocalWithoutDst(v.getTime()));
} }
break; break;
case Value.DATE: case Value.DATE:
if (version >= Constants.TCP_PROTOCOL_VERSION_9) { if (version >= Constants.TCP_PROTOCOL_VERSION_9) {
writeLong(((ValueDate) v).getDateValue()); writeLong(((ValueDate) v).getDateValue());
} else if (version >= Constants.TCP_PROTOCOL_VERSION_7) {
writeLong(DateTimeUtils.getTimeLocalWithoutDst(v.getDate()));
} else { } else {
writeLong(v.getDate().getTime()); writeLong(DateTimeUtils.getTimeLocalWithoutDst(v.getDate()));
} }
break; break;
case Value.TIMESTAMP: { case Value.TIMESTAMP: {
...@@ -369,13 +365,9 @@ public class Transfer { ...@@ -369,13 +365,9 @@ public class Transfer {
ValueTimestamp ts = (ValueTimestamp) v; ValueTimestamp ts = (ValueTimestamp) v;
writeLong(ts.getDateValue()); writeLong(ts.getDateValue());
writeLong(ts.getTimeNanos()); writeLong(ts.getTimeNanos());
} else if (version >= Constants.TCP_PROTOCOL_VERSION_7) {
Timestamp ts = v.getTimestamp();
writeLong(DateTimeUtils.getTimeLocalWithoutDst(ts));
writeInt(ts.getNanos() % 1_000_000);
} else { } else {
Timestamp ts = v.getTimestamp(); Timestamp ts = v.getTimestamp();
writeLong(ts.getTime()); writeLong(DateTimeUtils.getTimeLocalWithoutDst(ts));
writeInt(ts.getNanos() % 1_000_000); writeInt(ts.getNanos() % 1_000_000);
} }
break; break;
...@@ -555,28 +547,24 @@ public class Transfer { ...@@ -555,28 +547,24 @@ public class Transfer {
case Value.DATE: case Value.DATE:
if (version >= Constants.TCP_PROTOCOL_VERSION_9) { if (version >= Constants.TCP_PROTOCOL_VERSION_9) {
return ValueDate.fromDateValue(readLong()); return ValueDate.fromDateValue(readLong());
} else if (version >= Constants.TCP_PROTOCOL_VERSION_7) { } else {
return ValueDate.fromMillis(DateTimeUtils.getTimeUTCWithoutDst(readLong())); return ValueDate.fromMillis(DateTimeUtils.getTimeUTCWithoutDst(readLong()));
} }
return ValueDate.fromMillis(readLong());
case Value.TIME: case Value.TIME:
if (version >= Constants.TCP_PROTOCOL_VERSION_9) { if (version >= Constants.TCP_PROTOCOL_VERSION_9) {
return ValueTime.fromNanos(readLong()); return ValueTime.fromNanos(readLong());
} else if (version >= Constants.TCP_PROTOCOL_VERSION_7) { } else {
return ValueTime.fromMillis(DateTimeUtils.getTimeUTCWithoutDst(readLong())); return ValueTime.fromMillis(DateTimeUtils.getTimeUTCWithoutDst(readLong()));
} }
return ValueTime.fromMillis(readLong());
case Value.TIMESTAMP: { case Value.TIMESTAMP: {
if (version >= Constants.TCP_PROTOCOL_VERSION_9) { if (version >= Constants.TCP_PROTOCOL_VERSION_9) {
return ValueTimestamp.fromDateValueAndNanos( return ValueTimestamp.fromDateValueAndNanos(
readLong(), readLong()); readLong(), readLong());
} else if (version >= Constants.TCP_PROTOCOL_VERSION_7) { } else {
return ValueTimestamp.fromMillisNanos( return ValueTimestamp.fromMillisNanos(
DateTimeUtils.getTimeUTCWithoutDst(readLong()), DateTimeUtils.getTimeUTCWithoutDst(readLong()),
readInt() % 1_000_000); readInt() % 1_000_000);
} }
return ValueTimestamp.fromMillisNanos(readLong(),
readInt() % 1_000_000);
} }
case Value.TIMESTAMP_TZ: { case Value.TIMESTAMP_TZ: {
return ValueTimestampTimeZone.fromDateValueAndNanos(readLong(), return ValueTimestampTimeZone.fromDateValueAndNanos(readLong(),
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论