|
24 | 24 | import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP;
|
25 | 25 | import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_4_15_0;
|
26 | 26 | import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_4_16_0;
|
27 |
| -import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0; |
| 27 | +import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0; |
28 | 28 | import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.PHOENIX_MAJOR_VERSION;
|
29 | 29 | import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.PHOENIX_MINOR_VERSION;
|
30 | 30 | import static org.apache.phoenix.coprocessorclient.MetaDataProtocol.PHOENIX_PATCH_NUMBER;
|
@@ -4124,24 +4124,32 @@ protected PhoenixConnection upgradeSystemCatalogIfRequired(PhoenixConnection met
|
4124 | 4124 | }
|
4125 | 4125 | }
|
4126 | 4126 | }
|
4127 |
| - if (currentServerSideTableTimeStamp < MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0) { |
4128 |
| - metaConnection = addColumnsIfNotExists(metaConnection, |
4129 |
| - PhoenixDatabaseMetaData.SYSTEM_CATALOG, MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0 - 4, |
4130 |
| - PhoenixDatabaseMetaData.PHYSICAL_TABLE_NAME |
4131 |
| - + " " + PVarchar.INSTANCE.getSqlTypeName()); |
4132 |
| - |
4133 |
| - metaConnection = addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
4134 |
| - MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0 - 3, |
4135 |
| - PhoenixDatabaseMetaData.SCHEMA_VERSION + " " + PVarchar.INSTANCE.getSqlTypeName()); |
4136 |
| - metaConnection = addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
4137 |
| - MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0 - 2, |
4138 |
| - PhoenixDatabaseMetaData.EXTERNAL_SCHEMA_ID + " " + PVarchar.INSTANCE.getSqlTypeName()); |
4139 |
| - metaConnection = addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
4140 |
| - MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0 - 1, |
4141 |
| - PhoenixDatabaseMetaData.STREAMING_TOPIC_NAME + " " + PVarchar.INSTANCE.getSqlTypeName()); |
4142 |
| - metaConnection = addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
4143 |
| - MIN_SYSTEM_TABLE_TIMESTAMP_5_2_0, |
4144 |
| - PhoenixDatabaseMetaData.INDEX_WHERE + " " + PVarchar.INSTANCE.getSqlTypeName()); |
| 4127 | + if (currentServerSideTableTimeStamp < MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0) { |
| 4128 | + metaConnection = |
| 4129 | + addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
| 4130 | + MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0 - 4, |
| 4131 | + PhoenixDatabaseMetaData.PHYSICAL_TABLE_NAME + " " |
| 4132 | + + PVarchar.INSTANCE.getSqlTypeName()); |
| 4133 | + metaConnection = |
| 4134 | + addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
| 4135 | + MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0 - 3, |
| 4136 | + PhoenixDatabaseMetaData.SCHEMA_VERSION + " " |
| 4137 | + + PVarchar.INSTANCE.getSqlTypeName()); |
| 4138 | + metaConnection = |
| 4139 | + addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
| 4140 | + MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0 - 2, |
| 4141 | + PhoenixDatabaseMetaData.EXTERNAL_SCHEMA_ID + " " |
| 4142 | + + PVarchar.INSTANCE.getSqlTypeName()); |
| 4143 | + metaConnection = |
| 4144 | + addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
| 4145 | + MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0 - 1, |
| 4146 | + PhoenixDatabaseMetaData.STREAMING_TOPIC_NAME + " " |
| 4147 | + + PVarchar.INSTANCE.getSqlTypeName()); |
| 4148 | + metaConnection = |
| 4149 | + addColumnsIfNotExists(metaConnection, PhoenixDatabaseMetaData.SYSTEM_CATALOG, |
| 4150 | + MIN_SYSTEM_TABLE_TIMESTAMP_5_3_0, |
| 4151 | + PhoenixDatabaseMetaData.INDEX_WHERE + " " |
| 4152 | + + PVarchar.INSTANCE.getSqlTypeName()); |
4145 | 4153 | UpgradeUtil.bootstrapLastDDLTimestampForIndexes(metaConnection);
|
4146 | 4154 | }
|
4147 | 4155 | return metaConnection;
|
|
0 commit comments