package electric.dbs;

import java.sql.*;

import javax.servlet.http.*;

import electric.*;

import java.text.SimpleDateFormat;

import electric.electricUtils.*;

public class Dbnews{

private static final String LOAD_NEWS_BY_ID =

"SELECT * FROM [NEWS] WHERE [ID]=?";

private static final String INSERT_NEWS =

"INSERT INTO [NEWS] ([Id],[Motif],[Kithepeople],[Content],[Createdate],[Createpeople],[Status]) VALUES " +

"(?,?,?,?,?,?,?)";

private static final String UPDATE_NEWS =

"UPDATE [NEWS] SET [Motif]=?,[Kithepeople]=?,[Content]=?,[Createdate]=?," +

"[Createpeople]=?,[Status]=?" +

" WHERE [Id]=?";

private static final String DEL_NEWS =

"UPDATE [NEWS] SET [Status]=? WHERE [Id]=?";

private static final String CLEAR_NEWS = "DELETE FROM [NEWS] WHERE STATUS=" +

FinalConstants.STATUS_DELETE;

private int Id;

private String Motif;

private String Kithepeople;

private String Content;

private String CreateDate;

private int Createpeople;

private int Status;

public Dbnews()

{}

public Dbnews(HttpServletRequest request) {

this.Id = DbSequenceManager.nextID(FinalConstants.T_NEWS);

this.Motif = ParamUtils.getEscapeHTMLParameter(request, "motif");

this.Kithepeople = ParamUtils.getEscapeHTMLParameter(request, "kithepeople");

this.Content = ParamUtils.getEscapeHTMLParameter(request, "content");

SimpleDateFormat simpleDate = new SimpleDateFormat("yyyyMMdd");

String shiftDateToDate = simpleDate.format(new java.util.Date());

this.CreateDate = shiftDateToDate;

this.Createpeople = this.Id;

this.Status = FinalConstants.STATUS_NORMAL;

insertIntoDb();

}

public Dbnews(int Id) throws NewsNotFoundException {

this.Id = Id;

if (Id <= 0) {

return;

}

loadFromDb();

}

protected static Dbnews getInstance(int Id) throws

NewsNotFoundException {

return new Dbnews(Id);

}

protected void delete() {

setStatus(FinalConstants.STATUS_DELETE);

}

protected static void clear() {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = DbConnectionManager.getConnection();

pstmt = con.prepareStatement(CLEAR_NEWS);

pstmt.executeUpdate();

}

catch (SQLException sqle) {

System.err.println(

"SQLException in DbTChatRooms.java:clearTChatRooms(): " + sqle);

sqle.printStackTrace();

}

finally {

try {

pstmt.close();

}

catch (Exception e) {

e.printStackTrace();

}

try {

con.close();

}

catch (Exception e) {

e.printStackTrace();

}

}

}

/////////////////////////////////////////////////////////////////

public int getId() {

return this.Id;

}

public String getMotif()

{

return this.Motif;

}

public String getKithepeople()

{

return this.Kithepeople;

}

public String getContent()

{

return this.Content;

}

public String getCreateDate()

{

return this.CreateDate;

}

public int getCreatepeople()

{

return this.Createpeople;

}

public int getStatus()

{

return this.Status;

}

//////////////////////WRITE METHODS/////////////////////////////

/////////////////////////////////////////////////////////////////

public void setId(int Id) {

this.Id=Id;

saveToDb();

}

public void setMotif(String Motif)

{

this.Motif=Motif;

saveToDb();

}

public void setKithepeople(String Kithepeople)

{

this.Kithepeople=Kithepeople;

saveToDb();

}

public void setContent(String Content)

{

this.Content=Content;

saveToDb();

}

public void setCreateDate(String CreateDate)

{

this.CreateDate=CreateDate;

saveToDb();

}

public void setCreatepeople(int Createpeople)

{

this.Createpeople=Createpeople;

saveToDb();

}

public void setStatus(int Status)

{

this.Status=Status;

DELToDb();

}

////////////////////////////////////////////////////////////////////////////////

