package com.j2ee.implement;

import java.sql.*;
import javax.sql.*;
import com.j2ee.logs.Logs;
import com.j2ee.db.DbConnection;

/**
* 在一個線程中執行任務
*/
public class ScheduleThread extends Thread
{
	private Logs server=null;
	private Logs task=null;

	public ScheduleThread()
	{
		server=new Logs("server");
		task=new Logs("task");
	}

	public void run()
	{
		Connection conn=null;
		DbConnection db=null;
		try
		{
			db=new DbConnection();
			conn=db.connectByJdbc();
			server.print("成功獲得數據庫連接");//server.log
			//
			Mails mails=new Mails();
			mails.sendMail(conn);
			//
			server.print("成功關閉數據庫連接");//server.log
			//
			server.print("※※ 本次計劃預定的任務執行完畢 ※※");
		}
		catch (Exception e)
		{
			server.print("ScheduleThread.run error:"+e.getMessage());
		}
		finally
		{
			try
			{
				if (conn!=null)
				{
					conn.close();
					server.print("成功關閉數據庫連接");//server.log
				}
			}
			catch(Exception ee)
			{}
		}
	}
};