add prepared statements and counters

src/casser/Example.java

@@ -1,7 +1,9 @@
 package casser;
 
 import casser.core.Casser;
+import casser.core.PreparedStreamStatement;
 import casser.core.Session;
+import casser.tuple.Tuple1;
 import casser.tuple.Tuple2;
 
 public class Example {
@@ -35,6 +37,13 @@ public class Example {
 		
 		session.delete().where(_user::getId, "==", 100L).async();
 		
+		
+		PreparedStreamStatement<Tuple1<String>> ps = session.select(_user::getName).where(_user::getId, "==", null).prepare();
+		
+		long cnt = ps.bind(100L).sync().count();
+		
+		cnt = session.select(_user::getName).where(_user::getId, "==", 100L).count().sync();
+		
 	}
 	
 }

src/casser/core/PreparedStatement.java

@@ -0,0 +1,11 @@
+package casser.core;
+
+import casser.operation.AbstractOperation;
+
+public class PreparedStatement<E> {
+
+	public AbstractOperation<E> bind(Object... params) {
+		return null;
+	}
+	
+}

src/casser/core/PreparedStreamStatement.java

@@ -0,0 +1,11 @@
+package casser.core;
+
+import casser.operation.AbstractStreamOperation;
+
+public class PreparedStreamStatement<E> {
+
+	public AbstractStreamOperation<E> bind(Object... params) {
+		return null;
+	}
+	
+}

src/casser/operation/AbstractOperation.java

@@ -2,8 +2,14 @@ package casser.operation;
 
 import java.util.concurrent.Future;
 
+import casser.core.PreparedStreamStatement;
+
 public abstract class AbstractOperation<E> {
 
+	public PreparedStreamStatement<E> prepare() {
+		return null;
+	}
+	
 	public E sync() {
 		return null;
 	}

src/casser/operation/AbstractStreamOperation.java

@@ -3,8 +3,14 @@ package casser.operation;
 import java.util.concurrent.Future;
 import java.util.stream.Stream;
 
+import casser.core.PreparedStreamStatement;
+
 public abstract class AbstractStreamOperation<E> {
 
+	public PreparedStreamStatement<E> prepare() {
+		return null;
+	}
+	
 	public Stream<E> sync() {
 		return null;
 	}

src/casser/operation/CountOperation.java

@@ -0,0 +1,5 @@
+package casser.operation;
+
+public class CountOperation extends AbstractOperation<Long> {
+
+}

src/casser/operation/SelectOperation.java

@@ -15,6 +15,10 @@ public class SelectOperation<E> extends AbstractStreamOperation<E> {
 		return this;
 	}
 
+	public CountOperation count() {
+		return null;
+	}
+	
 	public <R> SelectOperation<R> map(Function<E, R> fn) {
 		return null;
 	}