Методы объекта Cursor модуля MySQLdb в Python.

Синтаксис:
import MySQLdb
db=MySQLdb.connect(...)
# создание объекта курсора
cursor = db.cursor([cursorclass])
Параметры:
  • cursorclass — необязательный аргумент, класс используемого курсора. По умолчанию используется стандартный класс cursors.Cursor (результат запроса будет возвращаться в виде списка кортежей). Может принимать встроенный класс cursors.DictCursor (результат запроса будет возвращаться в виде словаря, значения ключей — названия столбцов таблицы).
Возвращаемое значение:
  • объект Cursor.
Описание:

Объект Cursor представляет собой курсор базы данных, который создается для объекта соединения и используется для управления контекстом операции выборки. Курсоры, созданные из одного и того же соединения, не изолированы, т. е. любые изменения, внесенные в базу данных курсором, немедленно видны другим курсорам. Курсоры, созданные из разных соединений, могут или не могут быть изолированы, в зависимости от того, как реализована поддержка транзакций.

Атрибуты и методы объекта

Cursor.
  • Cursor.arraysize количество строк, которые нужно извлечь за один раз,
  • Cursor.lastrowid возвращает id последней измененной строки в таблице,
  • Cursor.rowcount возвращает количество строк, созданных последним запросом,
  • Cursor.rownumber должен возвращать текущий индекс курсора в результирующем наборе,
  • Cursor.callproc() вызывает хранимую процедуру,
  • Cursor.close() немедленно закрывает курсор,
  • Cursor.info() возвращает некоторую информацию о последнем запросе,
  • Cursor.execute() подготавливает и выполняет запрос к базе данных,
  • Cursor.executemany() выполняет множественные запросы к базе данных,
  • Cursor. fetchone() получает одну (первую) строку из результатов запроса,
  • Cursor.fetchmany() получает следующий набор строк размером size,
  • Cursor.fetchall() получает все или оставшиеся строки результата запроса,
  • Cursor.nextset() перемещает курсор к следующему набору результатов,
  • Cursor.next() возвращает следующую строку результата запроса,
  • Cursor.__iter__() обеспечивает совместимость с протоколом итерации,
  • Cursor.scroll() прокручивает курсор в наборе результатов до новой позиции,
  • Пример работы с курсором.
Cursor.arraysize:

Свойство Cursor.arraysize для чтения/записи указывает количество строк, которые нужно извлечь за один раз с помощью Cursor.fetchmany(). По умолчанию равен 1, что означает извлечение одной строки за раз.

Cursor.lastrowid:

Свойство Cursor. lastrowid только для чтения, возвращает id последней измененной строки в таблице (некоторые версии MySQL возвращают идентификатор строки только при выполнении одной операции INSERT). Если операция не может установить идентификатор строки id или если таблица базы данных не имеет столбца id, то этот атрибут возвращает значение None.

Семантика Cursor.lastrowid не определена, если последний выполненный запрос изменил более одной строки, например, при использовании INSERT с Cursor.executemany().

query = "INSERT INTO table (field1, field2, field3) VALUES (%s, %s, %s)"
cursor.execute(query, (param1, param2, param3,))
# получаем `id` вставленной записи
last_id = cursor.lastrowid)
Cursor.rowcount:

Свойство Cursor.rowcount только для чтения, возвращает количество строк, созданных последним Cursor.execute() (для операторов SQL, таких как SELECT), или затронутых (для операторов SQL, таких как UPDATE или INSERT).

Свойство Cursor.rowcount равен -1, если над курсором не было выполнено Cursor.execute() или интерфейс не может определить количество строк последней операции.

Примечание. Будущие версии спецификации Python DB API могут переопределить последний случай, чтобы объект возвращал None вместо -1.

