AfflictionNetworks/depot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Unfiddle long lines.

Browse Source
This commit is contained in:
Michael Bayne
2008-08-16 20:30:52 +00:00
parent 338bb62d9f
commit 22fb614f34
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/java/com/samskivert/jdbc/depot/DepotRepository.java
+14 -7
View File
@@ -187,7 +187,8 @@ public abstract class DepotRepository
// key will be null if record was supplied without a primary key // key will be null if record was supplied without a primary key
return _ctx.invoke(new CachingModifier<T>(record, key, key) { return _ctx.invoke(new CachingModifier<T>(record, key, key) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
// set any auto-generated column values // set any auto-generated column values
Set<String> identityFields = Set<String> identityFields =
marsh.generateFieldValues(conn, liaison, _result, false); marsh.generateFieldValues(conn, liaison, _result, false);
@@ -241,7 +242,8 @@ public abstract class DepotRepository
builder.newQuery(update); builder.newQuery(update);
return _ctx.invoke(new CachingModifier<T>(record, key, key) { return _ctx.invoke(new CachingModifier<T>(record, key, key) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
PreparedStatement stmt = builder.prepare(conn); PreparedStatement stmt = builder.prepare(conn);
try { try {
return stmt.executeUpdate(); return stmt.executeUpdate();
@@ -282,7 +284,8 @@ public abstract class DepotRepository
builder.newQuery(update); builder.newQuery(update);
return _ctx.invoke(new CachingModifier<T>(record, key, key) { return _ctx.invoke(new CachingModifier<T>(record, key, key) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
PreparedStatement stmt = builder.prepare(conn); PreparedStatement stmt = builder.prepare(conn);
// clear out _result so that we don't rewrite this partial record to the cache // clear out _result so that we don't rewrite this partial record to the cache
_result = null; _result = null;
@@ -424,7 +427,8 @@ public abstract class DepotRepository
builder.newQuery(update); builder.newQuery(update);
return _ctx.invoke(new Modifier(invalidator) { return _ctx.invoke(new Modifier(invalidator) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
PreparedStatement stmt = builder.prepare(conn); PreparedStatement stmt = builder.prepare(conn);
try { try {
return stmt.executeUpdate(); return stmt.executeUpdate();
@@ -556,7 +560,8 @@ public abstract class DepotRepository
builder.newQuery(update); builder.newQuery(update);
return _ctx.invoke(new Modifier(invalidator) { return _ctx.invoke(new Modifier(invalidator) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
PreparedStatement stmt = builder.prepare(conn); PreparedStatement stmt = builder.prepare(conn);
try { try {
return stmt.executeUpdate(); return stmt.executeUpdate();
@@ -593,7 +598,8 @@ public abstract class DepotRepository
final boolean[] created = new boolean[1]; final boolean[] created = new boolean[1];
_ctx.invoke(new CachingModifier<T>(record, key, key) { _ctx.invoke(new CachingModifier<T>(record, key, key) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
PreparedStatement stmt = null; PreparedStatement stmt = null;
try { try {
if (_key != null) { if (_key != null) {
@@ -701,7 +707,8 @@ public abstract class DepotRepository
builder.newQuery(delete); builder.newQuery(delete);
return _ctx.invoke(new Modifier(invalidator) { return _ctx.invoke(new Modifier(invalidator) {
@Override public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException { @Override
public int invoke (Connection conn, DatabaseLiaison liaison) throws SQLException {
PreparedStatement stmt = builder.prepare(conn); PreparedStatement stmt = builder.prepare(conn);
try { try {
return stmt.executeUpdate(); return stmt.executeUpdate();