package com.runwit.ebookstore.services.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.runwit.ebookstore.model.BugStatusModel;
import com.runwit.ebookstore.model.GroupModel;
import com.runwit.ebookstore.model.ProjectModel;
import com.runwit.ebookstore.services.IProjectServices;

public class ProjectDAO extends DbDAO implements IProjectServices {

	@Override
	public Object mapRowToModel(ResultSet rs) throws SQLException {
		
		ProjectModel model = new ProjectModel();
		model.setProjectId(rs.getInt("projectId"));
		model.setName(rs.getString("name"));
		model.setOwner(rs.getString("owner"));
		model.setRemark(rs.getString("remark"));
		model.setCreateTime(rs.getLong("createTime"));

		return model;
	}
	
	public boolean create(ProjectModel model) {
		String sql = "insert into project(name, owner, remark, createTime) values(?, ?, ?, ?)";
		String querySql = "select max(projectid) from project";
		
		try
		{
			openConnection();
			conn.setAutoCommit(false);
			openPreparedStatement(sql);
			pstmt.setString(1, model.getName());
			pstmt.setString(2, model.getOwner());
			pstmt.setString(3, model.getRemark());
			pstmt.setLong(4, System.currentTimeMillis());
			int iRet = pstmt.executeUpdate();
			closePreparedStatement();
			openPreparedStatement(querySql);
			rs  = pstmt.executeQuery();
			if(rs.next()) {
				model.setProjectId(rs.getInt(1));
			}
			closeResultSet();
			closePreparedStatement();
			conn.commit();
			return true;
		}catch(SQLException ex) {
			ex.printStackTrace();
			return false;
		}
		finally{
			closeConnection();
		}
	}
	
	public boolean set(ProjectModel model) {
		String sql = "update project set name=?, owner=?, remark=? where projectid=?";
		
		try
		{
			openConnection();
			openPreparedStatement(sql);
			pstmt.setString(1, model.getName());
			pstmt.setString(2, model.getOwner());
			pstmt.setString(3, model.getRemark());
			pstmt.setInt(4, model.getProjectId());
			int iRet = pstmt.executeUpdate();
			return iRet == 1;
		}catch(SQLException ex) {
			ex.printStackTrace();
			return false;
		}
		finally{
			closePreparedStatement();
			closeConnection();
		}
	}
	
	public boolean remove(ProjectModel model) {
		String sql = "delete from project where projectid=" + model.getProjectId();
		try{
			return updateBySql(sql) == 1;
		}catch(SQLException ex) {
			ex.printStackTrace();
			return false;
		}
	}
	
	private List listBySql(String sql) {
		
		try {
			return queryBySql(sql);
		}catch(SQLException ex) {
			ex.printStackTrace();
			return null;
		}
	}
	
	
	public List list() {
		
		return listBySql("select * from project");

	}
	
	public ProjectModel get(int projectId) {
		
		List models = listBySql("select * from project where projectid="+projectId);
		if(models != null && models.size() > 0) 
			return (ProjectModel)models.get(0);
		
		return null;
	}


}