自定义Cassandra数据类型
在博客文章《 从Java连接到Cassandra》中 ,我提到了用Java 实现的Cassandra Java开发人员的一个优势是能够创建自定义 Cassandra数据类型 。 在这篇文章中,我将详细介绍如何执行此操作。
Cassandra具有许多内置的数据类型 ,但是在某些情况下,可能需要添加自定义类型。 通过扩展org.apache.cassandra.db.marshal.AbstractType类,可以在Java中实现Cassandra定制数据类型。 扩展此方法的类必须最终实现具有以下签名的三个方法:
public ByteBuffer fromString(final String) throws MarshalException
public TypeSerializer getSerializer()
public int compare(Object, Object)
下一个代码清单中显示了本文的AbstractType
示例实现。
UnitedStatesState.java –扩展AbstractType
package dustin.examples.cassandra.cqltypes;import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.serializers.MarshalException;
import org.apache.cassandra.serializers.TypeSerializer;import java.nio.ByteBuffer;/*** Representation of a state in the United States that* can be persisted to Cassandra database.*/
public class UnitedStatesState extends AbstractType
{public static final UnitedStatesState instance = new UnitedStatesState();@Overridepublic ByteBuffer fromString(final String stateName) throws MarshalException{return getStateAbbreviationAsByteBuffer(stateName);}@Overridepublic TypeSerializer getSerializer(){return UnitedStatesStateSerializer.instance;}@Overridepublic int compare(Object o1, Object o2){if (o1 == null && o2 == null){return 0;}else if (o1 == null){return 1;}else if (o2 == null){return -1;}else{return o1.toString().compareTo(o2.toString());}}/*** Provide standard two-letter abbreviation for United States* state whose state name is provided.** @param stateName Name of state whose abbreviation is desired.* @return State's abbreviation as a ByteBuffer; will return "UK"* if provided state name is unexpected value.*/private ByteBuffer getStateAbbreviationAsByteBuffer(final String stateName){final String upperCaseStateName = stateName != null ? stateName.toUpperCase().replace(" ", "_") : "UNKNOWN";String abbreviation;try{abbreviation = upperCaseStateName.length() == 2? State.fromAbbreviation(upperCaseStateName).getStateAbbreviation(): State.valueOf(upperCaseStateName).getStateAbbreviation();}catch (Exception exception){abbreviation = State.UNKNOWN.getStateAbbreviation();}return ByteBuffer.wrap(abbreviation.getBytes());}
}
上面的类列表引用了State
枚举,如下所示。
State.java
package dustin.examples.cassandra.cqltypes;/*** Representation of state in the United States.*/
public enum State
{ALABAMA("Alabama", "AL"),ALASKA("Alaska", "AK"),ARIZONA("Arizona", "AZ"),ARKANSAS("Arkansas", "AR"),CALIFORNIA("California", "CA"),COLORADO("Colorado", "CO"),CONNECTICUT("Connecticut", "CT"),DELAWARE("Delaware", "DE"),DISTRICT_OF_COLUMBIA("District of Columbia", "DC"),FLORIDA("Florida", "FL"),GEORGIA("Georgia", "GA"),HAWAII("Hawaii", "HI"),IDAHO("Idaho", "ID"),ILLINOIS("Illinois", "IL"),INDIANA("Indiana", "IN"),IOWA("Iowa", "IA"),KANSAS("Kansas", "KS"),LOUISIANA("Louisiana", "LA"),MAINE("Maine", "ME"),MARYLAND("Maryland", "MD"),MASSACHUSETTS("Massachusetts", "MA"),MICHIGAN("Michigan", "MI"),MINNESOTA("Minnesota", "MN"),MISSISSIPPI("Mississippi", "MS"),MISSOURI("Missouri", "MO"),MONTANA("Montana", "MT"),NEBRASKA("Nebraska", "NE"),NEVADA("Nevada", "NV"),NEW_HAMPSHIRE("New Hampshire", "NH"),NEW_JERSEY("New Jersey", "NJ"),NEW_MEXICO("New Mexico", "NM"),NORTH_CAROLINA("North Carolina", "NC"),NORTH_DAKOTA("North Dakota", "ND"),NEW_YORK("New York", "NY"),OHIO("Ohio", "OH"),OKLAHOMA("Oklahoma", "OK"),OREGON("Oregon", "OR"),PENNSYLVANIA("Pennsylvania", "PA"),RHODE_ISLAND("Rhode Island", "RI"),SOUTH_CAROLINA("South Carolina", "SC"),SOUTH_DAKOTA("South Dakota", "SD"),TENNESSEE("Tennessee", "TN"),TEXAS("Texas", "TX"),UTAH("Utah", "UT"),VERMONT("Vermont", "VT"),VIRGINIA("Virginia", "VA"),WASHINGTON("Washington", "WA"),WEST_VIRGINIA("West Virginia", "WV"),WISCONSIN("Wisconsin", "WI"),WYOMING("Wyoming", "WY"),UNKNOWN("Unknown", "UK");private String stateName;private String stateAbbreviation;State(final String newStateName, final String newStateAbbreviation){this.stateName = newStateName;this.stateAbbreviation = newStateAbbreviation;}public String getStateName(){return this.stateName;}public String getStateAbbreviation(){return this.stateAbbreviation;}public static State fromAbbreviation(final String candidateAbbreviation){State match = UNKNOWN;if (candidateAbbreviation != null && candidateAbbreviation.length() == 2){final String upperAbbreviation = candidateAbbreviation.toUpperCase();for (final State state : State.values()){if (state.stateAbbreviation.equals(upperAbbreviation)){match = state;}}}return match;}
}
我们还可以提供上面显示的getSerializer()
方法返回的TypeSerializer
接口的实现。 通常,通过扩展org.apache.cassandra.serializers package
中Cassandra提供的TypeSerializer
的众多现有实现之一,通常可以最容易地编写实现TypeSerializer
类。 在我的示例中,我的自定义序列化程序扩展了AbstractTextSerializer
,我需要添加的唯一方法是签名public void validate(final ByteBuffer bytes) throws MarshalException
。 我的两个自定义类都需要通过静态访问提供对自身实例的引用。 这是通过AbstractTypeSerializer
扩展实现TypeSerializer
的类:
UnitedStatesStateSerializer.java –实现TypeSerializer
package dustin.examples.cassandra.cqltypes;import org.apache.cassandra.serializers.AbstractTextSerializer;
import org.apache.cassandra.serializers.MarshalException;import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;/*** Serializer for UnitedStatesState.*/
public class UnitedStatesStateSerializer extends AbstractTextSerializer
{public static final UnitedStatesStateSerializer instance = new UnitedStatesStateSerializer();private UnitedStatesStateSerializer(){super(StandardCharsets.UTF_8);}/*** Validates provided ByteBuffer contents to ensure they can* be modeled in the UnitedStatesState Cassandra/CQL data type.* This allows for a full state name to be specified or for its* two-digit abbreviation to be specified and either is considered* valid.** @param bytes ByteBuffer whose contents are to be validated.* @throws MarshalException Thrown if provided data is invalid.*/@Overridepublic void validate(final ByteBuffer bytes) throws MarshalException{try{final String stringFormat = new String(bytes.array()).toUpperCase();final State state = stringFormat.length() == 2? State.fromAbbreviation(stringFormat): State.valueOf(stringFormat);}catch (Exception exception){throw new MarshalException("Invalid model cannot be marshaled as UnitedStatesState.");}}
}
编写了用于创建自定义CQL数据类型的类后,需要将它们编译为.class
文件并存档在JAR文件中。 此过程(使用javac -cp "C:\Program Files\DataStax Community\apache-cassandra\lib\*" -sourcepath src -d classes src\dustin\examples\cassandra\cqltypes\*.java
,并将生成的归档.class
下面的屏幕快照中显示了将.class
文件转换为名为jar cvf CustomCqlTypes.jar *
名为CustomCqlTypes.jar
的JAR。
带有自定义CQL类型类的类定义的JAR需要放置在Cassandra安装的lib
目录中,如下一个屏幕快照所示。
通过在Cassandra安装目录的lib
目录中包含自定义CQL数据类型类实现的JAR,应该重新启动Cassandra,以便它能够“看到”这些自定义数据类型定义。
下一个代码清单显示了一个Cassandra查询语言(CQL)语句,该语句用于使用新的自定义类型dustin.examples.cassandra.cqltypes.UnitedStatesState
创建表。
createAddress.cql
CREATE TABLE us_address
(id uuid,street1 text,street2 text,city text,state 'dustin.examples.cassandra.cqltypes.UnitedStatesState',zipcode text,PRIMARY KEY(id)
);
下一个屏幕快照通过描述cqlsh中创建的表来演示运行上述createAddress.cql
代码的结果。
上面的屏幕快照演示了自定义类型dustin.examples.cassandra.cqltypes.UnitedStatesState
是us_address
表的state
列的类型。
可以使用常规INSERT
将新行添加到US_ADDRESS
表中。 例如,以下屏幕快照演示了使用INSERT INTO us_address (id, street1, street2, city, state, zipcode) VALUES (blobAsUuid(timeuuidAsBlob(now())), '350 Fifth Avenue', '', 'New York', 'New York', '10118');
命令INSERT INTO us_address (id, street1, street2, city, state, zipcode) VALUES (blobAsUuid(timeuuidAsBlob(now())), '350 Fifth Avenue', '', 'New York', 'New York', '10118');
:
请注意,虽然INSERT语句为该州插入了“纽约”,但它存储为“ NY”。
如果我运行一个INSERT
陈述cqlsh使用缩写下手( INSERT INTO us_address (id, street1, street2, city, state, zipcode) VALUES (blobAsUuid(timeuuidAsBlob(now())), '350 Fifth Avenue', '', 'New York', 'NY', '10118');
),它仍然可以正常工作,如下图所示。
在我的示例中,无效状态不会阻止INSERT
的发生,而是将状态持久保存为“ UK”(对于未知状态)[请参见UnitedStatesState.getStateAbbreviationAsByteBuffer(String)
的实现UnitedStatesState.getStateAbbreviationAsByteBuffer(String)
。
证明为什么要在Java中实现自定义CQL数据类型的第一个优点就是,能够采用与关系数据库中的检查约束所提供的行为类似的行为。 例如,在这篇文章中,我的示例确保为新行输入的任何州列都是美国的五十个州,哥伦比亚特区或未知的“英国”之一。 不能在该列的值中插入其他值。
自定义数据类型的另一个优点是能够将数据整理成首选格式。 在此示例中,我将每个州名称都更改为大写的两位数缩写。 在其他情况下,我可能想要始终以大写形式存储或始终以小写形式存储或将有限的字符串集映射为数值。 自定义CQL数据类型允许自定义验证和Cassandra数据库中值的表示。
结论
这篇文章介绍了如何在Cassandra中实现自定义CQL数据类型。 随着我越来越多地使用这个概念并尝试不同的方法,我希望就我所做的一些更细微的观察撰写另一篇博客文章。 如本文所显示,编写和使用自定义CQL数据类型非常容易,特别是对于Java开发人员而言。
翻译自: https://www.javacodegeeks.com/2014/07/custom-cassandra-data-types.html
自定义Cassandra数据类型相关推荐
- cassandra_自定义Cassandra数据类型
cassandra 在博客文章<从Java连接到Cassandra>中,我提到了用Java实现的Cassandra Java开发人员的一个优势是能够创建自定义Cassandra数据类型. ...
- springboot控制接口返回的字段_SpringBoot实战:SpringBoot之Rest Full接口自定义返回数据类型(ResponseBodyAdvice)...
我们在日常开发的过程中,经常会要求统一返回数据格式.如要求统一访问格式为 { "success": 请求是否成功, "message": 请求消息, " ...
- ROS中自定义复杂数据类型
ROS中自定义复杂数据类型 先说一下需求,想要服务的请求数据为一个point(x,y,z)的数组.具体的形式表示如: [point1,point2,...] geometry_msgs::Point ...
- Redis数据实战之GEO在LBS中应用与自定义新数据类型
Redis数据实战之GEO在LBS中应用与自定义新数据类型 引言 面向 LBS 应用的 GEO 数据类型 GEO 的底层结构 GeoHash 的编码方法 如何操作 GEO 类型 如何自定义数据类型 R ...
- c++ 哪些自定义的数据类型
http://www.cnblogs.com/ShaneZhang/archive/2013/06/21/3147648.html 这些数据类型是 C99 中定义的,具体定义在:/usr/includ ...
- Mapreduce自定义数据类型
Hadoop自带的数据类型: Intwritable,LongWritable,Text,xxWritable. 某些情况下:使用自定义的数据类型方便一些(类似java中的pojo). 实现: 实现w ...
- 用类模板实现容器存储自定义数据类型(类似于STL里面的vector)
上一节里面已经提到了,用类模板存储自定义的数据类型,如Teacher类型时,需要重载Teacher类的拷贝构造函数,"="操作符,"<<"操作符,特 ...
- 自学C++——自定义数据类型
一,typedef声明 在编写程序时,除了可以使用内置的基本数据类型名和自定义的数据类型名外,还可以为一个已有的数据类型另外命名. 类型命名的语法形式: typedef 已有类型名 新类型名表: 其 ...
- SQL Server 创建自定义数据类型
创建自定义数据类型 作用 在指定的数据库,创建自定义的数据类型. 格式 CREATE TYPE [dbo].[名称] FROM [类型] NOT NULL 例子 CREATE TYPE [dbo].[ ...
最新文章
- apache字体文件跨域_apache如何解决跨域资源访问
- 01背包 + 概率 之 hdu 2955
- Alluxio完成C轮5000万美元融资,新设中国区总部力拓国内市场
- 数字图像处理(四)——图像编码技术(一)
- g++编译时对'xxxx'未定义的引用问题(undefined reference to)
- 苏宁易购开放平台_苏宁易购半年报解读:业态场景与零售服务的“两手抓”
- 月活8.89亿背后:微信工程师细数兼容测试经验
- 详细图解,一眼就能看懂!卷帘快门(Rolling Shutter)与全局快门(Global Shutter)的区别
- 软考信息系统项目管理师考试心得-备考
- discuz发帖流程_C#代码、流程discuz论坛批量或自动发帖
- 项目管理成熟度模型及项目量化管理
- 怎样在html中设置首字母大写,javascript如何设置字符串首字母大写?
- P4313 文理分科 详细理解
- google不能用解决方法
- 基于树莓派的超声波数据采集与存储(一)——树莓派配置
- #第五章“拷问”既往的股市理论5.1有人情味的“拷问”
- 全新iPhone发布会确定时间了!从Loog上可以看出有新配色
- MADlib——基于SQL的数据挖掘解决方案(6)——数据转换之矩阵分解
- Vue3表单验证 单个验证 统一验证 自定验证
- Java直接量(字面量)
热门文章
- 153. 寻找旋转排序数组中的最小值---LeetCode---JAVA
- tar (child): .tgz\r:无法 open: 没有那个文件或目录
- 第8步 第2剑客 mybatis plugin 第三剑客 page helper csdn每天最多发多少文章 是20篇,刚刚才试了。2014
- (转)springboot:添加JSP支持
- DFS——深度优先搜索基础
- POJ3904(dfs)
- 数据结构和算法的基本概念
- camel apache_如何使用Apache Camel,Quarkus和GraalVM快速运行100个骆驼
- recorder_将Java Flight Recorder与OpenJDK 11一起使用
- th:each嵌套_难题:嵌套的computeIfAbsent