fix postgresql deployment (fix #350)

src/main/java/com/commafeed/backend/DatabaseUpdater.java

@@ -13,9 +13,11 @@ import javax.sql.DataSource;
 import liquibase.Liquibase;
 import liquibase.database.Database;
 import liquibase.database.DatabaseFactory;
+import liquibase.database.core.PostgresDatabase;
 import liquibase.database.jvm.JdbcConnection;
 import liquibase.resource.ClassLoaderResourceAccessor;
 import liquibase.resource.ResourceAccessor;
+import liquibase.structure.DatabaseObject;
 
 @Stateless
 @TransactionManagement(TransactionManagementType.BEAN)
@@ -37,10 +39,21 @@ public class DatabaseUpdater {
 				DataSource dataSource = (DataSource) context
 						.lookup(datasourceName);
 				connection = dataSource.getConnection();
+				JdbcConnection jdbcConnection = new JdbcConnection(connection);
 
 				Database database = DatabaseFactory.getInstance()
 						.findCorrectDatabaseImplementation(
-								new JdbcConnection(connection));
+								jdbcConnection);
+
+				if (database instanceof PostgresDatabase) {
+					database = new PostgresDatabase() {
+						@Override
+						public String escapeObjectName(String objectName, Class<? extends DatabaseObject> objectType) {
+							return objectName;
+						}
+					};
+					database.setConnection(jdbcConnection);
+				}
 
 				Liquibase liq = new Liquibase(
 						"changelogs/db.changelog-master.xml", accessor,

src/main/java/com/commafeed/backend/dao/FeedEntryStatusDAO.java

@@ -5,6 +5,7 @@ import java.util.List;
 import java.util.Map;
 
 import javax.ejb.Stateless;
+import javax.inject.Inject;
 import javax.persistence.NoResultException;
 import javax.persistence.Query;
 import javax.persistence.Tuple;
@@ -36,6 +37,7 @@ import com.commafeed.backend.model.FeedSubscription_;
 import com.commafeed.backend.model.Feed_;
 import com.commafeed.backend.model.User;
 import com.commafeed.backend.model.UserSettings.ReadingOrder;
+import com.commafeed.backend.services.ApplicationSettingsService;
 import com.google.common.base.Function;
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Lists;
@@ -47,6 +49,9 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 	protected static Logger log = LoggerFactory
 			.getLogger(FeedEntryStatusDAO.class);
 
+	@Inject
+	ApplicationSettingsService applicationSettingsService;
+
 	@SuppressWarnings("unchecked")
 	public FeedEntryStatus findById(User user, Long id) {
 
@@ -92,7 +97,7 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 		if (CollectionUtils.isEmpty(entries)) {
 			return results;
 		}
-		
+
 		CriteriaQuery<FeedEntryStatus> query = builder.createQuery(getType());
 		Root<FeedEntryStatus> root = query.from(getType());
 
@@ -126,11 +131,11 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 
 	public List<FeedEntryStatus> findByKeywords(User user, String keywords,
 			int offset, int limit) {
-		
+
 		String joinedKeywords = StringUtils.join(
 				keywords.toLowerCase().split(" "), "%");
 		joinedKeywords = "%" + joinedKeywords + "%";
-		
+
 		CriteriaQuery<Tuple> query = builder.createTupleQuery();
 		Root<FeedEntry> root = query.from(FeedEntry.class);
 
@@ -148,7 +153,7 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 
 		predicates
 				.add(builder.equal(subJoin.get(FeedSubscription_.user), user));
-		
+
 		Predicate content = builder.like(
 				builder.lower(contentJoin.get(FeedEntryContent_.content)),
 				joinedKeywords);
@@ -522,7 +527,10 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 	}
 
 	private void setTimeout(Query query) {
-		query.setHint("javax.persistence.query.timeout", 20000);
+		int queryTimeout = applicationSettingsService.get().getQueryTimeout();
+		if (queryTimeout > 0) {
+			query.setHint("javax.persistence.query.timeout", queryTimeout);
+		}
 	}
 
 	public void markSubscriptionEntries(FeedSubscription subscription,

src/main/java/com/commafeed/backend/model/ApplicationSettings.java

@@ -33,6 +33,7 @@ public class ApplicationSettings extends AbstractModel {
 	private boolean feedbackButton = true;
 	private String logLevel = Level.INFO.toString();
 	private boolean imageProxyEnabled;
+	private int queryTimeout;
 
 	@Column(length = 255)
 	private String announcement;
@@ -182,4 +183,12 @@ public class ApplicationSettings extends AbstractModel {
 		this.imageProxyEnabled = imageProxyEnabled;
 	}
 
+	public int getQueryTimeout() {
+		return queryTimeout;
+	}
+
+	public void setQueryTimeout(int queryTimeout) {
+		this.queryTimeout = queryTimeout;
+	}
+
 }