Ticket #160: checkdelete.groovy

import groovy.sql.*
import java.io.RandomAccessFile;

//ÐÂœšÊýŸÝ¶ÔÏó
def dburl = "jdbc:mysql://192.168.74.5:3310/bbs7_it_app";
def ussername = "root";
def password = "rootbbsmysql";
def Driver = "com.mysql.jdbc.Driver";

def Db = Sql.newInstance(dburl,ussername,password,Driver);

//¶šÒå²ÎÊý
def all_topics = 0;
def old_topics = 0;
def new_topics = 0;


def fids = [768144,769973,768653,768553,769839,768439,768483,768137,768136,678295,681594,681617,681618,741947,
677237,301876,301505,302186,301885,300318,300775,300345,302196,303863,301456,301866,301762,302985,301167,304216,
301175,301504,304955,303438,302007,667015,769843,762407,770085,762373,762426,301713,301027,301026,765284,587044,
592975,587845,27,28,755965,587828,675704,675836,675567,587830,587831,587832,587833,768233,768235,586978,769324,
680926,680927,729311,768223,768224,767854,768784,717089];


def checkAndGetAllTopics(List fids, def Db){
    def index = 0; 
    def all_topics = 0;
    (0..(fids.size() - 1)).each{i ->
        Db.eachRow(" SELECT (CASE WHEN COUNT(*) = 0 THEN 0 ELSE TABLEINDEX END) AS TABLEINDEX FROM BBS7_FORUM_INDEX WHERE FID = " + fids.get(i) ){
            index = it.tableindex;
        };

        Db.eachRow(" SELECT COUNT(*) AS NUM FROM BBS7_TOPIC" + (index == 0 ? "" : "_" + index) + "_BAK WHERE FID = " + fids.get(i) + " OR SUBFORUMID = " + fids.get(i)){
            old_topics = it.num;
        };
        Db.eachRow(" SELECT COUNT(*) AS NUM FROM BBS7_TOPIC" + (index == 0 ? "" : "_" + index) + " WHERE FID = " + fids.get(i) + " OR SUBFORUMID = " + fids.get(i)){
            new_topics = it.num;
        };
        if(new_topics != 0){
            println "Forum " + fids.get(i) + " has topics " + new_topics + " is error...";    
        }else{
            println "Forum " + fids.get(i) + " has topics " + new_topics + " is Ok !";    
        }
        all_topics += old_topics;
    }
    
    return all_topics;


}

def tempArray1 = [];
def tempArray2 = [];
def arrayCount = 0;

(0..(fids.size() - 1)).each{i ->
    
    //µÚÒ»²ã×Ó°æ
    Db.eachRow(" SELECT FID FROM BBS7_FORUM_BAK WHERE PARENTID = " + fids.get(i)){row ->
        tempArray1.add(row.fid);
    };

}
//µÚ¶þ²ã×Ó°æ
    
if( tempArray1.size() != 0){
    (0..(tempArray1.size() - 1)).each{j ->
        Db.eachRow(" SELECT FID FROM BBS7_FORUM_BAK WHERE PARENTID = " + tempArray1.get(j)){ row ->
            tempArray2.add(row.fid);
        };
    };
}
if( tempArray1.size() != 0){
    all_topics += checkAndGetAllTopics(tempArray1,Db);
    
}
if( tempArray2.size() != 0){
    all_topics += checkAndGetAllTopics(tempArray2,Db);

}
all_topics += checkAndGetAllTopics(fids, Db);

def oldTopic1Num = 0;
def newTopic1Num = 0;
Db.eachRow("SELECT COUNT(A.TID) AS NUM FROM BBS7_TOPIC_1 A"){
    newTopic1Num = it.num;
};
Db.eachRow("SELECT COUNT(A.TID) AS NUM FROM BBS7_TOPIC_1_BAK A"){
    oldTopic1Num = it.num;
};

if( all_topics == (newTopic1Num - oldTopic1Num )){
    println "Deleted topics : "+ all_topics +"; Added topics : "+ (newTopic1Num - oldTopic1Num ) +"; Table bbs7_topic_1 is OK!"
}else{
    println "Deleted topics : "+ all_topics +"; Added topics : "+ (newTopic1Num - oldTopic1Num ) +"; Table bbs7_topic_1 is error..."
}