Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 1 | package org.onlab.onos.store.service.impl; |
| 2 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 3 | import static com.google.common.base.Preconditions.checkNotNull; |
| 4 | |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 5 | import java.util.List; |
Yuta HIGUCHI | 841c0b6 | 2014-11-13 20:27:14 -0800 | [diff] [blame^] | 6 | import java.util.Map; |
Madan Jampani | f5d263b | 2014-11-13 10:04:40 -0800 | [diff] [blame] | 7 | import java.util.Set; |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 8 | import java.util.concurrent.CompletableFuture; |
| 9 | import java.util.concurrent.ExecutionException; |
| 10 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 11 | import net.kuujo.copycat.Copycat; |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 12 | |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 13 | import org.onlab.onos.store.service.BatchReadRequest; |
| 14 | import org.onlab.onos.store.service.BatchWriteRequest; |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 15 | import org.onlab.onos.store.service.DatabaseException; |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 16 | import org.onlab.onos.store.service.ReadResult; |
Yuta HIGUCHI | 841c0b6 | 2014-11-13 20:27:14 -0800 | [diff] [blame^] | 17 | import org.onlab.onos.store.service.VersionedValue; |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 18 | import org.onlab.onos.store.service.WriteResult; |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 19 | |
Madan Jampani | 686fa18 | 2014-11-04 23:16:27 -0800 | [diff] [blame] | 20 | /** |
| 21 | * Client for interacting with the Copycat Raft cluster. |
| 22 | */ |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 23 | public class DatabaseClient { |
| 24 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 25 | private final Copycat copycat; |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 26 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 27 | public DatabaseClient(Copycat copycat) { |
| 28 | this.copycat = checkNotNull(copycat); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 29 | } |
| 30 | |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 31 | public boolean createTable(String tableName) { |
| 32 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 33 | CompletableFuture<Boolean> future = copycat.submit("createTable", tableName); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 34 | try { |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 35 | return future.get(); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 36 | } catch (InterruptedException | ExecutionException e) { |
| 37 | throw new DatabaseException(e); |
| 38 | } |
| 39 | } |
| 40 | |
Madan Jampani | def2c65 | 2014-11-12 13:50:10 -0800 | [diff] [blame] | 41 | public boolean createTable(String tableName, int ttlMillis) { |
| 42 | |
Madan Jampani | f5d263b | 2014-11-13 10:04:40 -0800 | [diff] [blame] | 43 | CompletableFuture<Boolean> future = copycat.submit("createTableWithExpiration", tableName); |
Madan Jampani | def2c65 | 2014-11-12 13:50:10 -0800 | [diff] [blame] | 44 | try { |
| 45 | return future.get(); |
| 46 | } catch (InterruptedException | ExecutionException e) { |
| 47 | throw new DatabaseException(e); |
| 48 | } |
| 49 | } |
| 50 | |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 51 | public void dropTable(String tableName) { |
| 52 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 53 | CompletableFuture<Void> future = copycat.submit("dropTable", tableName); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 54 | try { |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 55 | future.get(); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 56 | } catch (InterruptedException | ExecutionException e) { |
| 57 | throw new DatabaseException(e); |
| 58 | } |
| 59 | } |
| 60 | |
| 61 | public void dropAllTables() { |
| 62 | |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 63 | CompletableFuture<Void> future = copycat.submit("dropAllTables"); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 64 | try { |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 65 | future.get(); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 66 | } catch (InterruptedException | ExecutionException e) { |
| 67 | throw new DatabaseException(e); |
| 68 | } |
| 69 | } |
| 70 | |
Madan Jampani | f5d263b | 2014-11-13 10:04:40 -0800 | [diff] [blame] | 71 | public Set<String> listTables() { |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 72 | |
Madan Jampani | f5d263b | 2014-11-13 10:04:40 -0800 | [diff] [blame] | 73 | CompletableFuture<Set<String>> future = copycat.submit("listTables"); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 74 | try { |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 75 | return future.get(); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 76 | } catch (InterruptedException | ExecutionException e) { |
| 77 | throw new DatabaseException(e); |
| 78 | } |
| 79 | } |
| 80 | |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 81 | public List<ReadResult> batchRead(BatchReadRequest batchRequest) { |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 82 | |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 83 | CompletableFuture<List<ReadResult>> future = copycat.submit("read", batchRequest); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 84 | try { |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 85 | return future.get(); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 86 | } catch (InterruptedException | ExecutionException e) { |
| 87 | throw new DatabaseException(e); |
| 88 | } |
| 89 | } |
| 90 | |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 91 | public List<WriteResult> batchWrite(BatchWriteRequest batchRequest) { |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 92 | |
Madan Jampani | 12390c1 | 2014-11-12 00:35:56 -0800 | [diff] [blame] | 93 | CompletableFuture<List<WriteResult>> future = copycat.submit("write", batchRequest); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 94 | try { |
Yuta HIGUCHI | f846844 | 2014-11-11 10:09:20 -0800 | [diff] [blame] | 95 | return future.get(); |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 96 | } catch (InterruptedException | ExecutionException e) { |
| 97 | throw new DatabaseException(e); |
| 98 | } |
| 99 | } |
Yuta HIGUCHI | 841c0b6 | 2014-11-13 20:27:14 -0800 | [diff] [blame^] | 100 | |
| 101 | public Map<String, VersionedValue> getAll(String tableName) { |
| 102 | CompletableFuture<Map<String, VersionedValue>> future = copycat.submit("getAll", tableName); |
| 103 | try { |
| 104 | return future.get(); |
| 105 | } catch (InterruptedException | ExecutionException e) { |
| 106 | throw new DatabaseException(e); |
| 107 | } |
| 108 | } |
Madan Jampani | 08822c4 | 2014-11-04 17:17:46 -0800 | [diff] [blame] | 109 | } |