public abstract class AbstractBusinessObject implements IBusinessObject {

    private int objectState;
    protected Object boID = null;

    public AbstractBusinessObject() {
        objectState = BOStates.Empty;
    }

    public AbstractBusinessObject(Object anID) {
        objectState = BOStates.Empty;
        this.boID = anID;
    }

    @Override
    public int getObjectState() {
        return objectState;
    }

    @Override
    public void setObjectState(int objectState) {
        if (this.objectState == BOStates.Created) {
            return;
        }
        this.objectState = objectState;
    }

    @Override
    public Object getID() {
        return boID;
    }

    @Override
    public void setID(Object anID) {
        boID = anID;
    }
}

public class News extends AbstractBusinessObject {

    private Timestamp newsdt = null;
    private String title = null;
    private String body = null;
    
    public News(){
	newsdt = new Timestamp(System.currentTimeMillis());
    }
    
    public Timestamp getNewsdt() {
	return newsdt;
    }

    public void setNewsdt(Timestamp newsdt) {
	this.newsdt = newsdt;
    }

    public String getTitle() {
	return title;
    }

    public void setTitle(String title) {
	this.title = title;
    }

    public String getBody() {
	return body;
    }

    public void setBody(String body) {
	this.body = body;
    }

    @Override
    public List<Object> getCreateParameters() {
	ArrayList<Object> params = new ArrayList<>();
	params.add(this.getNewsdt());
	params.add(this.getTitle());
	params.add(this.getBody());
	return params;
    }

    @Override
    public List<Object> getUpdateParameters() {
	ArrayList<Object> params = new ArrayList<>();
	params.add(this.getTitle());
	params.add(this.getBody());
	params.add(this.getID());
	return params;
    }

    @Override
    public List<Object> getDeleteParameters() {
	ArrayList<Object> params = new ArrayList<>();
	params.add(this.getID());
	return params;
    }

}

public class NewsModel extends SQLDataBaseModel {

    private boolean forSite;
    
    public NewsModel() throws SQLManagerCreationException
    {
	forSite = false;
    }    
    
    public void setForSite(boolean forSite) {
	this.forSite = forSite;
    }   
    
    @Override
    protected List<Object> getRetrieveParameters() {
	return null;
    }

    @Override
    protected void processRetrieveOutParameters() {
    }

    @Override
    protected IBusinessObject getItemFromDBRecord(ResultSet rs) {
	News o = new News();
	try {
	    o.setID(rs.getInt(1));
	    o.setNewsdt(rs.getTimestamp(2));
	    o.setTitle(rs.getString(3));
	    o.setBody(rs.getString(4));
	} catch (SQLException ex) {
	    AppLogger.log("NewsModel",ex);
	}
	return o;
    }

    @Override
    protected String getCreateStatementText() {
	return "insert into news(newsdt, newstitle, newsbody) values(?,?,?)";
    }

    @Override
    protected String getRetrieveStatementText() {
	return "select newsid, newsdt, newstitle, newsbody from news order by newsdt desc"+(forSite?" limit 20":"");
    }

    @Override
    protected String getUpdateStatementText() {
	return "update news set newstitle = ?, newsbody = ? where newsid = ?";
    }

    @Override
    protected String getDeleteStatementText() {
	return "delete from news where newsid = ?";
    }

    @Override
    protected String getRetrieveOneStatementText() {
	return "select newsid, newsdt, newstitle, newsbody from news where newsid = ?";
    }
    
}

public class BusSchemeModel extends SQLDataBaseModel {

    private int busid = 0;
    private short rows = 0;
    private short columns = 0;
    private short lastrowcolumns = 0;
    private long tripid = 0;

    public BusSchemeModel() throws SQLManagerCreationException{
        super();
    }

    public void setBusid(int busid) {
        this.busid = busid;
        this.tripid = 0;
    }

    public void setTripid(long tripid) {
        this.tripid = tripid;
    }

    public int getBusid() {
        return busid;
    }

    public short getRows() {
        return rows;
    }

    public short getColumns() {
        return columns;
    }

    public short getLastrowcolumns() {
        return lastrowcolumns;
    }

    @Override
    protected List<Object> getRetrieveParameters() {
        ArrayList<Object> params = new ArrayList<>();
        params.add(tripid == 0 ? busid : tripid);
        return params;
    }

    @Override
    protected void processRetrieveOutParameters() {
    }

    @Override
    protected IBusinessObject getItemFromDBRecord(ResultSet rs) {
        BusScheme bo = new BusScheme();
        try {
            bo.setID(rs.getLong(1));
            bo.setBusid(rs.getInt(2));
            bo.setSeatrow(rs.getShort(3));
            bo.setSeatcolumn(rs.getShort(4));
            bo.setSeatnumber(rs.getString(5));
            updateSchemeParameters(bo);
        } catch (SQLException ex) {
            AppLogger.log(this.getClass().getName(), ex);
        }
        return bo;
    }

    @Override
    protected String getCreateStatementText() {
        return tripid == 0 ? "insert into busscheme(busid, seatrow, seatcolumn, seatnumber) values(?,?,?,?)" : null;
    }

    @Override
    protected String getRetrieveStatementText() {
        return tripid == 0 ? "select busseatid, busid, seatrow, seatcolumn, seatnumber from busscheme where busid = ? order by seatrow, seatcolumn"
                : "select bs.busseatid, bs.busid, bs.seatrow, bs.seatcolumn, bs.seatnumber "
                + "from trip as t "
                + "inner join busscheme as bs on bs.busid = t.busid "
                + "where t.tripid = ? order by seatrow, seatcolumn";
    }

    @Override
    protected String getUpdateStatementText() {
       return tripid == 0 ? "update busscheme set seatnumber = ? where busseatid = ?" : null;
    }

    @Override
    protected String getDeleteStatementText() {
        return tripid == 0 ? "delete from busscheme where busid = ?" : null;
    }

    @Override
    protected String getRetrieveOneStatementText() {
        return tripid == 0 ? "select busseatid, busid, seatrow, seatcolumn, seatnumber from busscheme where busseatid = ?" : null;
    }

    private void updateSchemeParameters(BusScheme bo) {
        if (bo.getSeatrow() > rows) {
            rows = bo.getSeatrow();
            lastrowcolumns = bo.getSeatcolumn();
        } else if (bo.getSeatrow() == rows) {
            lastrowcolumns = bo.getSeatcolumn();
        }
        if (bo.getSeatcolumn() > columns) {
            columns = bo.getSeatcolumn();
        }
    }

}