src/org/bs/dao/impl/ArticleDaoImpl.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package org.bs.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import org.bs.dao.ArticleDao;
import org.bs.model.Article;
import org.bs.model.Channel;
import org.bs.model.User;
import org.bs.utils.ConnContext;
import org.bs.utils.DB;
import org.bs.utils.PageContext;


public class ArticleDaoImpl extends BaseDao implements ArticleDao {
	public void publish(int publisher,int article){
		Connection conn = ConnContext.getConn();
		PreparedStatement pstmt = null;
		String sql = "update t_article set publish_time = now(),publisher = ? where id = ?";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, publisher);
			pstmt.setInt(2, article);
			pstmt.executeUpdate();
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			DB.close(pstmt);
		}
	}
	public void publishBetch(int publisher,String[] articleIds){
		Connection conn = ConnContext.getConn();
		PreparedStatement pstmt = null;
		String sql = "update t_article set publish_time = now(),publisher = ? where id = ?";
		try {
			pstmt = conn.prepareStatement(sql);
			for (int i = 0; i < articleIds.length; i++) {
				pstmt.setInt(1, publisher);
				pstmt.setInt(2, Integer.parseInt(articleIds[i]));
				pstmt.addBatch();
			}
			pstmt.executeBatch();
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			DB.close(pstmt);
		}
	}
	public void save(Article article){
		Connection conn = ConnContext.getConn();
		PreparedStatement pstmt = null;
		String sql = "insert into t_article" +
				"(title,content,author,source," +
				"click_score,msg_count," +
				"create_time,publish_time,update_time,publisher,channel_id,is_headLine,is_recommend)";
		sql += "values(?,?,?,?,0,0,now(),null,null,?,?,?,?)";
		try {