使用C#批量修改dz论坛主题的发帖人

admin

        对于很多使用dz论坛运营的站长们，初始为了吸引人气可能会使用采集器，但论坛上全部都是几个用户在发帖回贴。于是便使用C#来批量修改发帖人和回贴人，制造论坛用户活跃的假象。代码如下，需要详细的请联系本站长。使用时需要使用MYSQL数据库连接库mysql-connector-net-6.8.3，注意MYSQL不支持OLEDB的自动更新语句，需要手工写更新代码。

1.         DataSet DiscuzDZDS = new DataSet();
   
2.             string DZConnectionString = "server=localhost;user id=root; password=*; database=ultrax; pooling=false;charset=utf8 ";
   
3.             string SqlText = "SELECT  uid,username FROM pre_common_member order by regdate limit 100 ";// "dnt_users";
   
4.             //MySqlConnection connection = new MySqlConnection(DZConnectionString);
   
5.             //connection.Open();
   
6.             MySqlDataAdapter users_newsAdapter = new MySqlDataAdapter(SqlText, DZConnectionString);
   
7.             MySqlCommandBuilder users_newsCommandBuilder = new MySqlCommandBuilder(users_newsAdapter);
   
8. 
   
9.             users_newsAdapter.Fill(DiscuzDZDS, "pre_common_member");
   
10.             //List<int> ID = new List<int>();
    
11. 
    
12. 
    
13. 
    
14.             string topicSqlText = "SELECT * FROM pre_forum_thread where author='xycost'";// "dnt_topics";
    
15.             MySqlDataAdapter dz_topicAdapter = new MySqlDataAdapter(topicSqlText, DZConnectionString);
    
16.             //MySqlCommandBuilder dz_topicCommandBuilder = new MySqlCommandBuilder(dz_topicAdapter);
    
17.             dz_topicAdapter.Fill(DiscuzDZDS, "pre_forum_thread");
    
18. 
    
19.             DataRow[] PostRows = DiscuzDZDS.Tables["pre_forum_thread"].Select();
    
20. 
    
21.             int postnum = 0;
    
22.             for (int j = 0; j < PostRows.Length; j++)
    
23.             {
    
24.                 //if (j == 1)
    
25.                 //    break;
    
26.                 DataRow TopicsRow = PostRows[j];
    
27.                 Random random = new Random();
    
28.                 int UserNum = random.Next(1, DiscuzDZDS.Tables["pre_common_member"].Select().Length);
    
29.                 DataRow UserRow = DiscuzDZDS.Tables["pre_common_member"].Select()[UserNum];
    
30.      
    
31.                 int uid = Convert.ToInt32(UserRow["uid"]);
    
32.                 string username = UserRow["username"].ToString();
    
33.                 postnum++;
    
34. 
    
35.                 //TopicsRow["author"] = username;
    
36.                 //TopicsRow["authorid"] = uid;
    
37.                 int tid =Convert.ToInt32( TopicsRow["tid"]);
    
38.           try
    
39.                 {
    
40.                     string sql = "update pre_forum_thread set author=?author,authorid=?authorid where tid=?tid";
    
41.                     MySqlParameter[] parameters = new MySqlParameter[3];
    
42.                     parameters[0] = new MySqlParameter("?author", MySqlDbType.VarChar, 50);
    
43.                     parameters[0].Value = username ;
    
44.                     parameters[1] = new MySqlParameter("?authorid", MySqlDbType.Int32);
    
45.                     parameters[1].Value = uid;
    
46.                   
    
47.                     parameters[2] = new MySqlParameter("?tid", MySqlDbType.Int32);
    
48.                     parameters[2].Value = tid;
    
49. 
    
50.                     ExecuteNonQuery(sql, parameters,DZConnectionString);
    
51. 
    
52.                     string postSqlText = "SELECT * FROM pre_forum_post where tid="+tid;// "dnt_topics";
    
53.                     MySqlDataAdapter dz_postAdapter = new MySqlDataAdapter(postSqlText, DZConnectionString);
    
54.                     //MySqlCommandBuilder dz_postCommandBuilder = new MySqlCommandBuilder(dz_postAdapter);
    
55.                     if (DiscuzDZDS.Tables.Contains("pre_forum_post"))
    
56.                         DiscuzDZDS.Tables["pre_forum_post"].Clear();
    
57.                     dz_postAdapter.Fill(DiscuzDZDS, "pre_forum_post");
    
58. 
    
59.                   
    
60.                     foreach (DataRow postrow in DiscuzDZDS.Tables["pre_forum_post"].Select())
    
61.                     {
    
62.                         sql = "update pre_forum_post set author=?author,authorid=?authorid where pid=?pid";
    
63.                         int pid = Convert.ToInt32(postrow["pid"]);  
    
64.                         if (Convert.ToInt32(postrow["first"]) == 1)
    
65.                         {
    
66.                             parameters = new MySqlParameter[3];
    
67.                             parameters[0] = new MySqlParameter("?author", MySqlDbType.VarChar, 50);
    
68.                             parameters[0].Value = username;
    
69.                             parameters[1] = new MySqlParameter("?authorid", MySqlDbType.Int32);
    
70.                             parameters[1].Value = uid;
    
71.                             parameters[2] = new MySqlParameter("?pid", MySqlDbType.Int32);
    
72.                             parameters[2].Value = pid;
    
73.                         }
    
74.                         else
    
75.                         {
    
76.                             UserNum = random.Next(1, DiscuzDZDS.Tables["pre_common_member"].Select().Length);
    
77.                             UserRow = DiscuzDZDS.Tables["pre_common_member"].Select()[UserNum];
    
78.                             uid = Convert.ToInt32(UserRow["uid"]);
    
79.                             username = UserRow["username"].ToString();
    
80.                             parameters = new MySqlParameter[3];
    
81.                             parameters[0] = new MySqlParameter("?author", MySqlDbType.VarChar, 50);
    
82.                             parameters[0].Value = username;
    
83.                             parameters[1] = new MySqlParameter("?authorid", MySqlDbType.Int32);
    
84.                             parameters[1].Value = uid;
    
85.                             parameters[2] = new MySqlParameter("?pid", MySqlDbType.Int32);
    
86.                             parameters[2].Value = pid;
    
87.                         }
    
88.                         ExecuteNonQuery(sql, parameters, DZConnectionString);
    
89.                     }
    
90.                     //DataTable changes = DiscuzDZDS.Tables["pre_forum_post"].GetChanges();
    
91.                     //dnt_topicsAdapter.Update(changes);
    
92.                     //DiscuzDZDS.Tables["pre_forum_post"].AcceptChanges();
    
93.                     //dnt_topicsAdapter.Update(DiscuzDZDS, "pre_forum_post");
    
94.                 }
    
95.                 catch(Exception ){}
    
96.               ｝  
    
97.             

复制代码