Как сделать чтобы в sqlite id людей бота не повторялись?
Как сделать чтобы в sqlite id людей бота не повторялись?
И как потом сделать рассылку чтобы можно было прекрепить инлайн кнопку,картинку и к нему фотку в одном сообщении?
Перед тем, как добавить id в базу, проверяйте на наличие этого id в базе.
И как потом сделать рассылку чтобы можно было прекрепить инлайн кнопку,картинку и к нему фотку в одном сообщении?
Сергей Карбивничий Какая функция или код на проверку id?
def add_user_to_db(user_id): connect = sqlite3.connect("db.db") cursor = connect.cursor() cursor.execute("INSERT INTO subscriptions (user_id, status) VALUES (?, ?)", (user_id, True)) connect.commit()
def add_user_to_db(user_id): connect = sqlite3.connect("db.db") cursor = connect.cursor() cursor.execute('SELECT * FROM subscriptions WHERE user_id=?',(user_id,)) result = cursor.fetchone() if not result: print('Добавляем юзера в базу') cursor.execute("INSERT INTO subscriptions (user_id, status) VALUES (?, ?)", (user_id, True)) connect.commit() else: print('Такой юзер уже есть! Ничего не делаем')
Nazar Ivakhiv, через цикл, с использованием метода sendPhoto https://core.telegram.org/bots/api#sendphoto , он как раз таки позволяет кроме отправки самой картинки, так же прикрепить текст Caption, и онлайн клавиатуру
MinTnt, А как сделать чтобы он отправлялся?
Или вообще какую то команду нужно чтобы она отправлялась людям или как?
Думаю будет быстрее работать если id сделать primery key и сразу инсертить в бд, а трюкачем ловить ошибку. Иначе нужно сделать выборку из бд и если нет такого то тогда уже инсертить, что больше будет нагружать бд.
userid = message.chat.id with sq.connect('base.db') as con: cur = con.cursor() cur.execute('''SELECT userid FROM users''') ALLuser = cur.fetchall() if userid in ALLuser: print('Такой ID уже есть') else: with sq.connect('base.db') as con: cur = con.cursor() cur.execute('''INSERT INTO users(userid) VALUES(?)''', (userid))И как потом сделать рассылку чтобы можно было прекрепить инлайн кнопку,картинку и к нему фотку в одном сообщении?
Рассылку можно сделать так
with sq.connect('base.db') as con: cur = con.cursor() cur.execute('''SELECT userid FROM user''') AllUser = cur.fetchall() count = 0 errors = 0 start_time = time.time() for s in range(len(AllUser)): user_id = AllUser[count][0] try: bot.send_message(user_id, text='Текст для рассылки') count += 1 except: count += 1 errors += 1 allusers = int(len(dataid)) goodresult = allusers - errors goodresult = str(goodresult) errors = str(errors) times = "Время выполнения: %s сек." % round((time.time() - start_time)) timesstr = times sms = 'Рассылка завершена!'+'\n'+ 'Успешных результатов: '+goodresult+'\n'+'Ошибок: '+errors+'\n'+timesstr bot.send_message(твой_айди, sms)# сюда придет уведомление о результатах рассылкиData bases with Python
In these examples we are going to use SQLite as database.
To start to use SQLite with python we will need to import the library ‘sqlite3’, once imported we can start using it, first we will establish a connection with the database using sqlite3.connect() , later, to start the navigation we will need a cursor, for that we use .cursor() .
import sqlite3 conn = sqlite3.connect('name database') cur = conn.cursor() import sqlite3 conn = sqlite3.connect('rosterdb.sqlite') cur = conn.cursor() executescript() and execute() ¶
There are two ways to execute SQL statements in python. * executescript() :allow me to execute several SQL statement art the same time, if this statement finish with «;». * execute() : this will be limited to one SQL statement.
executescript() example¶
In the following code we will execute several SQL statement
import sqlite3 conn = sqlite3.connect('rosterdb.sqlite') cur = conn.cursor() cur.executescript(''' SQL statements''') 1 2 3 4 5 6 7 8 9 10
import sqlite3 conn = sqlite3.connect('rosterdb.sqlite') cur = conn.cursor() cur.executescript(''' DROP TABLE IF EXISTS User; DROP TABLE IF EXISTS Member; DROP TABLE IF EXISTS Course; ''') 3. Now we will create 3 tables; «User», «Course», «Member». Member table contain a primary key composed of take two parameters, this is a way to link to the other 2 tables and create the many-to-many relationship
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
import sqlite3 conn = sqlite3.connect('rosterdb.sqlite') cur = conn.cursor() # Do some setup cur.executescript(''' DROP TABLE IF EXISTS User; DROP TABLE IF EXISTS Member; DROP TABLE IF EXISTS Course; CREATE TABLE User ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, name TEXT UNIQUE ); CREATE TABLE Course ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, title TEXT UNIQUE ); CREATE TABLE Member ( user_id INTEGER, course_id INTEGER, role INTEGER, PRIMARY KEY (user_id, course_id) ) ''') INSERT , IGNORE , REPLACE and SELECT ¶
In previous steps we create the schema of the database, now we need to populate this database with information, in this case we are going to extract information from a JSON file and use it to feed the dataset.
Getting the data from JSON¶
First we need to import json
second we need to get the information of a JSON file, in this case we are going to use one of the JSON file examples from the book «Python for everyone».
1 2 3 4 5 6 7 8 9 10 11 12
[. ] fname = input('Enter file name: ') if len(fname) 1: fname = 'roster_data_sample.json' # [ # [ "Charley", "si110", 1 ], # [ "Mea", "si110", 0 ], str_data = open(fname).read() json_data = json.loads(str_data) [. ] Now all the information is in the variable json_data (a list) we will need though this list
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
[. ] fname = input('Enter file name: ') if len(fname) 1: fname = 'roster_data_sample.json' # [ # [ "Charley", "si110", 1 ], # [ "Mea", "si110", 0 ], str_data = open(fname).read() json_data = json.loads(str_data) print(type(json_data)) for entry in json_data: name = entry[0] title = entry[1] role = entry[2] print((name, title, role)) INSERT OR IGNORE ¶
Now we are goin to insert the information in the different tables, for that we will use INSERT and we will add IGNORE to avoid those cases when a error appears.
cur.execute('''INSERT OR IGNORE INTO User (name) VALUES ( ? )''', ( name, ) ) in the previous statement execute() will execute an INSERT instruction to the «User» table, to the column «name», the «?» is a placeholder and the » (name,) » is a tuple that indicate that the information on the variable «name» is going to be place in the «?», and this information will be inserted in the table «User».
Bellow the example of the other statement, the only remark will be the usage of REPLACE which will replace the value of what ever is in that column(s).
1 2 3 4 5 6 7 8 9 10 11
cur.execute('''INSERT OR IGNORE INTO User (name) VALUES ( ? )''', ( name, ) ) cur.execute('''INSERT OR IGNORE INTO Course (title) VALUES ( ? )''', ( title, ) ) cur.execute('''INSERT OR REPLACE INTO Member (user_id, course_id, role) VALUES ( ?, ?, ? )''', ( user_id, course_id, role ) ) SELECT and fetchone()[0] ¶
now we are going to select one of the records in the database and store the first row, for this we will execute the SELECT and later use fetchone[0] to store the first record
cur.execute('SELECT id FROM User WHERE name = ? ', (name, )) user_id = cur.fetchone()[0] we use «[0]» to be sure that we will get just the first record ( fetchone() will get back just one record, to get more you can use fetchall() )
commit ¶
Finally, to commit this changes or this addition to the database we can use the function commit() , this will commit the changes to the database and wait until is done, that is one of the reason in some case the commit is done after several changes and not after each change, since this will make the execution of the script slower.
the full script¶
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65
import json import sqlite3 conn = sqlite3.connect('rosterdb.sqlite') cur = conn.cursor() # Do some setup cur.executescript(''' DROP TABLE IF EXISTS User; DROP TABLE IF EXISTS Member; DROP TABLE IF EXISTS Course; CREATE TABLE User ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, name TEXT UNIQUE ); CREATE TABLE Course ( id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE, title TEXT UNIQUE ); CREATE TABLE Member ( user_id INTEGER, course_id INTEGER, role INTEGER, PRIMARY KEY (user_id, course_id) ) ''') fname = input('Enter file name: ') if len(fname) 1: fname = 'roster_data_sample.json' # [ # [ "Charley", "si110", 1 ], # [ "Mea", "si110", 0 ], str_data = open(fname).read() json_data = json.loads(str_data) print(type(json_data)) for entry in json_data: name = entry[0] title = entry[1] role = entry[2] print((name, title, role)) cur.execute('''INSERT OR IGNORE INTO User (name) VALUES ( ? )''', ( name, ) ) cur.execute('SELECT id FROM User WHERE name = ? ', (name, )) user_id = cur.fetchone()[0] cur.execute('''INSERT OR IGNORE INTO Course (title) VALUES ( ? )''', ( title, ) ) cur.execute('SELECT id FROM Course WHERE title = ? ', (title, )) course_id = cur.fetchone()[0] cur.execute('''INSERT OR REPLACE INTO Member (user_id, course_id, role) VALUES ( ?, ?, ? )''', ( user_id, course_id, role ) ) conn.commit() and an example of the JSON file
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62
[ [ "Alekzander", "si110", 1 ], [ "Tione", "si110", 0 ], [ "Samy", "si110", 0 ], [ "Alicia", "si110", 0 ], [ "Kruz", "si110", 0 ], [ "Dillan", "si110", 0 ], [ "Badr", "si110", 0 ], [ "Murry", "si110", 0 ], [ "Ruslan", "si110", 0 ], [ "Aliesha", "si110", 0 ], [ "Gracielynn", "si110", 0 ], [ "Markus", "si110", 0 ] ]