public void modify(HttpServletRequest request) {

this.Id = ParamUtils.getIntParameter(request, "Id");

this.Motif = ParamUtils.getEscapeHTMLParameter(request, "Motif");

this.Kithepeople = ParamUtils.getEscapeHTMLParameter(request, "Kithepeople");

this.Content = ParamUtils.getEscapeHTMLParameter(request, "Content");

this.Createpeople =this.Id;

this.Status = FinalConstants.STATUS_NORMAL;

saveToDb();

}

private void loadFromDb() throws NewsNotFoundException {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = DbConnectionManager.getConnection();

pstmt = con.prepareStatement(LOAD_NEWS_BY_ID);

pstmt.setInt(1,Id);

ResultSet rs = pstmt.executeQuery();

if (!rs.next()) {

throw new NewsNotFoundException("从数据表[NEWS]中读取用户数据失败,欲读取的用户ID:[ " +

Id + "]!");

}

this.Id = rs.getInt("ID");

this.Motif = rs.getString("Motif");

this.Kithepeople = rs.getString("Kithepeople");

this.Content=rs.getString("Content");

this.CreateDate = rs.getString("CREATEDATE");

this.Createpeople = rs.getInt("CREATEPEOPLE");

this.Status = rs.getInt("STATUS");

}

catch (SQLException sqle) {

throw new NewsNotFoundException("从数据表[NEWS]中读取用户数据失败,欲读取的用户ID:[ " +

Id + "]!");

}

finally {

try {

pstmt.close();

}

catch (Exception e) {

e.printStackTrace();

}

try {

con.close();

}

catch (Exception e) {

e.printStackTrace();

}

}

}

private void insertIntoDb() {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = DbConnectionManager.getConnection();

pstmt = con.prepareStatement(INSERT_NEWS);

pstmt.setInt(1, this.Id);

pstmt.setString(2,StringUtils.toChinese(this.Motif));

pstmt.setString(3, StringUtils.toChinese(this.Kithepeople));

pstmt.setString(4, StringUtils.toChinese(this.Content));

pstmt.setString(5, StringUtils.toChinese(this.CreateDate));

pstmt.setInt(6, this.Createpeople);

pstmt.setInt(7, this.Status);

pstmt.executeUpdate();

}

catch (SQLException sqle) {

System.err.println("错误位置: DbNews:insertIntoDb()-" + sqle);

sqle.printStackTrace();

}

finally {

try {

pstmt.close();

}

catch (Exception e) {

e.printStackTrace();

}

try {

con.close();

}

catch (Exception e) {

e.printStackTrace();

}

}

}

private void saveToDb() {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = DbConnectionManager.getConnection();

pstmt = con.prepareStatement(UPDATE_NEWS);

pstmt.setString(1, StringUtils.toChinese(this.Motif));

pstmt.setString(2, StringUtils.toChinese(this.Kithepeople));

pstmt.setString(3, StringUtils.toChinese(this.Content));

pstmt.setString(4, StringUtils.toChinese(this.CreateDate));

pstmt.setInt(5, this.Createpeople);

pstmt.setInt(6, this.Status);

pstmt.setInt(7, this.Id);

pstmt.executeUpdate();

}

catch (SQLException sqle) {

System.err.println("错误位置: DbNews.java:saveToDb(): " + sqle);

sqle.printStackTrace();

}

finally {

try {

pstmt.close();

}

catch (Exception e) {

e.printStackTrace();

}

try {

con.close();

}

catch (Exception e) {

e.printStackTrace();

}

}

}

private void DELToDb() {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = DbConnectionManager.getConnection();

pstmt = con.prepareStatement(DEL_NEWS);

System.out.println(DEL_NEWS);

pstmt.setInt(1, this.Status);

pstmt.setInt(2, this.Id);

pstmt.executeUpdate();

}

catch (SQLException sqle) {

System.err.println("错误位置: DbShop.java:DELToDb(): " + sqle);

sqle.printStackTrace();

}

finally {

try {

pstmt.close();

}

catch (Exception e) {

e.printStackTrace();

}

try {

con.close();

}

catch (Exception e) {

e.printStackTrace();

}

}

}

}