完成基本的api

Signed-off-by: qianjc <leviqian@sina.com>

Author: JThink

.gitignore

@@ -0,0 +1,21 @@
+bin/
+target/
+file/
+logs/
+gen-java/
+.externalToolBuilders/
+.settings/
+.gradle/
+.classpath
+.gradletasknamecache
+.buildpath
+.project
+.springBeans
+dependency-reduced-pom.xml
+*.iml
+nohup.out
+/tmp
+/.apt_generated/
+.idea/
+disconf/
+/target/

README.md

@@ -1 +1,4 @@
-# spring-boot-starter-hbase
+# 项目介绍
+自定义的spring-boot的hbase starter，为hbase的query操作提供简易的api并集成spring-boot的auto configuration
+# 使用方式
+## 集成

build.gradle

@@ -0,0 +1,82 @@
+apply plugin: 'java'
+apply plugin: 'maven'
+apply plugin: 'eclipse'
+apply plugin: 'idea'
+apply plugin: 'spring-boot'
+
+group = 'jthink'
+version = '0.0.1'
+
+sourceCompatibility = 1.7
+targetCompatibility = 1.7
+compileJava.options.encoding = 'UTF-8'
+buildDir = 'target'
+
+ext {
+  mavenPublicUrl = 'http://192.168.88.8:8081/nexus/content/repositories/public'
+  mavenReleaseUrl = 'http://192.168.88.8:8081/nexus/content/repositories/releases'
+  mavenSnapshotUrl = 'http://192.168.88.8:8081/nexus/content/repositories/snapshots'
+  springBootVersion = '1.3.6.RELEASE'
+  springVersion = '4.2.7.RELEASE'
+  hbaseVersion = '1.0.0-cdh5.4.0'
+  slf4jVersion = '1.7.21'
+}
+
+repositories {
+  mavenLocal()
+  maven { url "https://repository.cloudera.com/artifactory/cloudera-repos" }
+  maven { url mavenPublicUrl }
+  maven { url mavenReleaseUrl }
+  maven { url mavenSnapshotUrl }
+  mavenCentral()
+}
+
+task sourcesJar(type: Jar, dependsOn: classes) {
+  classifier = 'sources'
+  from sourceSets.main.allSource
+}
+
+artifacts {
+  archives sourcesJar
+}
+
+uploadArchives {
+  repositories {
+    mavenDeployer {
+      repository(url: mavenReleaseUrl) {
+        authentication(userName: 'admin', password: 'admin123')
+      }
+      snapshotRepository(url: mavenSnapshotUrl) {
+        authentication(userName: 'admin', password: 'admin123')
+      }
+    }
+  }
+}
+
+dependencies {
+  compile "org.slf4j:slf4j-api:$slf4jVersion"
+  compile "org.springframework.boot:spring-boot-autoconfigure:$springBootVersion"
+  compile "org.springframework:spring-tx:$springVersion"
+  compile ("org.apache.hbase:hbase-client:$hbaseVersion") {
+    exclude group: 'javax.servlet', module: 'servlet-api'
+  }
+
+  testCompile "junit:junit:4.12"
+}
+
+buildscript {
+  ext {
+    springBootVersion = '1.3.6.RELEASE'
+  }
+
+  repositories {
+    mavenLocal()
+    maven { url "http://192.168.88.8:8081/nexus/content/groups/public" }
+    mavenCentral()
+  }
+
+  dependencies {
+    classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
+    classpath("io.spring.gradle:dependency-management-plugin:0.6.0.RELEASE")
+  }
+}

settings.gradle

@@ -0,0 +1 @@
+rootProject.name = 'spring-boot-starter-hbase'

src/main/java/com/jthink/spring/boot/starter/hbase/api/HbaseOperations.java

