dbdatahelper.java

短信发送

/**
 * Created at Nov 30, 2008
 */
package com.jdev.app.db;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;

import com.jdev.app.db.queue.DataQueue;
import com.jdev.app.db.queue.DataQueueFactory;
import com.jdev.app.db.wrap.DataWrapFactory;
import com.jdev.util.Debug;


/**
 * <p>Title: DbDataHelper</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 1.0
 */
public class DbDataHelper {
	private final static String module = DbDataHelper.class.getName();
	private final static DataQueueFactory queueFactory = DataQueueFactory
			.getInstance();
	private final static DataWrapFactory wrapFactory = DataWrapFactory
			.getInstance();

	public int getRecordCount() {
		DataQueue queue = queueFactory.getQueue();
		return queue.getRecordCount();
	}

	public InputStream pushData(byte[] array) throws Exception {
		try {
			DataQueue queue = queueFactory.getQueue();
			byte[] content = wrapFactory.getData(array);
			InputStream bin = new ByteArrayInputStream(content);
			queue.pushData(bin);
			return bin;
		} catch (Exception e) {
			Debug.logError("pushData error:" + e, module);
			throw new Exception(e);
		}
	}

	public byte[] getData() throws Exception {
		byte[] response = null;
		try {
			DataQueue queue = queueFactory.getQueue();
			ByteArrayOutputStream bout = (ByteArrayOutputStream) queue
					.removeDataFirst();
			response = wrapFactory.getData(bout.toByteArray());
		} catch (Exception e) {
			Debug.logError("getData error:" + e, module);
			throw new Exception(e);
		}
		return response;
	}
}