notesessionimpl.java

MVC留言

package org.bob.session;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import org.bob.entity.DynamicEntity;
import org.bob.model.DataAccessAdapter;
import org.bob.model.IDataAccess;

public class NoteSessionImpl extends DataAccessAdapter{

	private Connection con=null;
	
	@Override
	public void save(DynamicEntity entity) throws Exception {
		String sql="insert into note values(?,?,?,?)";
		con=getConnection();
		//使用预编译接口执行插入操作
		PreparedStatement pstm=con.prepareStatement(sql);
		pstm.setLong(1,System.currentTimeMillis());
		pstm.setString(2,(String)entity.getElement("USERID"));
		pstm.setString(3,(String)entity.getElement("TITLE"));
		pstm.setString(4,(String)entity.getElement("NOTE"));
		pstm.executeUpdate();
		con.close();
	}

	public List find() throws SQLException{
		return this.find("NOTE", null,IDataAccess.MODEL_ADD);
	}

	
	
}