博客 - Hibernate执行SQL语句

@Repository

public class ObjectDaoImp extends BaseDaoImpl<Object,String> implements IObjectDao {

​

	public Object sqlExecute(String sqlStr, String flag, String clzName) throws Exception {

		Object object = null;

		switch(flag) {

			case "add":

				break;

			case "delete":

			case "update":

				object = this.getSession().createSQLQuery(sqlStr).executeUpdate();

				break;

			case "select":

				object = this.getSession().createSQLQuery(sqlStr).list();

				break;

		}

		this.getSession().flush();

		return object;

	}

}