audit service can't compile

Evolveum · Dec 7, 2017 · eb7fde8 · eb7fde8
1 parent f43efd9
commit eb7fde8
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/repo/repo-sql-impl/src/main/java/com/evolveum/midpoint/repo/sql/SqlAuditServiceImpl.java b/repo/repo-sql-impl/src/main/java/com/evolveum/midpoint/repo/sql/SqlAuditServiceImpl.java
@@ -46,6 +46,7 @@
 import org.hibernate.dialect.Dialect;
 import org.hibernate.dialect.pagination.LimitHandler;
 import org.hibernate.engine.spi.RowSelection;
+import org.hibernate.query.NativeQuery;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import com.evolveum.midpoint.audit.api.AuditEventRecord;
@@ -511,15 +512,15 @@ private int batchDeletionAttempt(BiFunction<Session, String, Integer> recordsSel
 			LOGGER.trace("Inserted {} audit record ids ready for deleting.", count);
 
 			// drop records from m_audit_item, m_audit_event, m_audit_delta, and others
-			session.createSQLQuery(createDeleteQuery(RAuditItem.TABLE_NAME, tempTable,
+			session.createNativeQuery(createDeleteQuery(RAuditItem.TABLE_NAME, tempTable,
 					RAuditItem.COLUMN_RECORD_ID)).executeUpdate();
-			session.createSQLQuery(createDeleteQuery(RObjectDeltaOperation.TABLE_NAME, tempTable,
+			session.createNativeQuery(createDeleteQuery(RObjectDeltaOperation.TABLE_NAME, tempTable,
 					RObjectDeltaOperation.COLUMN_RECORD_ID)).executeUpdate();
-			session.createSQLQuery(createDeleteQuery(RAuditPropertyValue.TABLE_NAME, tempTable,
+			session.createNativeQuery(createDeleteQuery(RAuditPropertyValue.TABLE_NAME, tempTable,
 					RAuditPropertyValue.COLUMN_RECORD_ID)).executeUpdate();
-			session.createSQLQuery(createDeleteQuery(RAuditReferenceValue.TABLE_NAME, tempTable,
+			session.createNativeQuery(createDeleteQuery(RAuditReferenceValue.TABLE_NAME, tempTable,
 					RAuditReferenceValue.COLUMN_RECORD_ID)).executeUpdate();
-			session.createSQLQuery(createDeleteQuery(RAuditEventRecord.TABLE_NAME, tempTable, "id"))
+			session.createNativeQuery(createDeleteQuery(RAuditEventRecord.TABLE_NAME, tempTable, "id"))
 					.executeUpdate();
 
 			// drop temporary table
@@ -529,7 +530,7 @@ private int batchDeletionAttempt(BiFunction<Session, String, Integer> recordsSel
 				sb.append(dialect.getDropTemporaryTableString());
 				sb.append(' ').append(tempTable);
 
-				session.createSQLQuery(sb.toString()).executeUpdate();
+				session.createNativeQuery(sb.toString()).executeUpdate();
 			}
 
 			session.getTransaction().commit();
@@ -573,7 +574,7 @@ private int selectRecordsByMaxAge(Session session, String tempTable, Date minVal
 
 		String queryString = "insert into " + tempTable + " " + selectString;
 		LOGGER.trace("Query string = {}", queryString);
-		SQLQuery query = session.createSQLQuery(queryString);
+		NativeQuery query = session.createNativeQuery(queryString);
 		query.setParameter(0, new Timestamp(minValue.getTime()));
 
 		return query.executeUpdate();
@@ -609,7 +610,7 @@ private int selectRecordsByNumberToKeep(Session session, String tempTable, Integ
 
 		String queryString = "insert into " + tempTable + " " + selectString;
 		LOGGER.trace("Query string = {}", queryString);
-		SQLQuery query = session.createSQLQuery(queryString);
+		NativeQuery query = session.createNativeQuery(queryString);
 		return query.executeUpdate();
 	}