/*
* Copyright DataStax, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.datastax.oss.driver.api.core.type;
import com.datastax.oss.driver.api.core.CqlIdentifier;
import com.datastax.oss.driver.api.core.data.UdtValue;
import com.datastax.oss.driver.api.core.detach.AttachmentPoint;
import com.datastax.oss.driver.api.core.metadata.schema.Describable;
import com.datastax.oss.driver.api.core.type.codec.registry.CodecRegistry;
import com.datastax.oss.driver.internal.core.metadata.schema.ScriptBuilder;
import com.datastax.oss.driver.internal.core.util.Loggers;
import com.datastax.oss.protocol.internal.ProtocolConstants;
import edu.umd.cs.findbugs.annotations.NonNull;
import edu.umd.cs.findbugs.annotations.Nullable;
import java.util.Collections;
import java.util.List;
public interface UserDefinedType extends DataType, Describable {
@Nullable // because of ShallowUserDefinedType usage in the query builder
CqlIdentifier getKeyspace();
@NonNull
CqlIdentifier getName();
boolean isFrozen();
@NonNull
List<CqlIdentifier> getFieldNames();
API Note: the default implementation only exists for backward compatibility. It wraps the result of firstIndexOf(CqlIdentifier)
in a singleton list, which is not entirely correct, as it will only return the first occurrence. Therefore it also logs a warning. Implementors should always override this method (all built-in driver implementations
do).
/**
* @apiNote the default implementation only exists for backward compatibility. It wraps the result
* of {@link #firstIndexOf(CqlIdentifier)} in a singleton list, which is not entirely correct,
* as it will only return the first occurrence. Therefore it also logs a warning.
* <p>Implementors should always override this method (all built-in driver implementations
* do).
*/
@NonNull
default List<Integer> allIndicesOf(@NonNull CqlIdentifier id) {
Loggers.USER_DEFINED_TYPE.warn(
"{} should override allIndicesOf(CqlIdentifier), the default implementation is a "
+ "workaround for backward compatibility, it only returns the first occurrence",
getClass().getName());
return Collections.singletonList(firstIndexOf(id));
}
int firstIndexOf(@NonNull CqlIdentifier id);
API Note: the default implementation only exists for backward compatibility. It wraps the result of firstIndexOf(String)
in a singleton list, which is not entirely correct, as it will only return the first occurrence. Therefore it also logs a warning. Implementors should always override this method (all built-in driver implementations
do).
/**
* @apiNote the default implementation only exists for backward compatibility. It wraps the result
* of {@link #firstIndexOf(String)} in a singleton list, which is not entirely correct, as it
* will only return the first occurrence. Therefore it also logs a warning.
* <p>Implementors should always override this method (all built-in driver implementations
* do).
*/
@NonNull
default List<Integer> allIndicesOf(@NonNull String name) {
Loggers.USER_DEFINED_TYPE.warn(
"{} should override allIndicesOf(String), the default implementation is a "
+ "workaround for backward compatibility, it only returns the first occurrence",
getClass().getName());
return Collections.singletonList(firstIndexOf(name));
}
int firstIndexOf(@NonNull String name);
default boolean contains(@NonNull CqlIdentifier id) {
return firstIndexOf(id) >= 0;
}
default boolean contains(@NonNull String name) {
return firstIndexOf(name) >= 0;
}
@NonNull
List<DataType> getFieldTypes();
@NonNull
UserDefinedType copy(boolean newFrozen);
@NonNull
UdtValue newValue();
Creates a new instance with the specified values for the fields.
To encode the values, this method uses the CodecRegistry
that this type is attached
to; it looks for the best codec to handle the target CQL type and actual runtime type of each value (see CodecRegistry.codecFor(DataType, Object)
).
Params: - fields – the value of the fields. They must be in the same order as the fields in the type's definition. You can specify less values than there are fields (the remaining ones will be set to NULL), but not more (a runtime exception will be thrown). Individual values can be
null
, but the array itself can't.
Throws: - IllegalArgumentException – if there are too many values.
/**
* Creates a new instance with the specified values for the fields.
*
* <p>To encode the values, this method uses the {@link CodecRegistry} that this type is {@link
* #getAttachmentPoint() attached} to; it looks for the best codec to handle the target CQL type
* and actual runtime type of each value (see {@link CodecRegistry#codecFor(DataType, Object)}).
*
* @param fields the value of the fields. They must be in the same order as the fields in the
* type's definition. You can specify less values than there are fields (the remaining ones
* will be set to NULL), but not more (a runtime exception will be thrown). Individual values
* can be {@code null}, but the array itself can't.
* @throws IllegalArgumentException if there are too many values.
*/
@NonNull
UdtValue newValue(@NonNull Object... fields);
@NonNull
AttachmentPoint getAttachmentPoint();
@NonNull
@Override
default String asCql(boolean includeFrozen, boolean pretty) {
if (getKeyspace() != null) {
String template = (isFrozen() && includeFrozen) ? "frozen<%s.%s>" : "%s.%s";
return String.format(template, getKeyspace().asCql(pretty), getName().asCql(pretty));
} else {
String template = (isFrozen() && includeFrozen) ? "frozen<%s>" : "%s";
return String.format(template, getName().asCql(pretty));
}
}
@NonNull
@Override
default String describe(boolean pretty) {
ScriptBuilder builder = new ScriptBuilder(pretty);
builder
.append("CREATE TYPE ")
.append(getKeyspace())
.append(".")
.append(getName())
.append(" (")
.newLine()
.increaseIndent();
List<CqlIdentifier> fieldNames = getFieldNames();
List<DataType> fieldTypes = getFieldTypes();
int fieldCount = fieldNames.size();
for (int i = 0; i < fieldCount; i++) {
builder.append(fieldNames.get(i)).append(" ").append(fieldTypes.get(i).asCql(true, pretty));
if (i < fieldCount - 1) {
builder.append(",");
}
builder.newLine();
}
builder.decreaseIndent().append(");");
return builder.build();
}
@NonNull
@Override
default String describeWithChildren(boolean pretty) {
// No children (if it uses other types, they're considered dependencies, not sub-elements)
return describe(pretty);
}
@Override
default int getProtocolCode() {
return ProtocolConstants.DataType.UDT;
}
}