Queries.java

package net.metanotion.emailqueue;

/** <i>This is a SQL query class generated by the SQLC compiler.</i> */
@javax.annotation.Generated("net.metanotion.sqlc.SQLC")  final class Queries {
	private final net.metanotion.util.Dictionary<Class,net.metanotion.util.types.Parser> types;
	public Queries() { this.types = new net.metanotion.util.types.TypeDictionary(); }
	public Queries(net.metanotion.util.Dictionary<Class,net.metanotion.util.types.Parser> types) { this.types = types; }
	public int deleteMessage(final java.sql.Connection _0, final @javax.inject.Named("mid") long _1) throws Exception {
			try (final java.sql.PreparedStatement _2 = _0.prepareStatement("DELETE FROM MailQueue WHERE MailID = ?")) {
			_2.setLong(1, _1);
			final int _3 = _2.executeUpdate();
			return _3;
}
	}
	public int incrementRetryCounter(final java.sql.Connection _0, final @javax.inject.Named("mid") long _1) throws Exception {
			try (final java.sql.PreparedStatement _2 = _0.prepareStatement("UPDATE MailQueue SET RetryCount = RetryCount + 1 WHERE MailID = ?")) {
			_2.setLong(1, _1);
			final int _3 = _2.executeUpdate();
			return _3;
}
	}
	public int queueMessage(final java.sql.Connection _0, final @javax.inject.Named("sender") String _1, final @javax.inject.Named("address") String _2, final @javax.inject.Named("subject") String _3, final @javax.inject.Named("msgBody") String _4) throws Exception {
			try (final java.sql.PreparedStatement _5 = _0.prepareStatement("INSERT INTO MailQueue(Sender, EmailAddress, Subject, MessageBody) VALUES (?, ?, ?, ?)")) {
			_5.setString(1, _1);
			_5.setString(2, _2);
			_5.setString(3, _3);
			_5.setString(4, _4);
			final int _6 = _5.executeUpdate();
			return _6;
}
	}
	public java.util.List<net.metanotion.emailqueue.MessageStruct> getMessages(final java.sql.Connection _0, final @javax.inject.Named("lim") int _1, final @javax.inject.Named("maxRetries") int _2) throws Exception {
			try (final java.sql.PreparedStatement _3 = _0.prepareStatement("SELECT\tSender,\r\n\t\t\t\t\tEmailAddress AS Recipient,\r\n\t\t\t\t\tSubject,\r\n\t\t\t\t\tMessageBody AS Message,\r\n\t\t\t\t\tRetryCount,\r\n\t\t\t\t\tMailId\r\n\t\t\tFROM MailQueue\r\n\t\t\tWHERE RetryCount < ?\r\n\t\t\tORDER BY MailID ASC\r\n\t\t\tLIMIT ?")) {
			_3.setInt(1, _2);
			_3.setInt(2, _1);
			try (final java.sql.ResultSet _4 = _3.executeQuery()) {
			final java.util.List<net.metanotion.emailqueue.MessageStruct> _5 = new java.util.ArrayList<net.metanotion.emailqueue.MessageStruct>();
		final net.metanotion.util.reflect.GetInitializer<net.metanotion.emailqueue.MessageStruct> _6 = net.metanotion.util.reflect.ReflectiveFieldInitializer.getInitializer(net.metanotion.emailqueue.MessageStruct.class, this.types);
		while(_4.next()) {
					final net.metanotion.util.reflect.Initializer<net.metanotion.emailqueue.MessageStruct> _7 = _6.initializer();
					_7.put("Sender", _4.getString("Sender"));
					_7.put("Recipient", _4.getString("Recipient"));
					_7.put("Subject", _4.getString("Subject"));
					_7.put("Message", _4.getString("Message"));
					_7.put("RetryCount", _4.getInt("RetryCount"));
					_7.put("MailId", _4.getLong("MailId"));
					_5.add(_7.instance());
		}
			return _5;
}
}
	}
}