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/7fce22a4 Tree: http://git-wip-us.apache.org/repos/asf/ode/tree/7fce22a4 Diff: http://git-wip-us.apache.org/repos/asf/ode/diff/7fce22a4 Branch: refs/heads/master Commit: 7fce22a49504687f692b2eae15e16d384cff533f Parents: a28cabe Author: sathwik <[email protected]> Authored: Wed Jun 28 16:20:51 2017 +0530 Committer: sathwik <[email protected]> Committed: Wed Jun 28 16:20:51 2017 +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/7fce22a4/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 b395a8c..1c36ee0 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/7fce22a4/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 b255e08..43c9658 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 @@ -215,7 +215,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 {
