Skip to content
This repository has been archived by the owner on Sep 18, 2021. It is now read-only.

Commit

Permalink
use two separate queries instead of a union.
Browse files Browse the repository at this point in the history
Conflicts:

	src/main/scala/com/twitter/flockdb/shards/SqlShard.scala
  • Loading branch information
eaceaser committed Apr 5, 2011
1 parent aca10bd commit 32610bc
Showing 1 changed file with 14 additions and 5 deletions.
19 changes: 14 additions & 5 deletions src/main/scala/com/twitter/flockdb/shards/SqlShard.scala
Expand Up @@ -226,9 +226,13 @@ class SqlShard(val queryEvaluator: QueryEvaluator, val shardInfo: shards.ShardIn

val (continueCursorQuery, args1) = query(cursorName, index, 1, cursor, opposite(order), opposite(inequality), conditions, args)
val (edgesQuery, args2) = query(cursorName, index, count + 1, cursor, order, inequality, conditions, args)
val totalQuery = continueCursorQuery + " UNION ALL " + edgesQuery
queryEvaluator.select(queryClass, totalQuery, args1 ++ args2: _*) { row =>
edges += (row.getLong("destination_id"), Cursor(row.getLong(cursorName)))
queryEvaluator.transaction { transaction =>
transaction.select(queryClass, continueCursorQuery, args1: _*) { row =>
edges += (row.getLong("destination_id") -> Cursor(row.getLong(cursorName)))
}
transaction.select(queryClass, edgesQuery, args2: _*) { row =>
edges += (row.getLong("destination_id") -> Cursor(row.getLong(cursorName)))
}
}

var page = edges.projection
Expand All @@ -245,8 +249,13 @@ class SqlShard(val queryEvaluator: QueryEvaluator, val shardInfo: shards.ShardIn
val (continueCursorQuery, args2) = query("*", "position", "PRIMARY", 1, cursor, opposite(order), opposite(inequality), conditions, args)

val edges = new mutable.ArrayBuffer[(Edge, Cursor)]
queryEvaluator.select(continueCursorQuery + " UNION ALL " + edgesQuery, args1 ++ args2: _*) { row =>
edges += (makeEdge(row), Cursor(row.getLong("position")))
queryEvaluator.transaction { transaction =>
transaction.select(continueCursorQuery, args1: _*) { row =>
edges += (makeEdge(row) -> Cursor(row.getLong("position")))
}
transaction.select(edgesQuery, args2: _*) { row =>
edges += (makeEdge(row) -> Cursor(row.getLong("position")))
}
}

var page = edges.projection
Expand Down

0 comments on commit 32610bc

Please sign in to comment.