Skip to content

Commit

Permalink
formatting. make it easier to grab sql out of the model reader.
Browse files Browse the repository at this point in the history
  • Loading branch information
chenson42 committed Nov 11, 2011
1 parent b795247 commit ef6c81f
Showing 1 changed file with 15 additions and 15 deletions.
Expand Up @@ -24,21 +24,21 @@ protected void setDistributionKeys(Connection connection, Table table, String sc
// get the distribution keys for segments
StringBuilder query = new StringBuilder();

query.append("select ");
query.append(" t.relname, ");
query.append(" a.attname ");
query.append("from ");
query.append(" pg_class t, ");
query.append(" pg_namespace n, ");
query.append(" pg_attribute a, ");
query.append(" gp_distribution_policy p ");
query.append("where ");
query.append(" n.oid = t.relnamespace and ");
query.append(" p.localoid = t.oid and ");
query.append(" a.attrelid = t.oid and ");
query.append(" a.attnum = any(p.attrnums) and ");
query.append(" n.nspname = ? and ");
query.append(" t.relname = ?");
query.append("select ");
query.append(" t.relname, ");
query.append(" a.attname ");
query.append("from ");
query.append(" pg_class t, ");
query.append(" pg_namespace n, ");
query.append(" pg_attribute a, ");
query.append(" gp_distribution_policy p ");
query.append("where ");
query.append(" n.oid = t.relnamespace and ");
query.append(" p.localoid = t.oid and ");
query.append(" a.attrelid = t.oid and ");
query.append(" a.attnum = any(p.attrnums) and ");
query.append(" n.nspname = ? and ");
query.append(" t.relname = ? ");

PreparedStatement prepStmt = connection.prepareStatement(query.toString());

Expand Down

0 comments on commit ef6c81f

Please sign in to comment.