Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/env python
- # -*- coding: utf-8 -*-
- import pymysql
- # Connect to the database
- connection = pymysql.connect(host='mariadb55.websupport.sk',
- port=3310,
- user='my_user',
- passwd='my_pass',
- db='my_db',
- charset='utf8mb4',
- cursorclass=pymysql.cursors.DictCursor)
- with connection.cursor() as cursor:
- sql = "DELETE FROM `email_unreg` WHERE email LIKE '%voprakticky%';\
- DELETE FROM `email_unreg` WHERE email LIKE '%stonline%';"
- cursor.execute(sql)
- with connection.cursor() as cursor:
- sql = "SELECT `email`,`id` FROM `email_unreg`"
- cursor.execute(sql)
- result = cursor.fetchall()
- bad_emails = []
- duplicates = []
- for x in result:
- si_mail = str(x['email']).replace('\n', '').replace(' ', '')
- si_id = str(x['id']).replace('\n', '').replace(' ', '')
- if si_mail in bad_emails:
- print si_mail
- print si_id
- with connection.cursor() as cursor:
- sql = "DELETE FROM `email_unreg` WHERE id=%s"
- cursor.execute(sql, (si_id))
- print "Duplicate removed : " + si_mail
- duplicates.append(si_mail)
- else:
- print "Unique E-MAIL ADDED TO LIST : " + si_mail
- bad_emails.append(si_mail)
- with connection.cursor() as cursor:
- sql = "ALTER TABLE `email_unreg` DROP `id`;\
- ALTER TABLE `email_unreg` ADD `id` INT NOT NULL AUTO_INCREMENT FIRST, ADD PRIMARY KEY (`id`) ;"
- cursor.execute(sql)
- print "\n###################################\n"
- print "Total E-Mails: " + str(len(result))
- print "Total - Deleted E-Mails : " + str(len(duplicates))
- print "\n###################################\n"
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement