Dima/orion_greptime_proto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: create schema with options (#93)

Browse Source 
* chore: add options to create database expr

* chore: rebase develop
This commit is contained in:
shuiyisong
2023-08-30 14:40:08 +08:00
committed by GitHub
parent e8e228b026
commit f263419222
5 changed files with 719 additions and 155 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/src/main/java/io/greptime/v1/Ddl.java
+360 -21
View File
@@ -9933,6 +9933,42 @@ java.lang.String defaultValue);
* @return The createIfNotExists.
*/
boolean getCreateIfNotExists();
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
int getOptionsCount();
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
boolean containsOptions(
java.lang.String key);
/**
* Use {@link #getOptionsMap()} instead.
*/
@java.lang.Deprecated
java.util.Map<java.lang.String, java.lang.String>
getOptions();
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
java.util.Map<java.lang.String, java.lang.String>
getOptionsMap();
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
/* nullable */
java.lang.String getOptionsOrDefault(
java.lang.String key,
/* nullable */
java.lang.String defaultValue);
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
java.lang.String getOptionsOrThrow(
java.lang.String key);
}
/**
* Protobuf type {@code greptime.v1.CreateDatabaseExpr}
@@ -9970,6 +10006,7 @@ java.lang.String defaultValue);
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
int mutable_bitField0_ = 0;
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder();
try {
@@ -9991,6 +10028,19 @@ java.lang.String defaultValue);
createIfNotExists_ = input.readBool();
break;
}
case 26: {
if (!((mutable_bitField0_ & 0x00000001) != 0)) {
options_ = com.google.protobuf.MapField.newMapField(
OptionsDefaultEntryHolder.defaultEntry);
mutable_bitField0_ |= 0x00000001;
}
com.google.protobuf.MapEntry<java.lang.String, java.lang.String>
options__ = input.readMessage(
OptionsDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry);
options_.getMutableMap().put(
options__.getKey(), options__.getValue());
break;
}
default: {
if (!parseUnknownField(
input, unknownFields, extensionRegistry, tag)) {
@@ -10017,6 +10067,18 @@ java.lang.String defaultValue);
return io.greptime.v1.Ddl.internal_static_greptime_v1_CreateDatabaseExpr_descriptor;
}
@SuppressWarnings({"rawtypes"})
@java.lang.Override
protected com.google.protobuf.MapField internalGetMapField(
int number) {
switch (number) {
case 3:
return internalGetOptions();
default:
throw new RuntimeException(
"Invalid map field number: " + number);
}
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
@@ -10074,6 +10136,87 @@ java.lang.String defaultValue);
return createIfNotExists_;
}
public static final int OPTIONS_FIELD_NUMBER = 3;
private static final class OptionsDefaultEntryHolder {
static final com.google.protobuf.MapEntry<
java.lang.String, java.lang.String> defaultEntry =
com.google.protobuf.MapEntry
.<java.lang.String, java.lang.String>newDefaultInstance(
io.greptime.v1.Ddl.internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor,
com.google.protobuf.WireFormat.FieldType.STRING,
"",
com.google.protobuf.WireFormat.FieldType.STRING,
"");
}
private com.google.protobuf.MapField<
java.lang.String, java.lang.String> options_;
private com.google.protobuf.MapField<java.lang.String, java.lang.String>
internalGetOptions() {
if (options_ == null) {
return com.google.protobuf.MapField.emptyMapField(
OptionsDefaultEntryHolder.defaultEntry);
}
return options_;
}
public int getOptionsCount() {
return internalGetOptions().getMap().size();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public boolean containsOptions(
java.lang.String key) {
if (key == null) { throw new NullPointerException("map key"); }
return internalGetOptions().getMap().containsKey(key);
}
/**
* Use {@link #getOptionsMap()} instead.
*/
@java.lang.Override
@java.lang.Deprecated
public java.util.Map<java.lang.String, java.lang.String> getOptions() {
return getOptionsMap();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public java.util.Map<java.lang.String, java.lang.String> getOptionsMap() {
return internalGetOptions().getMap();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public java.lang.String getOptionsOrDefault(
java.lang.String key,
java.lang.String defaultValue) {
if (key == null) { throw new NullPointerException("map key"); }
java.util.Map<java.lang.String, java.lang.String> map =
internalGetOptions().getMap();
return map.containsKey(key) ? map.get(key) : defaultValue;
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public java.lang.String getOptionsOrThrow(
java.lang.String key) {
if (key == null) { throw new NullPointerException("map key"); }
java.util.Map<java.lang.String, java.lang.String> map =
internalGetOptions().getMap();
if (!map.containsKey(key)) {
throw new java.lang.IllegalArgumentException();
}
return map.get(key);
}
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
@@ -10094,6 +10237,12 @@ java.lang.String defaultValue);
if (createIfNotExists_ != false) {
output.writeBool(2, createIfNotExists_);
}
com.google.protobuf.GeneratedMessageV3
.serializeStringMapTo(
output,
internalGetOptions(),
OptionsDefaultEntryHolder.defaultEntry,
3);
unknownFields.writeTo(output);
}
@@ -10110,6 +10259,16 @@ java.lang.String defaultValue);
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(2, createIfNotExists_);
}
for (java.util.Map.Entry<java.lang.String, java.lang.String> entry
: internalGetOptions().getMap().entrySet()) {
com.google.protobuf.MapEntry<java.lang.String, java.lang.String>
options__ = OptionsDefaultEntryHolder.defaultEntry.newBuilderForType()
.setKey(entry.getKey())
.setValue(entry.getValue())
.build();
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(3, options__);
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
return size;
@@ -10129,6 +10288,8 @@ java.lang.String defaultValue);
.equals(other.getDatabaseName())) return false;
if (getCreateIfNotExists()
!= other.getCreateIfNotExists()) return false;
if (!internalGetOptions().equals(
other.internalGetOptions())) return false;
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
}
@@ -10145,6 +10306,10 @@ java.lang.String defaultValue);
hash = (37 * hash) + CREATE_IF_NOT_EXISTS_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(
getCreateIfNotExists());
if (!internalGetOptions().getMap().isEmpty()) {
hash = (37 * hash) + OPTIONS_FIELD_NUMBER;
hash = (53 * hash) + internalGetOptions().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@@ -10252,6 +10417,28 @@ java.lang.String defaultValue);
return io.greptime.v1.Ddl.internal_static_greptime_v1_CreateDatabaseExpr_descriptor;
}
@SuppressWarnings({"rawtypes"})
protected com.google.protobuf.MapField internalGetMapField(
int number) {
switch (number) {
case 3:
return internalGetOptions();
default:
throw new RuntimeException(
"Invalid map field number: " + number);
}
}
@SuppressWarnings({"rawtypes"})
protected com.google.protobuf.MapField internalGetMutableMapField(
int number) {
switch (number) {
case 3:
return internalGetMutableOptions();
default:
throw new RuntimeException(
"Invalid map field number: " + number);
}
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
@@ -10282,6 +10469,7 @@ java.lang.String defaultValue);
createIfNotExists_ = false;
internalGetMutableOptions().clear();
return this;
}
@@ -10308,8 +10496,11 @@ java.lang.String defaultValue);
@java.lang.Override
public io.greptime.v1.Ddl.CreateDatabaseExpr buildPartial() {
io.greptime.v1.Ddl.CreateDatabaseExpr result = new io.greptime.v1.Ddl.CreateDatabaseExpr(this);
int from_bitField0_ = bitField0_;
result.databaseName_ = databaseName_;
result.createIfNotExists_ = createIfNotExists_;
result.options_ = internalGetOptions();
result.options_.makeImmutable();
onBuilt();
return result;
}
@@ -10365,6 +10556,8 @@ java.lang.String defaultValue);
if (other.getCreateIfNotExists() != false) {
setCreateIfNotExists(other.getCreateIfNotExists());
}
internalGetMutableOptions().mergeFrom(
other.internalGetOptions());
this.mergeUnknownFields(other.unknownFields);
onChanged();
return this;
@@ -10393,6 +10586,7 @@ java.lang.String defaultValue);
}
return this;
}
private int bitField0_;
private java.lang.Object databaseName_ = "";
/**
@@ -10500,6 +10694,137 @@ java.lang.String defaultValue);
onChanged();
return this;
}
private com.google.protobuf.MapField<
java.lang.String, java.lang.String> options_;
private com.google.protobuf.MapField<java.lang.String, java.lang.String>
internalGetOptions() {
if (options_ == null) {
return com.google.protobuf.MapField.emptyMapField(
OptionsDefaultEntryHolder.defaultEntry);
}
return options_;
}
private com.google.protobuf.MapField<java.lang.String, java.lang.String>
internalGetMutableOptions() {
onChanged();;
if (options_ == null) {
options_ = com.google.protobuf.MapField.newMapField(
OptionsDefaultEntryHolder.defaultEntry);
}
if (!options_.isMutable()) {
options_ = options_.copy();
}
return options_;
}
public int getOptionsCount() {
return internalGetOptions().getMap().size();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public boolean containsOptions(
java.lang.String key) {
if (key == null) { throw new NullPointerException("map key"); }
return internalGetOptions().getMap().containsKey(key);
}
/**
* Use {@link #getOptionsMap()} instead.
*/
@java.lang.Override
@java.lang.Deprecated
public java.util.Map<java.lang.String, java.lang.String> getOptions() {
return getOptionsMap();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public java.util.Map<java.lang.String, java.lang.String> getOptionsMap() {
return internalGetOptions().getMap();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public java.lang.String getOptionsOrDefault(
java.lang.String key,
java.lang.String defaultValue) {
if (key == null) { throw new NullPointerException("map key"); }
java.util.Map<java.lang.String, java.lang.String> map =
internalGetOptions().getMap();
return map.containsKey(key) ? map.get(key) : defaultValue;
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
@java.lang.Override
public java.lang.String getOptionsOrThrow(
java.lang.String key) {
if (key == null) { throw new NullPointerException("map key"); }
java.util.Map<java.lang.String, java.lang.String> map =
internalGetOptions().getMap();
if (!map.containsKey(key)) {
throw new java.lang.IllegalArgumentException();
}
return map.get(key);
}
public Builder clearOptions() {
internalGetMutableOptions().getMutableMap()
.clear();
return this;
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
public Builder removeOptions(
java.lang.String key) {
if (key == null) { throw new NullPointerException("map key"); }
internalGetMutableOptions().getMutableMap()
.remove(key);
return this;
}
/**
* Use alternate mutation accessors instead.
*/
@java.lang.Deprecated
public java.util.Map<java.lang.String, java.lang.String>
getMutableOptions() {
return internalGetMutableOptions().getMutableMap();
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
public Builder putOptions(
java.lang.String key,
java.lang.String value) {
if (key == null) { throw new NullPointerException("map key"); }
if (value == null) {
throw new NullPointerException("map value");
}
internalGetMutableOptions().getMutableMap()
.put(key, value);
return this;
}
/**
* <code>map&lt;string, string&gt; options = 3;</code>
*/
public Builder putAllOptions(
java.util.Map<java.lang.String, java.lang.String> values) {
internalGetMutableOptions().getMutableMap()
.putAll(values);
return this;
}
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
@@ -16568,6 +16893,11 @@ java.lang.String defaultValue);
private static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_greptime_v1_CreateDatabaseExpr_fieldAccessorTable;
private static final com.google.protobuf.Descriptors.Descriptor
internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor;
private static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_fieldAccessorTable;
private static final com.google.protobuf.Descriptors.Descriptor
internal_static_greptime_v1_TruncateTableExpr_descriptor;
private static final
@@ -16655,26 +16985,29 @@ java.lang.String defaultValue);
"able_id\030\005 \001(\0132\024.greptime.v1.TableId\"h\n\020C" +
"ompactTableExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023\n" +
"\013schema_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022\025" +
"\n\rregion_number\030\004 \001(\r\"I\n\022CreateDatabaseE" +
"xpr\022\025\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if_" +
"not_exists\030\002 \001(\010\"z\n\021TruncateTableExpr\022\024\n" +
"\014catalog_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t" +
"\022\022\n\ntable_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024" +
".greptime.v1.TableId\"9\n\nAddColumns\022+\n\013ad" +
"d_columns\030\001 \003(\0132\026.greptime.v1.AddColumn\"" +
"<\n\013DropColumns\022-\n\014drop_columns\030\001 \003(\0132\027.g" +
"reptime.v1.DropColumn\"%\n\013RenameTable\022\026\n\016" +
"new_table_name\030\001 \001(\t\"\215\002\n\tAddColumn\022*\n\nco" +
"lumn_def\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\016" +
"\n\006is_key\030\002 \001(\010\0221\n\010location\030\003 \001(\0132\037.grept" +
"ime.v1.AddColumn.Location\032\220\001\n\010Location\022C" +
"\n\rlocation_type\030\001 \001(\0162,.greptime.v1.AddC" +
"olumn.Location.LocationType\022\031\n\021after_clo" +
"umn_name\030\002 \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020" +
"\000\022\t\n\005AFTER\020\001\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t" +
"\"\025\n\007TableId\022\n\n\002id\030\001 \001(\rBL\n\016io.greptime.v" +
"1B\003DdlZ5github.com/GreptimeTeam/greptime" +
"-proto/go/greptime/v1b\006proto3"
"\n\rregion_number\030\004 \001(\r\"\270\001\n\022CreateDatabase" +
"Expr\022\025\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if" +
"_not_exists\030\002 \001(\010\022=\n\007options\030\003 \003(\0132,.gre" +
"ptime.v1.CreateDatabaseExpr.OptionsEntry" +
"\032.\n\014OptionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002" +
" \001(\t:\0028\001\"z\n\021TruncateTableExpr\022\024\n\014catalog" +
"_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\ntabl" +
"e_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.greptim" +
"e.v1.TableId\"9\n\nAddColumns\022+\n\013add_column" +
"s\030\001 \003(\0132\026.greptime.v1.AddColumn\"<\n\013DropC" +
"olumns\022-\n\014drop_columns\030\001 \003(\0132\027.greptime." +
"v1.DropColumn\"%\n\013RenameTable\022\026\n\016new_tabl" +
"e_name\030\001 \001(\t\"\215\002\n\tAddColumn\022*\n\ncolumn_def" +
"\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\016\n\006is_key" +
"\030\002 \001(\010\0221\n\010location\030\003 \001(\0132\037.greptime.v1.A" +
"ddColumn.Location\032\220\001\n\010Location\022C\n\rlocati" +
"on_type\030\001 \001(\0162,.greptime.v1.AddColumn.Lo" +
"cation.LocationType\022\031\n\021after_cloumn_name" +
"\030\002 \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020\000\022\t\n\005AFT" +
"ER\020\001\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"\025\n\007Tabl" +
"eId\022\n\n\002id\030\001 \001(\rBL\n\016io.greptime.v1B\003DdlZ5" +
"github.com/GreptimeTeam/greptime-proto/g" +
"o/greptime/v1b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -16728,7 +17061,13 @@ java.lang.String defaultValue);
internal_static_greptime_v1_CreateDatabaseExpr_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_greptime_v1_CreateDatabaseExpr_descriptor,
new java.lang.String[] { "DatabaseName", "CreateIfNotExists", });
new java.lang.String[] { "DatabaseName", "CreateIfNotExists", "Options", });
internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor =
internal_static_greptime_v1_CreateDatabaseExpr_descriptor.getNestedTypes().get(0);
internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_greptime_v1_TruncateTableExpr_descriptor =
getDescriptor().getMessageTypes().get(7);
internal_static_greptime_v1_TruncateTableExpr_fieldAccessorTable = new