cursor.execute("SELECT spam, eggs, sausage FROM breakfast")
if cursor.rowcount > 0: # если есть результаты
    # то проходимся по списку кортежей с результатами запроса
    for row in cursor.fetchall():
        # извлекаем данные из кортежа с результатами
        spam = row[0]
        eggs = row[1]
        sausage = row[2]
Cursor.rownumber:

Свойство Cursor.rownumber только для чтения, должен возвращать текущий индекс курсора в результирующем наборе, отсчитываемый от 0, или None, если индекс не может быть определен.

Индекс можно рассматривать как индекс курсора в последовательности (результирующем наборе). Следующая операция выборки извлечет строку с индексом Cursor.rownumber в этой последовательности.

Cursor.callproc(procname [, parameters]):

Метод Cursor.callproc() вызывает хранимую процедуру procname с последовательностью аргументов parameters. Возвращает исходные аргументы. Поддержка хранимых процедур работает только с MySQL версии 5.0 и новее.

Примечание о совместимости: PEP-249 указывает, что при наличии параметров OUT или INOUT должны быть возвращены измененные значения. Это не всегда возможно с MySQL. Аргументы хранимой процедуры должны передаваться как переменные сервера и могут быть возвращены только с помощью оператора SELECT. Так как хранимая процедура может возвращать ноль или более наборов результатов, модуль MySQLdb не может определить, есть ли наборы результатов для выборки, прежде чем будут доступны измененные параметры.

Параметры хранятся на сервере как @_*procname*_*n*, где n — позиция аргумента. То есть, если используется cursor.callproc("foo", (a, b, c)), то параметры будут доступны с помощью запроса SELECT @_foo_0 as foo_0, @_foo_1 as foo_1 и @_foo_2 as foo_2.

Примечание о совместимости: Похоже, что выполнение инструкции SQL CALL создает пустой результирующий набор, который появляется после любых результирующих наборов, которые могут быть сгенерированы хранимой процедурой. Таким образом, всегда нужно будет использовать метод Cursor.nextset() для перебора результатов.

Cursor.close():

