package xwfb;

import java.sql.*;


public class commentDB
{
	String DBDriver =  "oracle.jdbc.driver.OracleDriver";
	String DBUrl = "jdbc:oracle:thin:@localhost:1521:ORACLE";
	String DBUser = "jerry";
	String DBPsw = "123456";
	Connection conn = null;
	PreparedStatement stmt = null;
	ResultSet rs = null;
	
	private Connection initDB()
	{
		try
		{
			Class.forName(DBDriver);
			return DriverManager.getConnection(DBUrl,DBUser,DBPsw);
		}
		catch (Exception e)
		{
			e.printStackTrace();
			return null;
		}
	}
	
	public int addComment(commentTable ctable)
	{
		try
		{
			conn = this.initDB();
			String sql = "select MAX(id) from XWFB_COMMENT where news_id = ?";
			this.stmt = null;
			this.stmt = conn.prepareStatement(sql);
			stmt.setString(1,ctable.getNewsid());
			rs = stmt.executeQuery();
			int d = 0;
			if(rs.next())
			{
				d = rs.getInt(1) + 1;
			}
			sql = "insert into XWFB_COMMENT(id,news_id,author,comment_author,comment_content,comment_date) values(?,?,?,?,?,?)";
			this.stmt = null;
			this.stmt = conn.prepareStatement(sql);
			
			stmt.setInt(1,d);
			stmt.setString(2,ctable.getNewsid());
			stmt.setString(3,ctable.getAuthor());
			stmt.setString(4,ctable.getCommentauthor());
			stmt.setString(5,ctable.getCommentcontent());
			stmt.setString(6,ctable.getCommentdate());
			
			stmt.executeUpdate();
			return 1;
		}
		catch(Exception e)
		{
			e.printStackTrace();
			return 0;
		}
		finally
		{
			try
			{
				rs.close();
				conn.close();
				stmt.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
			}
		}
	}
	
	/*
	public int editNews(newsTable ntable)
	{
		try
		{
			conn = this.initDB();
			String sql = "update XWFB_NEWS set title=?,content =?,editor=?,editor_time=?,where id =?";
			this.stmt = null;
			this.stmt = conn.prepareStatement(sql);
			
			stmt.setString(1,ntable.getTitle());
			stmt.setString(2,ntable.getContent());
			stmt.setString(3,ntable.getEditor());
			stmt.setString(4,ntable.getEditortime());
			stmt.setString(5,ntable.getId());
			
			stmt.executeUpdate();
			
			return 1;
		}
		catch(Exception e)
		{
			e.printStackTrace();
			return 0;
		}
		finally
		{
			try
			{
				conn.close();
				stmt.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
			}
		}
	}
	*/
	public int deleteNews(String [] id, String newsid)
	{
		try
		{
			for(int i=0; i<id.length; i++)
			{
				
				String sql = "delete from XWFB_COMMENT where news_id = "+newsid+" and  news_id ="+id[i];
				this.stmt = null;
				this.stmt = conn.prepareStatement(sql);
				stmt.executeUpdate();
			}
			
			return 1;
		}
		catch(Exception e)
		{
			e.printStackTrace();
			return 0;
		}
		finally
		{
			try
			{
				conn.close();
				stmt.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
			}
		}
	}	
}