@@ -0,0 +1,132 @@
+package com.jthink.spring.boot.starter.hbase.api;
+
+import org.apache.hadoop.hbase.client.Mutation;
+import org.apache.hadoop.hbase.client.Scan;
+
+import java.util.List;
+
+/**
+ * Interface that specifies a basic set of Hbase operations, implemented by {@link HbaseTemplate}. Not often used,
+ * but a useful option to enhance testability, as it can easily be mocked or stubbed.
+ *
+ * @author Costin Leau
+ * @author Shaun Elliott
+ */
+/**
+ * JThink@JThink
+ *
+ * @author JThink
+ * @version 0.0.1
+ * @desc copy from spring data hadoop hbase, modified by JThink, remove the unuse interface
+ * @date 2016-11-15 14:49:52
+ */
+public interface HbaseOperations {
+
+    /**
+     * Executes the given action against the specified table handling resource management.
+     * <p>
+     * Application exceptions thrown by the action object get propagated to the caller (can only be unchecked).
+     * Allows for returning a result object (typically a domain object or collection of domain objects).
+     *
+     * @param tableName the target table
+     * @param action callback object that specifies the action
+     * @param <T> action type
+     * @return the result object of the callback action, or null
+     */
+    <T> T execute(String tableName, TableCallback<T> mapper);
+
+    /**
+     * Scans the target table, using the given column family.
+     * The content is processed row by row by the given action, returning a list of domain objects.
+     *
+     * @param tableName target table
+     * @param family column family
+     * @param action row mapper handling the scanner results
+     * @param <T> action type
+     * @return a list of objects mapping the scanned rows
+     */
+    <T> List<T> find(String tableName, String family, final RowMapper<T> mapper);
+
+    /**
+     * Scans the target table, using the given column family.
+     * The content is processed row by row by the given action, returning a list of domain objects.
+     *
+     * @param tableName target table
+     * @param family column family
+     * @param qualifier column qualifier
+     * @param action row mapper handling the scanner results
+     * @param <T> action type
+     * @return a list of objects mapping the scanned rows
+     */
+    <T> List<T> find(String tableName, String family, String qualifier, final RowMapper<T> mapper);
+
+    /**
+     * Scans the target table using the given {@link Scan} object. Suitable for maximum control over the scanning
+     * process.
+     * The content is processed row by row by the given action, returning a list of domain objects.
+     *
+     * @param tableName target table
+     * @param scan table scanner
+     * @param action row mapper handling the scanner results
+     * @param <T> action type
+     * @return a list of objects mapping the scanned rows
+     */
+    <T> List<T> find(String tableName, final Scan scan, final RowMapper<T> mapper);
+
+    /**
+     * Gets an individual row from the given table. The content is mapped by the given action.
+     *
+     * @param tableName target table
+     * @param rowName row name
+     * @param mapper row mapper
+     * @param <T> mapper type
+     * @return object mapping the target row
+     */
+    <T> T get(String tableName, String rowName, final RowMapper<T> mapper);
+
+    /**
+     * Gets an individual row from the given table. The content is mapped by the given action.
+     *
+     * @param tableName target table
+     * @param rowName row name
+     * @param familyName column family
+     * @param mapper row mapper
+     * @param <T> mapper type
+     * @return object mapping the target row
+     */
+    <T> T get(String tableName, String rowName, String familyName, final RowMapper<T> mapper);
+
+    /**
+     * Gets an individual row from the given table. The content is mapped by the given action.
+     *
+     * @param tableName target table
+     * @param rowName row name
+     * @param familyName family
+     * @param qualifier column qualifier
+     * @param mapper row mapper
+     * @param <T> mapper type
+     * @return object mapping the target row
+     */
+    <T> T get(String tableName, final String rowName, final String familyName, final String qualifier, final RowMapper<T> mapper);
+
+    /**
+     * 执行put update or delete
+     * @param tableName
+     * @param action
+     */
+    void execute(String tableName, MutatorCallback action);
+
+    /**
+     *
+     * @param tableName
+     * @param mutation
+     */
+    void saveOrUpdate(String tableName, Mutation mutation);
+
+    /**
+     *
+     * @param tableName
+     * @param mutations
+     */
+    void saveOrUpdates(String tableName, List<Mutation> mutations);
+}

src/main/java/com/jthink/spring/boot/starter/hbase/api/HbaseSystemException.java

@@ -0,0 +1,27 @@
+package com.jthink.spring.boot.starter.hbase.api;
+
+import org.springframework.dao.UncategorizedDataAccessException;
+
+/**
+ * HBase Data Access exception.
+ *
+ * @author Costin Leau
+ */
+/**
+ * JThink@JThink
+ *
+ * @author JThink
+ * @version 0.0.1
+ * @desc copy from spring data hadoop hbase, modified by JThink
+ * @date 2016-11-15 16:08:41
+ */
+public class HbaseSystemException extends UncategorizedDataAccessException {
+
+    public HbaseSystemException(Exception cause) {
+        super(cause.getMessage(), cause);
+    }
+
+    public HbaseSystemException(Throwable throwable) {
+        super(throwable.getMessage(), throwable);
+    }
+}