Метод Cursor.close() немедленно закрывает курсор. Будущие операции будут вызывать исключение `MySQLdb.ProgrammingError’. Если используются курсоры на стороне сервера, то очень важно закрыть курсор, когда он больше не нужен, и особенно перед созданием нового.

Модуль не представляет менеджер контекста для закрытия открытого курсора. Для этих целей можно использовать функцию стандартной библиотеки contextlib.closing().

from MySQLdb import connect
from contextlib import closing
# поднимаем соединение с базой данных
db = connect('user': 'user', 'password': 'password', 'db': 'test_db')
# открываем db.cursor() в менеджере контекста
with closing(db.cursor()) as cursor:
    cursor.execute("SELECT spam, eggs, sausage FROM breakfast")
    ...
    ...
Cursor.info():

Метод Cursor.info() возвращает некоторую информацию о последнем запросе. Обычно этот метод не используется. Если есть какие-либо предупреждения MySQL, то это должно привести к выдаче предупреждения через MySQLdb.Warning и/или предупреждения Python. Также, по умолчанию предупреждение приводит к появлению сообщения на консоли. Можно отфильтровать их или вызвать предупреждение, которое будет выдано как исключение.

Cursor.execute(operation [, parameters]):

Метод Cursor. execute() подготавливает и выполняет operation к базе данных (запрос или SQL-команду). Аргумент parameters могут быть предоставлены в виде кортежа или сопоставления и будут привязаны к переменным в operation. Переменные указываются в нотации, специфичной для базы данных (подробности смотрите в описании аргумента paramstyle функции MySQLdb.connect()).

Ссылка на операцию operation останется за курсором. Если снова передается тот же объект операции, то курсор может оптимизировать свое поведение. Это наиболее эффективно для алгоритмов, в которых используется одна и та же операция, но к ней привязаны разные

parameters (много раз).

Возвращает список объектов, представляющие выборку строк таблицы базы данных в зависимости от используемого класса курсора или None, если запрос вернул пустую выборку.

max_price=5
cursor.execute("""SELECT spam, eggs, sausage FROM breakfast
          WHERE price < %s""", (max_price,))
Cursor. executemany(operation, seq_of_parameters):

Метод Cursor.executemany() подготавливает operation (множественный запрос) к базы данных (запрос или SQL-команду), а затем выполняет его для всех значений последовательности параметров или сопоставлений, найденных в последовательности

seq_of_parameters.

Использование этого метода для операции, которая создает один или несколько результирующих наборов, представляет собой неопределенное поведение.

К этому методу применимы те же комментарии, что и для Cursor.execute().

cursor.executemany(
      """INSERT INTO breakfast (name, spam, eggs, sausage, price)
      VALUES (%s, %s, %s, %s, %s)""",
      [
          ("Spam and Sausage Lover's Plate", 5, 1, 8, 7.95 ),
          ("Not So Much Spam Plate", 3, 2, 0, 3.95 ),
          ("Don't Wany ANY SPAM! Plate", 0, 4, 3, 5.95 )
      ] )
Cursor.fetchone():

Метод Cursor.fetchone() получает одну (первую) строку набора результатов запроса, возвращая одну последовательность, или

None, если больше нет доступных данных.

Если предыдущий вызов Cursor.execute() не привел к набору результатов или вызов еще не был выполнен, то возникает исключение MySQLdb.Error (или его подкласс).

max_price=5
cursor.execute("""SELECT spam, eggs, sausage FROM breakfast
          WHERE price < %s""", (max_price,))
# получаем первый кортеж из списка 
# кортежей с результатами запроса
row = cursor.fetchone()
# извлекаем результаты из кортежа
spam = row[0]
eggs = row[1]
sausage = row[2]
Cursor.fetchmany([size=cursor.arraysize]):

Метод Cursor.fetchmany() получает следующий набор строк результата запроса, возвращая список кортежей. Когда больше нет доступных строк, то возвращается пустая последовательность.

Количество строк для выборки за вызов определяется аргументом size. Если он не указан, то размер массива курсора определяет количество извлекаемых строк. Метод попытаться получить столько строк, сколько указано аргументом size. Если это невозможно из-за того, что указанное количество строк недоступно, то может быть возвращено меньшее количество строк.

Если предыдущий вызов Cursor.execute() не привел к набору результатов или вызов еще не был выполнен, то возникает исключение MySQLdb.Error (или его подкласс).

Обратите внимание, что с аргументом size связаны соображения производительности. Для оптимальной производительности, лучше всего использовать свойство Cursor.arraysize. Если используется аргумент size, то для него лучше сохранять одно и то же значение от одного вызова Cursor.fetchmany() до следующего.

Cursor.fetchall():

Метод Cursor.fetchall()

получает все (оставшиеся) строки результата запроса, возвращая их в виде список кортежей.

Обратите внимание, что свойство Cursor.arraysize может повлиять на производительность этой операции.

Если предыдущий вызов Cursor. execute() не привел к набору результатов или вызов еще не был выполнен, то возникает исключение MySQLdb.Error (или его подкласс).

cursor.execute("SELECT spam, eggs, sausage FROM breakfast")
# проходимся по списку кортежей с результатами запроса
for row in cursor.fetchall():
    # извлекаем данные из кортежа с результатами
    spam = row[0]
    eggs = row[1]
    sausage = row[2]
Cursor.nextset():

Метод Cursor.nextset() перемещает курсор к следующему набору результатов, отбрасывая оставшиеся строки в текущем наборе результатов. Если дополнительных наборов результатов нет, то возвращается None, в противном случае он возвращает истинное значение.

Обратите внимание, что MySQL не поддерживает несколько наборов результатов до версии 4.1.

Если предыдущий вызов Cursor.execute() не привел к набору результатов или вызов еще не был выполнен, то возникает исключение MySQLdb. Error (или его подкласс).

Cursor.next():

Метод Cursor.next() возвращает следующую строку из выполняемого в данный момент оператора SQL, используя ту же семантику, что и Cursor.fetchone().

Когда набор результатов исчерпан, появляется исключение StopIteration.

Cursor.__iter__():

Метод Cursor.__iter__() возвращает self, чтобы сделать курсоры совместимыми с протоколом итерации.

Cursor.scroll(value [, mode=’relative’ ]):

Метод Cursor.scroll() прокручивает курсор в наборе результатов до новой позиции value в соответствии с режимом mode.Если режим mode='relative' (по умолчанию), то значение берется как смещение к текущей позиции в результирующем наборе, если установлено mode='absolute', то значение указывает абсолютную целевую позицию.

Если операция прокрутки выходит за пределы набора результатов, то возникает исключение IndexError. В этом случае позиция курсора остается неопределенной.

Пример работы с курсором.

Модуль MySQLdb не имеет встроенных менеджеров контекста для закрытия курсора. Для удобной очистки оперативной памяти от результатов объекта курсора лучше использовать функцию стандартной библиотеки contextlib.closing.

from MySQLdb import connect, cursors, Error
from contextlib import closing
# конфигурация соединения с базой данных
MYSQLCONF = {
    'host': 'localhost', # хост базы данных
    'user': '******', # имя пользователя базы данных
    'password': '******', # пароль пользователя базы данных
    'db': 'test_db', # имя базы данных
    'charset': 'utf8', # используемая кодировка базы данных
    'autocommit': True, # автоматический cursor.commit()
    # извлекаемые строки из БД принимают вид словаря
    'cursorclass': cursors.DictCursor
}
# поднимаем соединение с базой данных
db = connect(**MYSQLCONF)
# открываем курсор при помощи `contextlib.closing` 
with closing(db.
 
 cursor()) as cursor:
    # создаем строку с запросом с использованием подстановок
    query = """INSERT INTO table (field1, field2, field3) 
               VALUES (%s, %s, %s)"""
    try:
        # выполняем запрос с необходимыми параметрами
        cursor.execute(query, (param1, param2, param3,))
        # здесь должна быть строка с командой `cursor.commit()`
        # но ее нет, т.к. соединение настроено с 'autocommit': True
    except Error as err:
        # Класс `Error` выводит ошибки, связанные с работой базы данных  
        # и не обязательно находящихся под контролем программиста
        print(err)
    # если нужно, то можно получить `id` вставленной записи
    print('lastrowid =>', cursor.lastrowid)
# далее какой-то код программы
...

питон операции с базами данных MySQL

Предыдущий: rstrip Python () метод

Далее: Python SMTP для отправки почты

стандартный интерфейс базы данных Python для Python DB-API, Python DB-API предоставляет интерфейс прикладного программирования баз данных для разработчиков.

Интерфейс базы данных Python поддерживает очень большие базы данных, вы можете выбрать свой проект базы данных:

  • овод
  • Msql
  • MySQL
  • PostgreSQL
  • Microsoft SQL Server 2000
  • Informix
  • Interbase
  • оракул
  • Sybase

Вы можете получить доступ к интерфейса базы данных Python и API См подробный список поддерживаемых баз данных.

Различные базы данных вам нужно будет загрузить другой модуль DB API, например, вам необходимо получить доступ к базам данных Oracle и данных MySQL, вам необходимо загрузить модуль базы данных Oracle и MySQL.

DB-API является спецификация, которая определяет набор объектов и базы данных режим должен иметь доступ, с тем чтобы обеспечить последовательный интерфейс для доступа широкий спектр базовой системы баз данных и разнообразные программы интерфейса базы данных.

DB-API в Python, для большинства из базы данных реализует интерфейс, используйте его только после подключения к базе данных, вы можете использовать таким же образом, каждую базу данных.

Python DB-API, с использованием процесса:

  • Внедрение модуля API.
  • Подключайтесь к базе данных.
  • Выполнение инструкций SQL и хранимых процедур.
  • Закройте соединение с базой данных.

Что такое MySQLdb?

MySQLdb представляет собой интерфейс для связи с базой данных Python Mysql, который реализует Python спецификации API Database V2.0, основанный на создании API MySQL C.

Как установить MySQLDb?

Для того, чтобы написать MySQL скрипты с DB-API, вы должны убедиться, что вы установили MySQL. Скопируйте следующий код и выполнить его:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

Если вывод заключается в следующем после выполнения, а это значит, у вас нет установлен модуль MySQLdb:

Traceback (most recent call last):
  File "test.py", line 3, in <module>
    import MySQLdb
ImportError: No module named MySQLdb

Установить MySQLDb, посетить http://sourceforge. net/projects/mysql-python , (платформа Linux можно получить: https://pypi.python.org/pypi/MySQL-python ) Отсюда выбрать для вашей платформы Инсталляционный пакет, предварительно скомпилированных двоичных файлов и в пакете исходного кода.

При выборе бинарную версию выпуска, процесс установки предложит завершить базовую установку. При установке из исходного кода, вам необходимо перейти в каталог выпуск верхнего уровня MySQLDb, и введите следующую команду:

$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install

Примечание: Убедитесь , что у вас есть привилегии суперпользователя для установки модулей , описанных выше.

Связь с базами данных

Перед подключением к базе данных, убедитесь, что следующие элементы:

  • Вы создали TESTDB базы данных.
  • В базе данных TESTDB вы создали таблицу сотрудников
  • СОТРУДНИК поля таблицы FIRST_NAME, LAST_NAME, возраст, пол и ДОХОД.
  • Пользователи подключаются к базе данных с использованием TESTDB с именем «TestUser», пароль «test123», вы можете настроить свой собственный прямо или корневой имя пользователя и пароль, Mysql лицензия пользователя базы данных, пожалуйста, используйте команду Grant.
  • На вашей машине уже установлен модуль Python MySQLDb.
  • Если вы не знакомы с утверждением SQL, вы можете посетить наш SQL учебник основы

Пример:

Следующие примеры связи баз данных TESTDB Mysql:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()

print "Database version : %s " % data

# 关闭数据库连接
db.close()

Реализация этого скрипта выводит результаты выглядят следующим образом:

Database version : 5. 0.45

Создание таблицы базы данных

Если соединение с базой данных существует, мы можем использовать метод Execute () для создания таблиц для базы данных, создать таблицу сотрудников, показанную в следующем:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()

вставка базы данных

В следующем примере используется выполнить SQL INSERT заявление, чтобы вставить запись в таблицу EMPLOYEE:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb. connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # Rollback in case there is any error
   db.rollback()

# 关闭数据库连接
db.close()

Приведенный выше пример можно записать следующим образом:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
       ('Mac', 'Mohan', 20, 'M', 2000)
try:
   # 执行sql语句
   cursor. execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

# 关闭数据库连接
db.close()

Пример:

Следующий код использует переменные для передачи параметров в SQL заявление:

..................................
user_id = "test123"
password = "password"

con.execute('insert into Login values("%s", "%s")' % \
             (user_id, password))
..................................

запросы к базе данных

Python Mysql запрос с использованием метода fetchone () для получения однократной данных с использованием метода fetchall () для получения множества данных.

  • fetchone (): Этот метод получает следующий набор результатов запроса.Результат представляет собой набор объектов
  • fetchall (): возвращает результат , чтобы получить все строки.
  • ROWCOUNT: Это атрибут только для чтения, и возвращает выполнение выполнения () метод после числа затронутых строк.

Пример:

Discover СОТРУДНИК таблица заработной платы (оплаты труда) поле данных больше, чем все 1000:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
      # 打印结果
      print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
             (fname, lname, age, sex, income )
except:
   print "Error: unable to fecth data"

# 关闭数据库连接
db.close()

Результаты выполнения скрипта выше следующим образом:

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

обновление баз

Данные операции обновление для обновления таблицы данных, следующие примеры TESTDB поля таблицы Секс все изменения ‘M’, поле AGE увеличивается на 1:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb. connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
                          WHERE SEX = '%c'" % ('M')
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

# 关闭数据库连接
db.close()

делеция

Удаление данных удаления данных для таблицы, следующий пример демонстрирует удаление данных в таблице EMPLOYEE возрастов больше, чем все данные 20:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交修改
   db. commit()
except:
   # 发生错误时回滚
   db.rollback()

# 关闭连接
db.close()

Исполнительные делам

Механизм транзакций для обеспечения целостности данных.

Услуги должны иметь четыре свойства: атомарность, согласованность, изоляция, долговечность. Эти четыре свойства часто называют свойствами ACID.

  • Atomic (атомарность). Сделка является неделимой единицей работы, такие операции включаются в транзакции либо делать или не делать.
  • Последовательность (концентрации). Услуги должны быть изменены, чтобы сделать базу данных из одного согласованного состояния в другое согласованное состояние. Последовательность и атомарность тесно связаны между собой.
  • Изоляция (изоляция). Выполнение транзакции не может быть другой транзакции помех. То есть внутренняя операция транзакций и использование других транзакций данных параллелизм изолируется и не могут мешать друг другу между отдельными сделками выполняться одновременно.
  • Стойкость (долговечность). Стойкие также называют постоянным (неизменность), это означает, что когда-то транзакция фиксируется, изменить свои данные в базе данных должны быть постоянными. Следующие другие операции или его отказ не должен иметь никакого влияния.

Python DB API 2.0 обеспечивает два способа фиксации транзакции или отката.

Пример: 

# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 向数据库提交
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

Для транзакционной базы данных, программирование баз данных в Python, когда установлен курсор, автоматически начинает транзакцию базы данных невидимой.

совершить () метод для всех метода обновления курсора, откат (), чтобы откатить все операции текущего курсора. Каждый метод начал новый бизнес.

Обработка ошибок

DB API определяет некоторые ошибки и отклонения от нормы функционирования базы данных В следующей таблице перечислены эти ошибки и исключения. :

ненормальный описание
предупреждение Когда есть серьезное предупреждение для запуска, например, вставка данных усекается, и так далее. Это должен быть подкласс StandardError.
ошибка Все остальные, кроме предупреждений классы ошибок. Это должен быть подкласс StandardError.
InterfaceError Срабатывает, когда модуль интерфейса базы данных имеет свою собственную ошибку (вместо базы данных ошибок) происходит. Оно должно быть подклассом Error.
DatabaseError Запуск и ошибки базы данных, связанных с. Оно должно быть подклассом Error.
DataError Когда есть произошла ошибка обработки данных при запуске, например: деление на ноль ошибок, данные вне диапазона, и так далее. Это должен быть подкласс DatabaseError.
OperationalError Это относится к не-контролируемых пользователем, но произошла ошибка при базе данных. Например: случайно отключен, имя базы данных не найден, то сделка не удается, ошибка распределения памяти произошла ошибка базы данных и т.п. операции. Это должен быть подкласс DatabaseError.
IntegrityError Целостность-ошибки, связанные, например, внешнего ключа проверки не удается, и тому подобное. Он должен быть DatabaseError подкласс.
InternalError Внутренняя ошибка базы данных, такие как курсор (курсор), выходит из строя, синхронизация транзакций сбой и так далее. Он должен быть DatabaseError подкласс.
ProgrammingError Процедурные ошибки, такие как таблицы данных (таблица) не найдена или уже существует, ошибка синтаксиса SQL заявление, номер ошибки параметров, и так далее. Это должен быть подкласс DatabaseError.
NotSupportedError Не поддерживается ошибка, относится к использованию функций, таких как API или база данных не поддерживает. Например, при использовании .rollback на функции объекта подключения (), но база данных не поддерживает транзакции или сделка была закрыта. Это должен быть подкласс DatabaseError.

Предыдущий: rstrip Python () метод

Далее: Python SMTP для отправки почты

Python MySQL Вставить в

❮ Предыдущий Далее ❯

Вставить в таблицу

Чтобы заполнить таблицу в MySQL, используйте оператор «INSERT INTO».

Пример

Вставить запись в таблицу «клиенты»:

импортировать mysql.connector

mydb = mysql.connector.connect(
  host=»localhost»,
user=» yourusername «,
  password=» yourpassword «,
  database=»mydatabase»
)

mycursor = mydb.cursor()

sql = «ВСТАВИТЬ В клиентов (имя, адрес) ЗНАЧЕНИЯ (%s, %s)»
val = («Джон», «Шоссе 21»)
mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, «запись вставлена»)

Выполнить пример »

Важно!: Обратите внимание на оператор: mydb. commit() . Требуется сделать меняется, иначе нет вносятся изменения в таблицу.

Вставить несколько строк

Чтобы вставить несколько строк в таблицу, используйте код . метод executemany() .

Второй параметр метода executemany() представляет собой список кортежей, содержащих данные, которые вы хотите вставить:

Пример

Заполните таблицу «клиенты» данными:

импортировать mysql.connector

mydb = mysql.connector.connect(
  host=»localhost»,
пользователь = » ваше имя пользователя «,
  пароль = » ваш пароль «,
  database=»mydatabase»
)

mycursor = mydb.cursor()

sql = «ВСТАВИТЬ В клиентов (имя, адрес) ЗНАЧЕНИЯ (%s, %s)»
знач = [
 (‘Питер’, ‘Лоустрит 4’),
(«Эми», «Яблочная улица 652»),
 («Ханна», «Маунтин 21»),
(«Майкл», «Долина 345»),
 («Сэнди», «Океанский бульвар 2»),
(«Бетти», «Зеленая трава 1»),
 («Ричард», «Скай-стрит 331»),
(«Сьюзен», «В одну сторону 98»),
  («Вики», «Желтый сад 2»),
(«Бен», «Парк Лейн 38»),
 (‘Уильям’, ‘Центральная улица 954’),
(«Чак», «Главная дорога 989»),
  («Альт», «Обочина 1633»)
]

mycursor. executemany(sql, val)

mydb.commit()

print(mycursor.rowcount, «был вставлен»)

Пример запуска »

Get Inserted ID

Вы можете получить идентификатор строки, которую вы только что вставил, задав объект курсора.

Примечание: Если вы вставляете более одной строки, идентификатор последней вставленная строка возвращается.

Пример

Вставить одну строку и вернуть идентификатор:

импортировать mysql.connector

mydb = mysql.connector.connect(
  host=»localhost»,
user=» yourusername «,
  password=» yourpassword «,
  database=»mydatabase»
)

mycursor = mydb.cursor()

sql = «ВСТАВИТЬ В клиентов (имя, адрес) ЗНАЧЕНИЯ (%s, %s)»
val = («Мишель», «Голубая деревня»)
mycursor.execute(sql, val)

mydb.commit()

print(«1 запись вставлен, ID:», mycursor. lastrowid)

Пример выполнения »

❮ Предыдущий Далее ❯


НОВИНКА

Мы только что запустили
Видео W3Schools

Узнать

ВЫБОР ЦВЕТА
КОД ИГРЫ

Играть в игру

Top Tutorials
Учебник HTML
Учебник CSS
Учебник JavaScript
Учебник How To
Учебник SQL
Учебник Python
Учебник по W3.CSS
Учебник по Bootstrap
Учебник по PHP
Учебник по Java
Учебник по C++
Учебник по jQuery

Основные ссылки
HTML Reference
CSS Reference
JavaScript Reference
SQL Reference
Python Reference
W3.CSS Reference
Bootstrap Reference
PHP Reference
HTML Colors
Java Reference
Angular Reference
jQuery Reference


5 Top3 Examples Примеры HTML
Примеры CSS
Примеры JavaScript
Примеры инструкций
Примеры SQL
Примеры Python
Примеры W3. CSS
Примеры Bootstrap
Примеры PHP
Примеры Java
Примеры XML
Примеры jQuery

FORUM | О

W3Schools оптимизирован для обучения и обучения. Примеры могут быть упрощены для улучшения чтения и обучения. Учебники, ссылки и примеры постоянно пересматриваются, чтобы избежать ошибок, но мы не можем гарантировать полную правильность всего содержания. Используя W3Schools, вы соглашаетесь прочитать и принять наши условия использования, куки-файлы и политика конфиденциальности.

Copyright 1999-2022 Refsnes Data. Все права защищены.
W3Schools работает на основе W3.CSS.

Как перенести курсоры Mysql в dbt? — Справка

каннанкр

#1

Как перенести курсоры Mysql в Dbt?
поделиться некоторыми ссылками на миграцию

jeffsk

#2

Поделитесь, что делает курсор?
Вы мигрируете на новое хранилище (от MySQL)?
Какой тип базы данных является целью?

Если вам нужно перебирать строки, возможно, модель Python будет самым чистым способом.

В противном случае вы могли бы использовать макросы + хуки для создания процедур.

джоэллабес

#3

Один из архитекторов решений dbt работал над переносом курсоров в операторы dbt. Я не знаю, удалось ли ей еще или нет, хотя! Если она есть, я попрошу ее обновить.

Как правило, курсоры и хранимые процедуры не являются частью мышления dbt. В общем, вы должны попытаться решить, как выразить свои модели в виде простых операторов выбора, которые описывают то, как вы хотите, чтобы ваши данные были в конце, не беспокоясь о том, как именно они туда попадают.

В качестве примера у нас есть сообщение в блоге о переносе хранимых процедур — то, что изначально было огромным блоком кода с логикой upsert, поочередно поддерживалось горсткой четко определенных модулей, объединенных вместе. Это не сопоставление 1:1 с курсорами, но у него тот же мыслительный паттерн. Курсоры и циклы обычно отражают тот факт, что склад не может обработать все сразу — с современными инструментами это может быть менее верно.

Было бы полезно, если бы вы могли поделиться примером запроса, который вы пытаетесь преобразовать.

1 Нравится

каннан₽

#4

есть ли способ поделиться вами лично?

джоэллабес

#5

Лучше бы вы выложили пример (даже урезанный) публично — я сам не знаком с курсорами так что , вероятно, не сможет помочь (но я готов попробовать!), и было бы полезно всем, у кого есть опыт, увидеть, что вы пытаетесь сделать.

каннан

#6

 ИСПОЛЬЗОВАНИЕ [temp_Staging]
ИДТИ 
УСТАНОВИТЕ ANSI_NULLS ВКЛ.
ИДТИ
УСТАНОВИТЕ QUOTED_IDENTIFIER НА
ИДТИ
Процедура ALTER [Процесс].[Set_Fact]
в качестве
Начинать
Начать попытку
ОБЪЯВИТЬ @min int = 0,
 @макс интервал = 0,
@DID внутр.,
@columnlength целое число,  Выберите @columnlength = Max(len([scid])) из [xyz].[kbo].[ref_cus] как cx (без блокировки)
объявить @ref_cus TABLE(
[scid] varchar( 20 ) NOT NULL УНИКАЛЬНЫЙ КЛАСТЕРНЫЙ,
[CIDP] целое не NULL
)
Вставить в @ref_cus (scid, CIDP)
Выбирать
сх.
No related posts.