diff options
-rw-r--r-- | forum-merge/optional-stored-routine-and-info-regarding-privmsgs | 84 |
1 files changed, 84 insertions, 0 deletions
diff --git a/forum-merge/optional-stored-routine-and-info-regarding-privmsgs b/forum-merge/optional-stored-routine-and-info-regarding-privmsgs new file mode 100644 index 0000000..939fa67 --- /dev/null +++ b/forum-merge/optional-stored-routine-and-info-regarding-privmsgs @@ -0,0 +1,84 @@ + +this segment into the merge script + +#---------------------------------privmsgs----------------------------------------------------------------- + +print "counting attach_id" +cursor.execute("SELECT max( msg_id ) FROM phpbb_privmsgs;") +data = cursor.fetchone() +maxmsg=data +print "maxmsg : %s " % maxmsg + +#make all user folders to inbox +cursor.execute("update phpbb_privmsgs_to_2 set folder_id = 0 where folder_id > 0;") +# remove the auto increment attribute and primary key index +cursor.execute("ALTER TABLE phpbb_privmsgs_2 CHANGE `msg_id` `msg_id` MEDIUMINT( 8 ) UNSIGNED NOT NULL;") +cursor.execute("alter table phpbb_privmsgs_2 drop primary key;") +cursor.execute("update phpbb_privmsgs_2 set msg_id = msg_id + %s;" % maxmsg) + +#delete auto increment +cursor.execute("ALTER TABLE phpbb_privmsgs_to_2 CHANGE `msg_id` `msg_id` MEDIUMINT( 8 ) UNSIGNED NOT NULL;") +#increase ids +cursor.execute("update phpbb_privmsgs_to_2 set msg_id = msg_id + %s;" % maxmsg) + +cursor.execute("CREATE TABLE phpbb_privmsgs_3 (msg_id MEDIUMINT( 8 ),to_address TEXT,bcc_address TEXT);") + + + + +##CALL STORED PROCEEDURE HERE + + + + +cursor.execute("update phpbb_privmsgs_2, phpbb_privmsgs_3 set phpbb_privmsgs_2.to_address = phpbb_privmsgs_3.to_address where phpbb_privmsgs_2.msg_id = phpbb_privmsgs_3.msg_id;") + +#merge +cursor.execute("INSERT INTO phpbb_privmsgs (msg_id, root_level, author_id, icon_id, author_ip, message_time, enable_bbcode, enable_smilies, enable_magic_url, enable_sig, message_subject, message_text, message_edit_reason, message_edit_user, message_attachment, bbcode_bitfield, bbcode_uid, message_edit_time, message_edit_count, to_address, bcc_address) select msg_id, root_level, author_id, icon_id, author_ip, message_time, enable_bbcode, enable_smilies, enable_magic_url, enable_sig, message_subject, message_text, message_edit_reason, message_edit_user, message_attachment, bbcode_bitfield, bbcode_uid, message_edit_time, message_edit_count, to_address, bcc_address from phpbb_privmsgs_2;") + +cursor.execute("INSERT INTO phpbb_privmsgs_to (msg_id, user_id, author_id, pm_deleted, pm_new, pm_unread, pm_replied, pm_marked, pm_forwarded, folder_id) select msg_id, user_id, author_id, pm_deleted, pm_new, pm_unread, pm_replied, pm_marked, pm_forwarded, folder_id from phpbb_privmsgs_to_2;") + + + + + + + + +this stored proceedure into mysql + +replace 133 with maxuser from script + + + + + + +delimiter ;; +CREATE PROCEDURE msgto() +BEGIN + DECLARE userid MEDIUMINT(8); + DECLARE useridold MEDIUMINT(8); + DECLARE done INT DEFAULT 0; + DECLARE myid MEDIUMINT(8); + DECLARE touser int; + DECLARE toadr text; + DECLARE bccadr text; + declare cur1 cursor for select msg_id, to_address, bcc_address from phpbb_privmsgs_2; + open cur1; + repeat + fetch cur1 into myid, toadr, bccadr; + if instr(toadr,':') = 0 and instr(toadr,'u_') = 1 THEN + set touser=convert(right(toadr,length(toadr)-2), UNSIGNED); + set touser=touser + 133; + set useridold=0; + select user_id, user_id_old into userid, useridold from phpbb_users_2 + where user_id_old=touser; + if useridold >=1 then + set touser=userid; + end if; + end if; + insert into phpbb_privmsgs_3 values (myid, concat('u_', convert(touser, char)), bccadr); + UNTIL done END REPEAT; + close cur1; +end;; |