cassandra 数据到Java对象的映射绑定

 1 package com.cnblogs.hoojo.cassar.utils;  2  3 import java.beans.PropertyDescriptor;  4 import java.lang.reflect.InvocationTargetException;  5 import java.math.BigDecimal;  6 import java.math.BigInteger;  7 import java.net.InetAddress;  8 import java.sql.Timestamp;  9 import java.util.Date;  10 import java.util.HashMap;  11 import java.util.Iterator;  12 import java.util.List;  13 import java.util.Map;  14 import java.util.Set;  15 import java.util.UUID;  16  17 import org.apache.commons.beanutils.PropertyUtils;  18 import org.apache.commons.collections.MapUtils;  19 import org.apache.commons.lang3.StringUtils;  20 import org.slf4j.Logger;  21 import org.slf4j.LoggerFactory;  22 import org.springframework.beans.BeanUtils;  23  24 import com.datastax.driver.core.BoundStatement;  25 import com.datastax.driver.core.ColumnDefinitions;  26 import com.datastax.driver.core.ColumnDefinitions.Definition;  27 import com.datastax.driver.core.DataType;  28 import com.datastax.driver.core.PreparedStatement;  29 import com.datastax.driver.core.Row;  30 import com.google.common.collect.Maps;  31  32 /**  33  * <b>function:</b> cassandra 到 JavaEntity 映射转换  34  * @author hoojo  35  * @createDate 2017-1-19 下午6:20:47  36  * @file RowMapperUtils.java  37  * @package com.cnblogs.hoojo.cassar.utils  38  * @blog http://blog.csdn.net/IBM_hoojo  39  * @email hoojo_@126.com  40  * @version 1.0  41 */  42 public class RowMapperUtils {  43  44 private static final Logger logger = LoggerFactory.getLogger(RowMapperUtils.class);  45  46 public static boolean DEBUG = false;  47 public static String LOG_LEVEL = "TRACE";  48  49 /**  50  * <b>function:</b> 将查询的Row转换到target 对象中返回  51  * @author hoojo  52  * @createDate 2017-1-20 下午5:36:20  53  * @param target 返回Java对象  54  * @param row { @link Row}  55  * @return 返回Java对象  56 */  57 public static <T> T conversion(T target, Row row) {  58 return conversion(target, row, null);  59  }  60  61 /**  62  * <b>function:</b> 将查询的Row转换到target 对象中返回，row对象存在List、Set集合类型情况  63  * @author hoojo  64  * @createDate 2017-1-20 下午5:36:20  65  * @param target 返回Java对象  66  * @param row { @link Row}  67  * @param genericClass List中存储值 的class类型  68  * @return 返回Java对象  69 */  70 public static <T> T conversion(T target, Row row, Map<String, Class<?>> genericClass) {  71 return conversion(target, row, genericClass, null);  72  }  73  74 /**  75  * <b>function:</b> 将查询的Row转换到target 对象中返回，row对象存在List、Set、Map集合类型情况  76  * @author hoojo  77  * @createDate 2017-1-20 下午5:36:20  78  * @param target 返回Java对象  79  * @param row { @link Row}  80  * @param valClass List中存储值 的class类型  81  * @param keyClass List中存储Key 的class类型  82  * @return 返回Java对象  83 */  84 @SuppressWarnings("unchecked")  85 public static <T> T conversion(T target, Row row, Map<String, Class<?>> valClass, Map<String, Class<?>> keyClass) {  86 Class<T> clazz = (Class<T>) target.getClass();  87 return conversion(clazz, row, valClass, keyClass);  88  }  89  90 /**  91  * <b>function:</b> 将查询的Row转换到clazz实例对象返回，row对象存在List、Set集合类型情况  92  * @author hoojo  93  * @createDate 2017-1-20 下午5:36:20  94  * @param target 返回Java对象  95  * @param row { @link Row}  96  * @return 返回Java对象  97 */  98 public static <T> T conversion(Class<T> clazz, Row row) {  99 return conversion(clazz, row, null); 100  } 101 102 /** 103  * <b>function:</b> 将查询的Row转换到clazz实例对象返回，row对象存在List、Set集合类型情况 104  * @author hoojo 105  * @createDate 2017-1-20 下午5:36:20 106  * @param target 返回Java对象 107  * @param row { @link Row} 108  * @param genericClass List中存储值 的class类型 109  * @return 返回Java对象 110 */ 111 public static <T> T conversion(Class<T> clazz, Row row, Map<String, Class<?>> genericClass) { 112 return conversion(clazz, row, genericClass, null); 113  } 114 115 public static <T> T transform(T target, Row row, Map<String, Class<?>> valClass, Map<String, Class<?>> keyClass) { 116 117 ColumnDefinitions cols = row.getColumnDefinitions(); 118 Iterator<Definition> definitionIter = null; 119 120 definitionIter = cols.iterator(); 121 while (definitionIter.hasNext()) { 122 Definition definition = definitionIter.next(); 123 124 DataType type = definition.getType(); 125 String columnName = definition.getName(); 126 debug(String.format("列名：%s，列类型：%s", columnName, type)); 127 128 Object value = getData(row, type, columnName, valClass, keyClass); 129 debug(String.format("列名：%s，取值：%s", columnName, value)); 130 131 String camelName = camelName(columnName); 132 try { 133  PropertyUtils.setProperty(target, camelName, value); 134 } catch (IllegalAccessException | InvocationTargetException e) { 135 log("设置{}值发生异常：", camelName, e); 136 } catch (NoSuchMethodException ex) { 137 138 if (camelName.equals(camelName.toLowerCase())) { 139 log("This Class '{}' set '{}' method notfound.", new Object[] { target.getClass().getSimpleName(), camelName } ); 140 } else { 141 142 try { 143  PropertyUtils.setProperty(target, camelName.toLowerCase(), value); 144 } catch (IllegalAccessException | InvocationTargetException | IllegalArgumentException e) { 145 log("设置{}值发生异常：", camelName, e); 146 } catch (NoSuchMethodException e) { 147 log("This Class '{}' set '{}' or set '{}' method notfound.", new Object[] { target.getClass().getSimpleName(), camelName, camelName.toLowerCase() } ); 148  } 149  } 150  } 151  } 152 debug("target: " + target); 153 154 return target; 155  } 156 157 /** 158  * <b>function:</b> 将查询的Row转换到clazz实例对象返回，row对象存在List、Set、Map集合类型情况 159  * @author hoojo 160  * @createDate 2017-1-20 下午5:36:20 161  * @param target 返回Java对象 162  * @param row { @link Row} 163  * @param valClass List中存储值 的class类型 164  * @param keyClass List中存储Key 的class类型 165  * @return 返回Java对象 166 */ 167 public static <T> T conversion(Class<T> clazz, Row row, Map<String, Class<?>> valClass, Map<String, Class<?>> keyClass) { 168 169 T target = BeanUtils.instantiate(clazz); 170 Map<String, PropertyDescriptor> mappedFields = getMappedFields(target.getClass()); 171 172 ColumnDefinitions cols = row.getColumnDefinitions(); 173 Iterator<Definition> definitionIter = cols.iterator(); 174 while (definitionIter.hasNext()) { 175 Definition definition = definitionIter.next(); 176 177 DataType type = definition.getType(); 178 String columnName = definition.getName().toLowerCase(); 179 debug(String.format("列名：%s，列类型：%s", columnName, type)); 180 181 Object value = getData(row, type, columnName, valClass, keyClass); 182 debug(String.format("列名：%s，取值：%s", columnName, value)); 183 184 if (mappedFields.containsKey(columnName)) { 185 try { 186  mappedFields.get(columnName).getWriteMethod().invoke(target, value); 187 } catch (IllegalAccessException | InvocationTargetException e) { 188 log("设置{}值发生异常：{}", columnName, e); 189 } catch (Exception e) { 190 log("设置{}值发生异常：{}", columnName, e.getMessage()); 191  } 192 } else { 193 log("The target Class '{}' in Column '{}' setter method notFound", clazz.getSimpleName(), columnName); 194  } 195  } 196 debug("target: " + target); 197 198 return target; 199  } 200 201 /** 202  * <b>function:</b> 将查询的Row转换到target Map对象中返回 203  * @author hoojo 204  * @createDate 2017-1-20 下午5:36:20 205  * @param target 返回Map对象 206  * @param row { @link Row} 207  * @return 返回Map对象 208 */ 209 public static <T> Map<String, T> conversion(Map<String, T> target, Row row) { 210 return conversion(target, row, null); 211  } 212 213 /** 214  * <b>function:</b> 将查询的Row转换到target Map对象中返回，row对象存在List、Set集合类型情况 215  * @author hoojo 216  * @createDate 2017-1-20 下午5:36:20 217  * @param target 返回Map对象 218  * @param row { @link Row} 219  * @param genericClass List中存储值 的class类型 220  * @return 返回Map对象 221 */ 222 public static <T> Map<String, T> conversion(Map<String, T> target, Row row, Map<String, Class<?>> genericClass) { 223 return conversion(target, row, genericClass, null); 224  } 225 226 /** 227  * <b>function:</b> 将查询的Row转换到target Map对象中返回，row对象存在Map集合类型情况 228  * @author hoojo 229  * @createDate 2017-1-20 下午5:36:20 230  * @param target 返回Map对象 231  * @param row { @link Row} 232  * @param valClass MAP、List中存储值 的class类型 233  * @param keyClass MAP Key 的class类型 234  * @return 返回Map对象 235 */ 236 @SuppressWarnings("unchecked") 237 public static <T> Map<String, T> conversion(Map<String, T> target, Row row, Map<String, Class<?>> valClass, Map<String, Class<?>> keyClass) { 238 239 if (target == null) { 240 target = Maps.newHashMap(); 241  } 242 243 ColumnDefinitions cols = row.getColumnDefinitions(); 244 Iterator<Definition> definitionIter = cols.iterator(); 245 while (definitionIter.hasNext()) { 246 Definition definition = definitionIter.next(); 247 248 DataType type = definition.getType(); 249 String columnName = definition.getName().toLowerCase(); 250 debug(String.format("列名：%s，列类型：%s", columnName, type)); 251 252 Object value = getData(row, type, columnName, valClass, keyClass); 253 debug(String.format("列名：%s，取值：%s", columnName, value)); 254 255 String camelName = camelName(columnName); 256 if (value != null) { 257  target.put(camelName, (T) value); 258 } else { 259 target.put(camelName, null); 260  } 261  } 262 debug("target: " + target); 263 264 return target; 265  } 266 267 /** 268  * <b>function:</b> 为cql PreparedStatement对象自动绑定参数值 269  * @author hoojo 270  * @createDate 2017-1-20 下午5:33:18 271  * @param statement PreparedStatement 272  * @param params 参数实体 273  * @return BoundStatement 已绑定值 274 */ 275 public static <T> BoundStatement bind(PreparedStatement statement, Map<String, T> bindParam) { 276 277 BoundStatement boundStatement = null; 278 279 Map<String, T> params = Maps.newHashMap(bindParam); 280 281 Set<String> keys = bindParam.keySet(); 282 Iterator<String> iter = keys.iterator(); 283 while (iter.hasNext()) { 284 String key = iter.next(); 285 T val = bindParam.get(key); 286  params.put(key, val); 287 288 if (!bindParam.containsKey(key.toLowerCase())) { 289  params.put(key.toLowerCase(), val); 290  } 291 292 key = underscoreName(key).toLowerCase(); 293 if (!bindParam.containsKey(key)) { 294  params.put(key, val); 295  } 296  } 297 298 Map<String, Object> bindParams = Maps.newLinkedHashMap(); 299 300 ColumnDefinitions cols = statement.getVariables(); 301 Iterator<Definition> definitionIter = cols.iterator(); 302 while (definitionIter.hasNext()) { 303 Definition definition = definitionIter.next(); 304 305 DataType type = definition.getType(); 306 String columnName = definition.getName().toLowerCase(); 307 debug(String.format("参数列名：%s，参数列类型：%s", columnName, type)); 308 309 Object param = null; 310 if (params.containsKey(columnName)) { 311 param = params.get(columnName); 312 } else { 313 log("The target Map does not exist param '{}' value.", columnName); 314  } 315 debug(String.format("参数列名：%s，参数取值：%s", columnName, param)); 316 317  bindParams.put(columnName, param); 318  } 319 320  debugCQL(statement.getQueryString(), bindParams); 321 322 boundStatement = statement.bind(bindParams.values().toArray()); 323 return boundStatement; 324  } 325 326 /** 327  * <b>function:</b> 为cql PreparedStatement对象自动绑定参数值 328  * @author hoojo 329  * @createDate 2017-1-20 下午5:33:18 330  * @param statement PreparedStatement 331  * @param bindEntity 参数实体 332  * @return BoundStatement 已绑定值 333 */ 334 public static <T> BoundStatement bind(PreparedStatement statement, T bindEntity) { 335 336 BoundStatement boundStatement = null; 337 338 Map<String, Object> params = Maps.newLinkedHashMap(); 339 Map<String, PropertyDescriptor> mappedFields = getMappedFields(bindEntity.getClass()); 340 341 ColumnDefinitions cols = statement.getVariables(); 342 Iterator<Definition> definitionIter = cols.iterator(); 343 while (definitionIter.hasNext()) { 344 Definition definition = definitionIter.next(); 345 346 DataType type = definition.getType(); 347 String columnName = definition.getName().toLowerCase(); 348 debug(String.format("参数列名：%s，参数列类型：%s", columnName, type)); 349 350 Object param = null; 351 if (mappedFields.containsKey(columnName)) { 352 try { 353 param = mappedFields.get(columnName).getReadMethod().invoke(bindEntity); 354 } catch (IllegalAccessException | InvocationTargetException e) { 355 log("设置{}值发生异常：", columnName, e); 356  } 357 } else { 358 log("The target Class '{}' in Column '{}' getter method notFound", bindEntity.getClass().getSimpleName(), columnName); 359  } 360 debug(String.format("参数列名：%s，参数取值：%s", columnName, param)); 361 362  params.put(columnName, param); 363  } 364 365  debugCQL(statement.getQueryString(), params); 366 367 boundStatement = statement.bind(params.values().toArray()); 368 return boundStatement; 369  } 370 371 /** 372  * <b>function:</b> 调试cql语句，将占位符替换参数值 373  * @author hoojo 374  * @createDate 2017-1-20 下午5:30:48 375  * @param queryString cql语句 376  * @param params 参数 377 */ 378 private static void debugCQL(String queryString, Map<String, Object> params) { 379 380 if (DEBUG) { 381 Set<String> keys = params.keySet(); 382 383 Object[] keyArrays = keys.toArray(); 384 for (int i = 0; i < keys.size(); i++) { 385 386 queryString = StringUtils.replaceOnce(queryString, "?", MapUtils.getString(params, keyArrays[i], "NULL")); 387  } 388 logger.info("debug cql: {}", queryString); 389  } 390  } 391 392 private static void debug(String log) { 393 394 if (DEBUG) { 395  logger.info(log); 396  } 397  } 398 399 private static void log(String msg, Object... args) { 400 401 if ("INFO".equalsIgnoreCase(LOG_LEVEL)) { 402  logger.info(msg, args); 403 } else if ("WARN".equalsIgnoreCase(LOG_LEVEL)) { 404  logger.warn(msg, args); 405 } else if ("DEBUG".equalsIgnoreCase(LOG_LEVEL)) { 406  logger.debug(msg, args); 407 } else if ("TRACE".equalsIgnoreCase(LOG_LEVEL)) { 408  logger.trace(msg, args); 409 } else if ("ERROR".equalsIgnoreCase(LOG_LEVEL)) { 410  logger.error(msg, args); 411  } 412  } 413 414 /** 415  * <b>function:</b> 获取对象的setter方法，并返回下划线命名和全小写命名的Map集合 416  * @author hoojo 417  * @createDate 2017-1-20 下午5:31:21 418  * @param clazz 目标对象class 419  * @return Map 420 */ 421 private static Map<String, PropertyDescriptor> getMappedFields(Class<?> clazz) { 422 Map<String, PropertyDescriptor> mappedFields = new HashMap<String, PropertyDescriptor>(); 423 424 PropertyDescriptor[] pds = BeanUtils.getPropertyDescriptors(clazz); 425 for (PropertyDescriptor pd : pds) { 426 if (pd.getWriteMethod() != null) { 427 428 //setUserId->userid,user_id; 429  mappedFields.put(pd.getName().toLowerCase(), pd); 430 431 String underscoreName = underscoreName(pd.getName()); 432 if (!pd.getName().toUpperCase().equals(underscoreName)) { 433  mappedFields.put(underscoreName.toLowerCase(), pd); 434  } 435  } 436  } 437 438 return mappedFields; 439  } 440 441 /** 442  * <b>function:</b> 获取cql 的值 443  * @author hoojo 444  * @createDate 2017-1-20 下午5:26:24 445  * @param row { @link Row} 446  * @param type 列类型 447  * @param columnName 列名 448  * @param valClass MAP、List中存储值 的class类型 449  * @param keyClass MAP Key 的class类型 450  * @return 451 */ 452 private static Object getData(Row row, DataType type, String columnName, Map<String, Class<?>> valClass, Map<String, Class<?>> keyClass) { 453 454 Object value = null; 455 456 try { 457 458 if (type == DataType.bigint()) { 459 value = row.getLong(columnName); 460 } else if (type == DataType.cboolean()) { 461 value = row.getBool(columnName); 462 } else if (type == DataType.blob()) { 463 value = row.getBytes(columnName); 464 } else if (type == DataType.timestamp()) { 465 value = row.getDate(columnName); 466 } else if (type == DataType.decimal()) { 467 value = row.getDecimal(columnName); 468 } else if (type == DataType.cfloat()) { 469 value = row.getFloat(columnName); 470 } else if (type == DataType.inet()) { 471 value = row.getInet(columnName); 472 } else if (type == DataType.cint()) { 473 value = row.getInt(columnName); 474 } else if (type.isCollection() && type.asJavaClass() == List.class) { 475 value = getCollectionData(row, type, columnName, valClass); 476 } else if (type.isCollection() && type.asJavaClass() == Set.class) { 477 value = getCollectionData(row, type, columnName, valClass); 478 } else if (type.isCollection() && type.asJavaClass() == Map.class) { 479 value = getCollectionData(row, type, columnName, valClass, keyClass); 480 } else if (type == DataType.varchar()) { 481 value = row.getString(columnName); 482 } else if (type == DataType.uuid() || type == DataType.timeuuid()) { 483 value = row.getUUID(columnName); 484 } else if (type == DataType.varint()) { 485 value = row.getVarint(columnName); 486 } else if (type == DataType.cdouble()) { 487 value = row.getDouble(columnName); 488 } else if (type == DataType.text()) { 489 value = row.getString(columnName); 490  } 491 492 } catch (Exception e) { 493 log("获取{}值发生异常：", columnName, e); 494  } 495 496 if (value == null) { 497 log("Column '{}' Type({}) get cassandra data is NULL.", columnName, type); 498  } 499 500 return value; 501  } 502 503 /** 504  * <b>function:</b> 获取cql List集合泛型的值 505  * @author hoojo 506  * @createDate 2017-1-20 下午5:26:24 507  * @param row { @link Row} 508  * @param type 列类型 509  * @param columnName 列名 510  * @param valClass List Value 的class类型 511  * @return 512 */ 513 private static Object getCollectionData(Row row, DataType type, String columnName, Map<String, Class<?>> valClass) { 514 515 Object value = null; 516 517 Class<?> ofValueType = valClass != null ? valClass.get(columnName) : null; 518 List<DataType> typeArguments = type.getTypeArguments(); 519 if (ofValueType == null) { 520 log("Column TypeArguments convter Error, CQL Type: '{} {}' --> '{} {}(NULL)'", new Object[] { columnName, type, columnName, type.getName() }); 521 } else if (ofValueType != typeArguments.get(0).asJavaClass()) { 522 log("Column TypeArguments convter Error, CQL Type: '{} {}({})' --> '{} {}({})'", new Object[] { columnName, type, typeArguments.get(0).asJavaClass(), columnName, valueOf(type.asJavaClass(), ofValueType), ofValueType }); 523 } else if (type.asJavaClass() == List.class) { 524 value = row.getList(columnName, ofValueType); 525 } else if (type.asJavaClass() == Set.class) { 526 value = row.getSet(columnName, ofValueType); 527  } 528 529 return value; 530  } 531 532 /** 533  * <b>function:</b> 获取cql MAP集合泛型的值 534  * @author hoojo 535  * @createDate 2017-1-20 下午5:26:24 536  * @param row { @link Row} 537  * @param type 列类型 538  * @param columnName 列名 539  * @param valClass MAP Value 的class类型 540  * @param keyClass MAP Key 的class类型 541  * @return 542 */ 543 private static Object getCollectionData(Row row, DataType type, String columnName, Map<String, Class<?>> valClass, Map<String, Class<?>> keyClass) { 544 545 Object value = null; 546 547 Class<?> ofKeyType = keyClass != null ? keyClass.get(columnName) : null; 548 Class<?> ofValueType = valClass != null ? valClass.get(columnName) : null; 549 550 List<DataType> typeArguments = type.getTypeArguments(); 551 if (ofValueType == null && ofKeyType == null) { 552 log("Column TypeArguments convter Error, CQL Type: '{} {}' --> '{} {}<NULL, NULL>'", new Object[] { columnName, type, columnName, type.getName() }); 553 } else if (ofValueType == null) { 554 log("Column TypeArguments convter Error, CQL Type: '{} {}' --> '{} {}<{}, NULL>'", new Object[] { columnName, type, columnName, type.getName(), valueOf(ofKeyType) }); 555 } else if (ofKeyType == null) { 556 log("Column TypeArguments convter Error, CQL Type: '{} {}' --> '{} {}<NULL, {}>'", new Object[] { columnName, type, columnName, type.getName(), valueOf(ofValueType) }); 557 } else if (ofKeyType != typeArguments.get(0).asJavaClass() || ofValueType != typeArguments.get(1).asJavaClass()) { 558 log("Column TypeArguments convter Error, CQL Type: '{} {} (<{}, {}>)' --> '{} {}(<{}, {}>)'", new Object[] { columnName, type, typeArguments.get(0).asJavaClass(), typeArguments.get(1).asJavaClass(), columnName, valueOf(Map.class, ofValueType, ofKeyType), ofKeyType, ofValueType }); 559 } else { 560 value = row.getMap(columnName, ofKeyType, ofValueType); 561  } 562 563 return value; 564  } 565 566 /** 567  * <b>function:</b> 转换为下划线命名方式 568  * @author hoojo 569  * @createDate 2017-1-20 下午5:24:50 570 */ 571 public static String underscoreName(String name) { 572 StringBuilder result = new StringBuilder(); 573 if (name != null && name.length() > 0) { 574 // 将第一个字符处理成大写 575 result.append(name.substring(0, 1).toUpperCase()); 576 // 循环处理其余字符 577 for (int i = 1; i < name.length(); i++) { 578 String s = name.substring(i, i + 1); 579 // 在大写字母前添加下划线 580 if (s.equals(s.toUpperCase()) && !Character.isDigit(s.charAt(0))) { 581 result.append("_"); 582  } 583 // 其他字符直接转成大写 584  result.append(s.toUpperCase()); 585  } 586  } 587 return result.toString(); 588  } 589 590 /** 591  * <b>function:</b> 驼峰式命名方式 592  * @author hoojo 593  * @createDate 2017-1-20 下午5:25:09 594 */ 595 public static String camelName(String name) { 596 StringBuilder sb = new StringBuilder(); 597 if (!name.contains("_")) { 598 // 不含下划线，仅将首字母小写 599 return name.substring(0, 1).toLowerCase() + name.substring(1); 600  } 601 // 用下划线将原始字符串分割 602 String camels[] = name.split("_"); 603 for (String camel : camels) { 604 // 跳过原始字符串中开头、结尾的下换线或双重下划线 605 if (camel.isEmpty()) { 606 continue; 607  } 608 // 处理真正的驼峰片段 609 if (sb.length() == 0) { 610 // 第一个驼峰片段，全部字母都小写 611  sb.append(camel.toLowerCase()); 612 } else { 613 // 其他的驼峰片段，首字母大写 614 sb.append(camel.substring(0, 1).toUpperCase()); 615 sb.append(camel.substring(1).toLowerCase()); 616  } 617  } 618 return sb.toString(); 619  } 620 621 /** 622  * <b>function:</b> java class转换到cql类型 623  * @author hoojo 624  * @createDate 2017-1-20 下午5:24:09 625  * @param clazz Class 626  * @return { @link DataType} 627 */ 628 private static DataType valueOf(Class<?> clazz) { 629 630 if (clazz == null) { 631 return DataType.custom("NULL"); 632  } 633 if (clazz == long.class || clazz == Long.class) { 634 return DataType.bigint(); 635  } 636 if (clazz == boolean.class || clazz == Boolean.class) { 637 return DataType.cboolean(); 638  } 639 if (clazz == Byte.class || clazz == byte.class) { 640 return DataType.blob(); 641  } 642 if (clazz == Date.class || clazz == Timestamp.class) { 643 return DataType.timestamp(); 644  } 645 if (clazz == BigDecimal.class) { 646 return DataType.decimal(); 647  } 648 if (clazz == float.class || clazz == Float.class) { 649 return DataType.cfloat(); 650  } 651 if (clazz == InetAddress.class) { 652 return DataType.inet(); 653  } 654 if (clazz == int.class || clazz == Integer.class) { 655 return DataType.cint(); 656  } 657 if (clazz == String.class) { 658 return DataType.varchar();// text(); 659  } 660 if (clazz == UUID.class) { 661 return DataType.uuid(); // timeuuid(); 662  } 663 if (clazz == BigInteger.class) { 664 return DataType.varint(); 665  } 666 667 log("Class '{}' unknow DataType in cassandra.", clazz); 668 669 return DataType.custom("unknow"); 670  } 671 672 /** 673  * <b>function:</b> 转换集合list、set到cql类型 674  * @author hoojo 675  * @createDate 2017-1-20 下午5:22:43 676  * @param clazz java class 677  * @param valueClass 集合值存储类型class 678  * @param keyClass 集合键存储类型class 679  * @return DataType 680 */ 681 public static DataType valueOf(Class<?> clazz, Class<?> valueClass, Class<?> keyClass) { 682 683 if (clazz == List.class) { 684 return DataType.list(valueOf(valueClass)); 685  } 686 if (clazz == Set.class) { 687 return DataType.set(valueOf(valueClass)); 688  } 689 if (clazz == Map.class) { 690 return DataType.map(valueOf(keyClass), valueOf(valueClass)); 691  } 692 693 log("Class '{}' unknow DataType in cassandra.", clazz); 694 return DataType.custom("unknow"); 695  } 696 697 /** 698  * <b>function:</b> 转换集合list、set到cql类型 699  * @author hoojo 700  * @createDate 2017-1-20 下午5:22:43 701  * @param clazz java class 702  * @param valueClass 集合存储类型class 703  * @return DataType 704 */ 705 private static DataType valueOf(Class<?> clazz, Class<?> valueClass) { 706 707 return valueOf(clazz, valueClass, null); 708  } 709 }