-
Notifications
You must be signed in to change notification settings - Fork 543
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Better support of Bool, Enum, and custom type mapping
- Loading branch information
Showing
27 changed files
with
1,183 additions
and
392 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
135 changes: 135 additions & 0 deletions
135
clickhouse-client/src/main/java/com/clickhouse/client/ClickHouseEnum.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,135 @@ | ||
| package com.clickhouse.client; | ||
|
|
||
| import java.util.Arrays; | ||
| import java.util.Collection; | ||
| import java.util.Collections; | ||
|
|
||
| public class ClickHouseEnum { | ||
| public static final ClickHouseEnum EMPTY = new ClickHouseEnum(Collections.emptyList()); | ||
|
|
||
| public static ClickHouseEnum of(Class<? extends Enum> clazz) { | ||
| if (clazz == null || !Enum.class.isAssignableFrom(clazz)) { | ||
| return EMPTY; | ||
| } | ||
|
|
||
| Enum<?>[] constants = clazz.getEnumConstants(); | ||
| int size = constants.length; | ||
| String[] names = new String[size]; | ||
| int[] values = new int[size]; | ||
| int i = 0; | ||
| for (Enum<?> e : clazz.getEnumConstants()) { | ||
| names[i] = e.name(); | ||
| values[i] = e.ordinal(); | ||
| i++; | ||
| } | ||
|
|
||
| return new ClickHouseEnum(names, values); | ||
| } | ||
|
|
||
| private final int size; | ||
| private final String[] names; | ||
| private final int[] values; | ||
|
|
||
| protected ClickHouseEnum(Collection<String> params) { | ||
| size = params.size(); | ||
| names = new String[size]; | ||
| values = new int[size]; | ||
|
|
||
| int i = 0; | ||
| for (String p : params) { | ||
| int index = p.lastIndexOf('='); | ||
| if (index > 0) { | ||
| names[i] = ClickHouseUtils.unescape(p.substring(0, index)); | ||
| values[i] = Integer.parseInt(p.substring(index + 1)); | ||
| } else { | ||
| throw new IllegalArgumentException("Invalid enum entry: " + p); | ||
| } | ||
| i++; | ||
| } | ||
| } | ||
|
|
||
| protected ClickHouseEnum(String[] names, int[] values) { | ||
| if (names == null || values == null) { | ||
| throw new IllegalArgumentException("Non-null names and values are required"); | ||
| } else if (names.length != values.length) { | ||
| throw new IllegalArgumentException("Names and values should have same length"); | ||
| } | ||
|
|
||
| this.size = names.length; | ||
| this.names = names; | ||
| this.values = values; | ||
| } | ||
|
|
||
| public String validate(String name) { | ||
| for (int i = 0; i < size; i++) { | ||
| if (names[i].equals(name)) { | ||
| return name; | ||
| } | ||
| } | ||
|
|
||
| throw new IllegalArgumentException("Unknown enum name: " + name); | ||
| } | ||
|
|
||
| public int validate(int value) { | ||
| for (int i = 0; i < size; i++) { | ||
| if (values[i] == value) { | ||
| return value; | ||
| } | ||
| } | ||
|
|
||
| throw new IllegalArgumentException("Unknown enum value: " + value); | ||
| } | ||
|
|
||
| public String name(int value) { | ||
| for (int i = 0; i < size; i++) { | ||
| if (values[i] == value) { | ||
| return names[i]; | ||
| } | ||
| } | ||
|
|
||
| throw new IllegalArgumentException("Unknown enum value: " + value); | ||
| } | ||
|
|
||
| public int value(String name) { | ||
| for (int i = 0; i < size; i++) { | ||
| if (names[i].equals(name)) { | ||
| return values[i]; | ||
| } | ||
| } | ||
|
|
||
| throw new IllegalArgumentException("Unknown enum name: " + name); | ||
| } | ||
|
|
||
| @Override | ||
| public int hashCode() { | ||
| final int prime = 31; | ||
| int result = prime + size; | ||
| result = prime * result + Arrays.hashCode(names); | ||
| result = prime * result + Arrays.hashCode(values); | ||
| return result; | ||
| } | ||
|
|
||
| @Override | ||
| public boolean equals(Object obj) { | ||
| if (this == obj) { | ||
| return true; | ||
| } | ||
| if (obj == null || getClass() != obj.getClass()) { | ||
| return false; | ||
| } | ||
| ClickHouseEnum other = (ClickHouseEnum) obj; | ||
| return size == other.size && Arrays.equals(names, other.names) && Arrays.equals(values, other.values); | ||
| } | ||
|
|
||
| public String toSqlException() { | ||
| StringBuilder builder = new StringBuilder(); | ||
| for (int i = 0; i < size; i++) { | ||
| builder.append('\'').append(ClickHouseUtils.escape(names[i], '\'')).append('\'').append('=') | ||
| .append(values[i]).append(','); | ||
| } | ||
| if (builder.length() > 0) { | ||
| builder.setLength(builder.length() - 1); | ||
| } | ||
| return builder.toString(); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.