Permalink
Browse files

fix for new querulous.

  • Loading branch information...
1 parent c3fb31a commit b8a90c09b5dc0d80ba7b1d09cc855d9c0208f004 Robey Pointer committed Nov 16, 2010
Showing with 5 additions and 1 deletion.
  1. +5 −1 src/main/scala/com/twitter/flockdb/shards/SqlShard.scala
@@ -29,7 +29,9 @@ import net.lag.configgy.ConfigMap
import net.lag.logging.Logger
import State._
-object SelectModify extends QueryClass("select_modify")
+object FlockQueryClass {
+ val SelectModify = QueryClass("select_modify")
+}
class SqlShardFactory(instantiatingQueryEvaluatorFactory: QueryEvaluatorFactory, materializingQueryEvaluatorFactory: QueryEvaluatorFactory, config: ConfigMap)
extends shards.ShardFactory[Shard] {
@@ -88,6 +90,8 @@ class SqlShard(private val queryEvaluator: QueryEvaluator, val shardInfo: shards
private val tablePrefix = shardInfo.tablePrefix
private val randomGenerator = new util.Random
+ import FlockQueryClass._
+
def get(sourceId: Long, destinationId: Long) = {
queryEvaluator.selectOne("SELECT * FROM " + tablePrefix + "_edges WHERE source_id = ? AND destination_id = ?", sourceId, destinationId) { row =>
makeEdge(row)

0 comments on commit b8a90c0

Please sign in to comment.