franta-hg@63: /*
franta-hg@63:  *   SONEWS News Server
franta-hg@63:  *   see AUTHORS for the list of contributors
franta-hg@63:  *
franta-hg@63:  *   This program is free software: you can redistribute it and/or modify
franta-hg@63:  *   it under the terms of the GNU General Public License as published by
franta-hg@63:  *   the Free Software Foundation, either version 3 of the License, or
franta-hg@63:  *   (at your option) any later version.
franta-hg@63:  *
franta-hg@63:  *   This program is distributed in the hope that it will be useful,
franta-hg@63:  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
franta-hg@63:  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
franta-hg@63:  *   GNU General Public License for more details.
franta-hg@63:  *
franta-hg@63:  *   You should have received a copy of the GNU General Public License
franta-hg@63:  *   along with this program.  If not, see <http://www.gnu.org/licenses/>.
franta-hg@63:  */
franta-hg@63: package org.sonews.storage.impl;
franta-hg@63: 
franta-hg@68: import java.io.UnsupportedEncodingException;
franta-hg@68: import java.sql.Connection;
franta-hg@68: import java.sql.DriverManager;
franta-hg@68: import java.sql.PreparedStatement;
franta-hg@68: import java.sql.ResultSet;
franta-hg@64: import java.sql.SQLException;
franta-hg@68: import java.sql.Statement;
franta-hg@71: import java.text.SimpleDateFormat;
franta-hg@68: import java.util.ArrayList;
franta-hg@65: import java.util.Collections;
franta-hg@70: import java.util.Date;
franta-hg@64: import java.util.List;
franta-hg@71: import java.util.Locale;
franta-hg@65: import java.util.logging.Level;
franta-hg@66: import java.util.logging.Logger;
franta-hg@70: import javax.mail.internet.MailDateFormat;
franta-hg@68: import javax.mail.internet.MimeUtility;
franta-hg@70: import org.apache.commons.codec.net.BCodec;
franta-hg@69: import org.apache.commons.codec.net.QuotedPrintableCodec;
franta-hg@68: import org.sonews.config.Config;
franta-hg@64: import org.sonews.feed.Subscription;
franta-hg@64: import org.sonews.storage.Article;
franta-hg@64: import org.sonews.storage.ArticleHead;
franta-hg@64: import org.sonews.storage.Group;
franta-hg@64: import org.sonews.storage.Storage;
franta-hg@64: import org.sonews.storage.StorageBackendException;
franta-hg@64: import org.sonews.util.Pair;
franta-hg@64: 
franta-hg@63: /**
franta-hg@63:  *
franta-hg@63:  * @author František Kučera (frantovo.cz)
franta-hg@63:  */
franta-hg@64: public class DrupalDatabase implements Storage {
franta-hg@67: 
franta-hg@66: 	private static final Logger log = Logger.getLogger(DrupalDatabase.class.getName());
franta-hg@70: 	public static final String CHARSET = "UTF-8";
franta-hg@68: 	public static final String CRLF = "\r\n";
franta-hg@68: 	public static final int MAX_RESTARTS = 2;
franta-hg@68: 	/** How many times the database connection was reinitialized */
franta-hg@68: 	protected int restarts = 0;
franta-hg@68: 	protected Connection conn = null;
franta-hg@70: 	private QuotedPrintableCodec qpc = new QuotedPrintableCodec(CHARSET);
franta-hg@71: 	private SimpleDateFormat RFC822_DATE = new SimpleDateFormat("EEE', 'dd' 'MMM' 'yyyy' 'HH:mm:ss' 'Z", Locale.US);
franta-hg@70: 	// TODO: správná doména
franta-hg@70: 	private String myDomain = "kinderporno.cz";
franta-hg@68: 
franta-hg@68: 	public DrupalDatabase() throws StorageBackendException {
franta-hg@68: 		connectDatabase();
franta-hg@68: 	}
franta-hg@68: 
franta-hg@68: 	private void connectDatabase() throws StorageBackendException {
franta-hg@68: 		try {
franta-hg@68: 			// Load database driver
franta-hg@68: 			String driverClass = Config.inst().get(Config.LEVEL_FILE, Config.STORAGE_DBMSDRIVER, "java.lang.Object");
franta-hg@68: 			Class.forName(driverClass);
franta-hg@68: 
franta-hg@68: 			// Establish database connection
franta-hg@68: 			String url = Config.inst().get(Config.LEVEL_FILE, Config.STORAGE_DATABASE, "<not specified>");
franta-hg@68: 			String username = Config.inst().get(Config.LEVEL_FILE, Config.STORAGE_USER, "root");
franta-hg@68: 			String password = Config.inst().get(Config.LEVEL_FILE, Config.STORAGE_PASSWORD, "");
franta-hg@68: 			conn = DriverManager.getConnection(url, username, password);
franta-hg@68: 
franta-hg@68: 			conn.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
franta-hg@68: 			if (conn.getTransactionIsolation() != Connection.TRANSACTION_SERIALIZABLE) {
franta-hg@68: 				log.warning("Database is NOT fully serializable!");
franta-hg@68: 			}
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		}
franta-hg@68: 	}
franta-hg@68: 
franta-hg@68: 	protected static void close(Connection connection, Statement statement, ResultSet resultSet) {
franta-hg@68: 		if (resultSet != null) {
franta-hg@68: 			try {
franta-hg@68: 				resultSet.close();
franta-hg@68: 			} catch (Exception e) {
franta-hg@68: 			}
franta-hg@68: 		}
franta-hg@68: 		if (statement != null) {
franta-hg@68: 			try {
franta-hg@68: 				statement.close();
franta-hg@68: 			} catch (Exception e) {
franta-hg@68: 			}
franta-hg@68: 		}
franta-hg@68: 		if (connection != null) {
franta-hg@68: 			try {
franta-hg@68: 				connection.close();
franta-hg@68: 			} catch (Exception e) {
franta-hg@68: 			}
franta-hg@68: 		}
franta-hg@68: 	}
franta-hg@64: 
franta-hg@64: 	/**
franta-hg@68: 	 * 
franta-hg@70: 	 * @param messageID &lt;{0}-{1}-{2}@domain.tld&gt; where {0} is nntp_id and {1} is group_id and {2} is group_name
franta-hg@68: 	 * @return array where [0] = nntp_id and [1] = group_id and [2] = group_name or returns null if messageID is invalid
franta-hg@64: 	 */
franta-hg@68: 	private static String[] parseMessageID(String messageID) {
franta-hg@70: 		if (messageID.matches("<[0-9]+\\-[0-9]+\\-[a-z0-9\\.]+@.+>")) {
franta-hg@70: 			return messageID.substring(1).split("@")[0].split("\\-");
franta-hg@68: 		} else {
franta-hg@68: 			return null;
franta-hg@68: 		}
franta-hg@68: 	}
franta-hg@68: 
franta-hg@68: 	private static Long parseArticleID(String messageID) {
franta-hg@68: 		String[] localPart = parseMessageID(messageID);
franta-hg@68: 		if (localPart == null) {
franta-hg@68: 			return null;
franta-hg@68: 		} else {
franta-hg@68: 			return Long.parseLong(localPart[0]);
franta-hg@68: 		}
franta-hg@68: 	}
franta-hg@68: 
franta-hg@68: 	private static Long parseGroupID(String messageID) {
franta-hg@68: 		String[] localPart = parseMessageID(messageID);
franta-hg@68: 		if (localPart == null) {
franta-hg@68: 			return null;
franta-hg@68: 		} else {
franta-hg@68: 			return Long.parseLong(localPart[1]);
franta-hg@68: 		}
franta-hg@68: 	}
franta-hg@68: 
franta-hg@68: 	private static String parseGroupName(String messageID) {
franta-hg@68: 		String[] localPart = parseMessageID(messageID);
franta-hg@68: 		if (localPart == null) {
franta-hg@68: 			return null;
franta-hg@68: 		} else {
franta-hg@68: 			return localPart[2];
franta-hg@68: 		}
franta-hg@68: 	}
franta-hg@68: 
franta-hg@70: 	private static String constructMessageId(int articleID, int groupID, String groupName, String domainName) {
franta-hg@70: 		StringBuilder sb = new StringBuilder();
franta-hg@70: 		sb.append("<");
franta-hg@70: 		sb.append(articleID);
franta-hg@70: 		sb.append("-");
franta-hg@70: 		sb.append(groupID);
franta-hg@70: 		sb.append("-");
franta-hg@70: 		sb.append(groupName);
franta-hg@70: 		sb.append("@");
franta-hg@70: 		sb.append(domainName);
franta-hg@70: 		sb.append(">");
franta-hg@70: 		return sb.toString();
franta-hg@70: 	}
franta-hg@70: 
franta-hg@70: 	/**
franta-hg@70: 	 * 
franta-hg@70: 	 * @param sb header list to be appended with new header. List must be terminated by line end.
franta-hg@70: 	 * @param key header name (without : and space)
franta-hg@70: 	 * @param value header value
franta-hg@70: 	 * @param encode true if value should be encoded/escaped before appending
franta-hg@70: 	 * @throws UnsupportedEncodingException 
franta-hg@70: 	 */
franta-hg@70: 	private static void addHeader(StringBuilder sb, String key, String value, boolean encode) throws UnsupportedEncodingException {
franta-hg@70: 		sb.append(key);
franta-hg@70: 		sb.append(": ");
franta-hg@70: 		if (encode) {
franta-hg@70: 			sb.append(MimeUtility.encodeWord(value));
franta-hg@70: 		} else {
franta-hg@70: 			sb.append(value);
franta-hg@70: 		}
franta-hg@70: 		sb.append(CRLF);
franta-hg@70: 	}
franta-hg@70: 
franta-hg@70: 	private String constructHeaders(ResultSet rs) throws SQLException, UnsupportedEncodingException {
franta-hg@68: 		StringBuilder sb = new StringBuilder();
franta-hg@69: 
franta-hg@70: 		addHeader(sb, "Message-id", constructMessageId(rs.getInt("id"), rs.getInt("group_id"), rs.getString("group_name"), myDomain), false);
franta-hg@70: 		addHeader(sb, "From", MimeUtility.encodeWord(rs.getString("sender_name")) + " <>", false);
franta-hg@70: 		addHeader(sb, "Subject", rs.getString("subject"), true);
franta-hg@70: 		/** TODO: správný formát data: */
franta-hg@71: 		addHeader(sb, "Date", RFC822_DATE.format(new Date(rs.getLong("created"))), false);
franta-hg@70: 		addHeader(sb, "Content-Type", "text/html; charset=" + CHARSET, false);
franta-hg@70: 		addHeader(sb, "Content-Transfer-Encoding", "quoted-printable", false);
franta-hg@70: 		//addHeader(sb, "Content-Transfer-Encoding", "base64", false);
franta-hg@69: 
franta-hg@70: 		Integer parentID = rs.getInt("parent_id");
franta-hg@70: 		if (parentID != null && parentID > 0) {
franta-hg@70: 			String parentMessageID = constructMessageId(parentID, rs.getInt("group_id"), rs.getString("group_name"), myDomain);
franta-hg@70: 			addHeader(sb, "In-Reply-To", parentMessageID, false);
franta-hg@70: 			addHeader(sb, "References", parentMessageID, false);
franta-hg@70: 		}
franta-hg@68: 
franta-hg@68: 		return sb.toString();
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@67: 	public List<Group> getGroups() throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@68: 			ps = conn.prepareStatement("SELECT * FROM nntp_group");
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 			List<Group> skupiny = new ArrayList<Group>();
franta-hg@68: 
franta-hg@68: 			while (rs.next()) {
franta-hg@68: 				skupiny.add(new Group(rs.getString("name"), rs.getInt("id"), Group.READONLY));
franta-hg@68: 			}
franta-hg@68: 
franta-hg@68: 			return skupiny;
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@67: 	public Group getGroup(String name) throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@68: 			ps = conn.prepareStatement("SELECT * FROM nntp_group WHERE name = ?");
franta-hg@68: 			ps.setString(1, name);
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 
franta-hg@68: 			while (rs.next()) {
franta-hg@68: 				return new Group(rs.getString("name"), rs.getInt("id"), Group.READONLY);
franta-hg@68: 			}
franta-hg@68: 
franta-hg@68: 			return null;
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@67: 	public boolean isGroupExisting(String groupname) throws StorageBackendException {
franta-hg@68: 		return getGroup(groupname) != null;
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public Article getArticle(String messageID) throws StorageBackendException {
franta-hg@68: 		Long articleID = parseArticleID(messageID);
franta-hg@68: 		Long groupID = parseGroupID(messageID);
franta-hg@68: 
franta-hg@68: 		if (articleID == null || groupID == null) {
franta-hg@68: 			log.log(Level.SEVERE, "Invalid messageID: {0}", new Object[]{messageID});
franta-hg@68: 			return null;
franta-hg@68: 		} else {
franta-hg@68: 			return getArticle(articleID, groupID);
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@68: 	public Article getArticle(long articleID, long groupID) throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@68: 			ps = conn.prepareStatement("SELECT * FROM nntp_article WHERE id = ? AND group_id = ?");
franta-hg@68: 			ps.setLong(1, articleID);
franta-hg@68: 			ps.setLong(2, groupID);
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 
franta-hg@68: 			if (rs.next()) {
franta-hg@68: 				String headers = constructHeaders(rs);
franta-hg@70: 				// TODO: fold?
franta-hg@70: 				BCodec bc = new BCodec(CHARSET);
franta-hg@69: 				byte[] body = qpc.encode(rs.getString("text")).getBytes();
franta-hg@70: 				//byte[] body = bc.encode(rs.getString("text")).getBytes();
franta-hg@69: 
franta-hg@68: 				return new Article(headers, body);
franta-hg@68: 			} else {
franta-hg@68: 				return null;
franta-hg@68: 			}
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public List<Pair<Long, ArticleHead>> getArticleHeads(Group group, long first, long last) throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@70: 			// TODO: je nutné řazení?
franta-hg@70: 			ps = conn.prepareStatement("SELECT * FROM nntp_article WHERE group_id = ? AND id >= ? AND id <= ? ORDER BY id");
franta-hg@68: 			ps.setLong(1, group.getInternalID());
franta-hg@68: 			ps.setLong(2, first);
franta-hg@68: 			ps.setLong(3, last);
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 
franta-hg@68: 			List<Pair<Long, ArticleHead>> heads = new ArrayList<Pair<Long, ArticleHead>>();
franta-hg@68: 
franta-hg@68: 			while (rs.next()) {
franta-hg@68: 				String headers = constructHeaders(rs);
franta-hg@68: 				heads.add(new Pair<Long, ArticleHead>(rs.getLong("id"), new ArticleHead(headers)));
franta-hg@68: 			}
franta-hg@68: 
franta-hg@68: 			return heads;
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public List<Pair<Long, String>> getArticleHeaders(Group group, long start, long end, String header, String pattern) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getArticleHeaders {0} / {1} / {2} / {3} / {4}", new Object[]{group, start, end, header, pattern});
franta-hg@65: 		/** TODO: */
franta-hg@65: 		return Collections.emptyList();
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@68: 	public long getArticleIndex(Article article, Group group) throws StorageBackendException {
franta-hg@68: 		Long id = parseArticleID(article.getMessageID());
franta-hg@68: 		if (id == null) {
franta-hg@68: 			throw new StorageBackendException("Invalid messageID: " + article.getMessageID());
franta-hg@68: 		} else {
franta-hg@68: 			return id;
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public List<Long> getArticleNumbers(long groupID) throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@68: 			ps = conn.prepareStatement("SELECT id FROM nntp_article WHERE group_id = ?");
franta-hg@68: 			ps.setLong(1, groupID);
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 			List<Long> articleNumbers = new ArrayList<Long>();
franta-hg@68: 			while (rs.next()) {
franta-hg@68: 				articleNumbers.add(rs.getLong(1));
franta-hg@68: 			}
franta-hg@68: 			return articleNumbers;
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@67: 	public int getFirstArticleNumber(Group group) throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@68: 			ps = conn.prepareStatement("SELECT min(id) FROM nntp_article WHERE group_id = ?");
franta-hg@68: 			ps.setLong(1, group.getInternalID());
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 			rs.next();
franta-hg@68: 			return rs.getInt(1);
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public int getLastArticleNumber(Group group) throws StorageBackendException {
franta-hg@68: 		PreparedStatement ps = null;
franta-hg@68: 		ResultSet rs = null;
franta-hg@68: 		try {
franta-hg@68: 			ps = conn.prepareStatement("SELECT max(id) FROM nntp_article WHERE group_id = ?");
franta-hg@68: 			ps.setLong(1, group.getInternalID());
franta-hg@68: 			rs = ps.executeQuery();
franta-hg@68: 			rs.next();
franta-hg@68: 			return rs.getInt(1);
franta-hg@68: 		} catch (Exception e) {
franta-hg@68: 			throw new StorageBackendException(e);
franta-hg@68: 		} finally {
franta-hg@68: 			close(null, ps, rs);
franta-hg@68: 		}
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public boolean isArticleExisting(String messageID) throws StorageBackendException {
franta-hg@68: 		Long articleID = parseArticleID(messageID);
franta-hg@68: 		Long groupID = parseGroupID(messageID);
franta-hg@68: 
franta-hg@68: 		if (articleID == null || groupID == null) {
franta-hg@68: 			return false;
franta-hg@68: 		} else {
franta-hg@68: 			PreparedStatement ps = null;
franta-hg@68: 			ResultSet rs = null;
franta-hg@68: 			try {
franta-hg@68: 				ps = conn.prepareStatement("SELECT count(*) FROM nntp_article WHERE id = ? AND group_id = ?");
franta-hg@68: 				ps.setLong(1, articleID);
franta-hg@68: 				ps.setLong(2, groupID);
franta-hg@68: 				rs = ps.executeQuery();
franta-hg@68: 
franta-hg@68: 				rs.next();
franta-hg@68: 				return rs.getInt(1) == 1;
franta-hg@68: 			} catch (Exception e) {
franta-hg@68: 				throw new StorageBackendException(e);
franta-hg@68: 			} finally {
franta-hg@68: 				close(null, ps, rs);
franta-hg@68: 			}
franta-hg@68: 		}
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	//
franta-hg@67: 	// --- zatím neimplementovat ---
franta-hg@67: 	//
franta-hg@67: 	@Override
franta-hg@67: 	public void addArticle(Article art) throws StorageBackendException {
franta-hg@67: 		log.log(Level.SEVERE, "TODO: addArticle {0}", new Object[]{art});
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public void addEvent(long timestamp, int type, long groupID) throws StorageBackendException {
franta-hg@67: 		log.log(Level.SEVERE, "TODO: addEvent {0} / {1} / {2}", new Object[]{timestamp, type, groupID});
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public void addGroup(String groupname, int flags) throws StorageBackendException {
franta-hg@67: 		log.log(Level.SEVERE, "TODO: addGroup {0} / {1}", new Object[]{groupname, flags});
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public int countArticles() throws StorageBackendException {
franta-hg@69: 		PreparedStatement ps = null;
franta-hg@69: 		ResultSet rs = null;
franta-hg@69: 		try {
franta-hg@69: 			ps = conn.prepareStatement("SELECT count(*) FROM nntp_article");
franta-hg@69: 			rs = ps.executeQuery();
franta-hg@69: 			rs.next();
franta-hg@69: 			return rs.getInt(1);
franta-hg@69: 		} catch (Exception e) {
franta-hg@69: 			throw new StorageBackendException(e);
franta-hg@69: 		} finally {
franta-hg@69: 			close(null, ps, rs);
franta-hg@69: 		}
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public int countGroups() throws StorageBackendException {
franta-hg@69: 		PreparedStatement ps = null;
franta-hg@69: 		ResultSet rs = null;
franta-hg@69: 		try {
franta-hg@69: 			ps = conn.prepareStatement("SELECT count(*) FROM nntp_group");
franta-hg@69: 			rs = ps.executeQuery();
franta-hg@69: 			rs.next();
franta-hg@69: 			return rs.getInt(1);
franta-hg@69: 		} catch (Exception e) {
franta-hg@69: 			throw new StorageBackendException(e);
franta-hg@69: 		} finally {
franta-hg@69: 			close(null, ps, rs);
franta-hg@69: 		}
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@67: 	public void delete(String messageID) throws StorageBackendException {
franta-hg@67: 		log.log(Level.SEVERE, "TODO: delete {0}", new Object[]{messageID});
franta-hg@67: 	}
franta-hg@67: 
franta-hg@67: 	@Override
franta-hg@64: 	public String getConfigValue(String key) throws StorageBackendException {
franta-hg@69: 		//log.log(Level.SEVERE, "TODO: getConfigValue {0}", new Object[]{key});
franta-hg@65: 		return null;
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public int getEventsCount(int eventType, long startTimestamp, long endTimestamp, Group group) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getEventsCount {0} / {1} / {2} / {3}", new Object[]{eventType, startTimestamp, endTimestamp, group});
franta-hg@65: 		return 0;
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public double getEventsPerHour(int key, long gid) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getEventsPerHour {0} / {1}", new Object[]{key, gid});
franta-hg@65: 		return 0;
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public List<String> getGroupsForList(String listAddress) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getGroupsForList {0}", new Object[]{listAddress});
franta-hg@65: 		return Collections.emptyList();
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public List<String> getListsForGroup(String groupname) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getListsForGroup {0}", new Object[]{groupname});
franta-hg@65: 		return Collections.emptyList();
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public String getOldestArticle() throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getOldestArticle");
franta-hg@65: 		return null;
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public int getPostingsCount(String groupname) throws StorageBackendException {
franta-hg@69: 		PreparedStatement ps = null;
franta-hg@69: 		ResultSet rs = null;
franta-hg@69: 		try {
franta-hg@69: 			ps = conn.prepareStatement("SELECT count(*) FROM nntp_article WHERE group_name = ?");
franta-hg@69: 			ps.setString(1, groupname);
franta-hg@69: 			rs = ps.executeQuery();
franta-hg@69: 			rs.next();
franta-hg@69: 			return rs.getInt(1);
franta-hg@69: 		} catch (Exception e) {
franta-hg@69: 			throw new StorageBackendException(e);
franta-hg@69: 		} finally {
franta-hg@69: 			close(null, ps, rs);
franta-hg@69: 		}
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public List<Subscription> getSubscriptions(int type) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: getSubscriptions {0}", new Object[]{type});
franta-hg@65: 		return Collections.emptyList();
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public void purgeGroup(Group group) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: purgeGroup {0}", new Object[]{group});
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public void setConfigValue(String key, String value) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: setConfigValue {0} = {1}", new Object[]{key, value});
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public boolean update(Article article) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: update {0}", new Object[]{article});
franta-hg@65: 		throw new StorageBackendException("Not implemented yet.");
franta-hg@64: 	}
franta-hg@64: 
franta-hg@64: 	@Override
franta-hg@64: 	public boolean update(Group group) throws StorageBackendException {
franta-hg@66: 		log.log(Level.SEVERE, "TODO: update {0}", new Object[]{group});
franta-hg@65: 		throw new StorageBackendException("Not implemented yet.");
franta-hg@64: 	}
franta-hg@63: }