ODE-1063: Marked the column as bytea
Project: http://git-wip-us.apache.org/repos/asf/ode/repo Commit: http://git-wip-us.apache.org/repos/asf/ode/commit/42aff2dc Tree: http://git-wip-us.apache.org/repos/asf/ode/tree/42aff2dc Diff: http://git-wip-us.apache.org/repos/asf/ode/diff/42aff2dc Branch: refs/heads/ode-1.3.x Commit: 42aff2dc832f2f43f1aab22429781ae289bd1bc5 Parents: f7b4c61 Author: sathwik <[email protected]> Authored: Fri Jul 8 17:15:09 2016 +0530 Committer: sathwik <[email protected]> Committed: Fri Jul 8 17:15:09 2016 +0530 ---------------------------------------------------------------------- dao-hibernate-db/src/main/sql/simplesched-postgres.sql | 2 +- .../main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode/blob/42aff2dc/dao-hibernate-db/src/main/sql/simplesched-postgres.sql ---------------------------------------------------------------------- diff --git a/dao-hibernate-db/src/main/sql/simplesched-postgres.sql b/dao-hibernate-db/src/main/sql/simplesched-postgres.sql index abe97f9..00badc7 100644 --- a/dao-hibernate-db/src/main/sql/simplesched-postgres.sql +++ b/dao-hibernate-db/src/main/sql/simplesched-postgres.sql @@ -20,7 +20,7 @@ CREATE TABLE ode_job ( correlationKeySet varchar(255), retryCount int, inMem int, - detailsExt blob(4096), + detailsExt bytea, PRIMARY KEY(jobid)); http://git-wip-us.apache.org/repos/asf/ode/blob/42aff2dc/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java ---------------------------------------------------------------------- diff --git a/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java b/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java index c8bb2f3..94a5232 100644 --- a/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java +++ b/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java @@ -211,7 +211,7 @@ public class JdbcDelegate implements DatabaseDelegate { ps.setObject(i++, details.inMem, Types.INTEGER); if (details.detailsExt == null || details.detailsExt.size() == 0) { - ps.setObject(i++, null, Types.BLOB); + ps.setBytes(i++, null); } else { ByteArrayOutputStream bos = new ByteArrayOutputStream(); try {
