C# 拍拍贷采集程序源码(sqlite数据库)

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using SpiderModel;
using System.Data.SQLite;
using System.Data;
namespace DBCenter
{
    public class PPDaiBui
    {
        public DataTable SearchPPDModel(int pageindex)
        {

            StringBuilder sb = new StringBuilder();
            sb.Append(" select * from ppdmodel limit "   pageindex ",20");

            SQLiteCommand cmd = new SQLiteCommand(sb.ToString());
            return SQLiteHelper.ExecuteDataSet(cmd).Tables[0];

             
        }
        public int GetMaxPPId()
        {
            StringBuilder sb = new StringBuilder();
            sb.Append(" select max(ppid) from ppdmodel");
             
            SQLiteCommand cmd = new SQLiteCommand(sb.ToString());
            System.Data.DataSet ds = SQLiteHelper.ExecuteDataSet(cmd);

            return Convert.ToInt32(ds.Tables[0].Rows[0][0].ToString());

        }
        public DataTable GetPlanPPId(int paginex)
        {
            StringBuilder sb = new StringBuilder();
            sb.Append(" select  ppid from ppdmodel where plan !='100%' and Finished=0 limit "   paginex   ",10");

            SQLiteCommand cmd = new SQLiteCommand(sb.ToString());
             DataSet ds = SQLiteHelper.ExecuteDataSet(cmd);

            return ds.Tables[0];

        }
        public void InsertOrUpdate(PPDModel model)
        {
            if (CheckModel(model))
                InsertModel(model);
            else
                UpdateModel(model);
        }

        public void InsertModel(PPDModel model)
        {

            // 
            StringBuilder sb = new StringBuilder();
            sb.Append("insert into ppdmodel(PPId,UserName,TimeLimits,Rate,AllBalance,RemainingBalance,Plan,Recheck,lefttime,Finished,UpdateTime)");
            sb.Append("values");
            sb.AppendFormat("('{0}','{1}','{2}','{3}','{4}','{5}','{6}','{7}','{8}','{9}','{10}')",
                model.PPId, model.UserName, model.TimeLimits, model.Rate, model.AllBalance, model.RemainingBalance, model.Plan, model.Recheck,model.LeftTime,model.Finished,DateTime.Now);
            SQLiteCommand cmd = new SQLiteCommand(sb.ToString());
            SQLiteHelper.ExecuteNonQuery(cmd);

        }

        public void UpdateModel(PPDModel model)
        {


            StringBuilder sb = new StringBuilder();
            sb.Append("update   ppdmodel ");
            sb.Append(" set ");

            sb.AppendFormat("  UserName='{0}',", model.UserName);
            sb.AppendFormat("  TimeLimits='{0}',", model.TimeLimits);
            sb.AppendFormat("  Rate='{0}',", model.Rate);
            sb.AppendFormat("  AllBalance='{0}',", model.AllBalance);
            sb.AppendFormat("  RemainingBalance='{0}',", model.RemainingBalance);
            sb.AppendFormat("  Plan='{0}',", model.Plan);
            sb.AppendFormat("  LeftTime='{0}',", model.LeftTime);
            sb.AppendFormat("  Finished='{0}',", model.Finished);
            sb.AppendFormat("  UpdateTime='{0}',", DateTime.Now);
            sb.AppendFormat("  Recheck='{0}' ", model.Recheck);
            sb.AppendFormat("  where ppid='{0}' ", model.PPId);

            SQLiteCommand cmd = new SQLiteCommand(sb.ToString());
            SQLiteHelper.ExecuteNonQuery(cmd);

        }


        /// <summary>
        /// 检查PPID是不是存在
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool CheckModel(PPDModel model)
        {
            StringBuilder sb = new StringBuilder();
            sb.Append(" select count(1) from ppdmodel where PPId="   model.PPId);



            SQLiteCommand cmd = new SQLiteCommand(sb.ToString());
            System.Data.DataSet ds = SQLiteHelper.ExecuteDataSet(cmd);
            if (ds.Tables[0].Rows[0][0].ToString().Equals("0"))
                return true;
            else
                return false;

        }
    }
}