RussianLDP Рейтинг@Mail.ru
WebMoney: 
WMZ Z294115950220 
WMR R409981405661 
WME E134003968233 
Visa 
4274 3200 2453 6495 

Глава 6. Обучающие программы Connector/Python

Эти обучающие программы иллюстрируют, как разработать приложения Python и скрипты, которые соединяются сервером базы данных MySQL с использованием MySQL Connector/Python.

6.1. Поднимите зарплату сотрудника, используя буферизированный курсор

Следующий скрипт в качестве примера дает 15% подъем с завтрашнего дня всем сотрудникам, которые наняты в 2000 году и все еще работают.

Чтобы повторить для отобранных сотрудников, мы используем буферизованные курсоры. Буферизированный курсор получает и буферизует строки набора результатов после выполнения запроса, посмотрите раздел 10.6.1 . Этот путь не обязательно получит строки в новые переменные. Вместо этого курсор может использоваться в качестве итератора.

Этот скрипт пример, есть другие способы сделать эту простую задачу.

from __future__ import print_function
from decimal import Decimal
from datetime import datetime, date, timedelta

import mysql.connector
# Connect with the MySQL Server
cnx = mysql.connector.connect(user='scott', database='employees')

# Get two buffered cursors
curA = cnx.cursor(buffered=True)
curB = cnx.cursor(buffered=True)

# Query to get employees who joined in a period defined by two dates
query = (
  "SELECT s.emp_no, salary, from_date, to_date FROM employees AS e "
  "LEFT JOIN salaries AS s USING (emp_no) "
  "WHERE to_date = DATE('9999-01-01')"
  "AND e.hire_date BETWEEN DATE(%s) AND DATE(%s)")

# UPDATE and INSERT statements for the old and new salary
update_old_salary = (
  "UPDATE salaries SET to_date = %s "
  "WHERE emp_no = %s AND from_date = %s")
  insert_new_salary = (
  "INSERT INTO salaries (emp_no, from_date, to_date, salary) "
  "VALUES (%s, %s, %s, %s)")

# Select the employees getting a raise
curA.execute(query, (date(2000, 1, 1), date(2000, 12, 31)))
# Iterate through the result of curA
for (emp_no, salary, from_date, to_date) in curA:
  # Update the old and insert the new salary
  new_salary = int(round(salary * Decimal('1.15')))
  curB.execute(update_old_salary, (tomorrow, emp_no, from_date))
  curB.execute(insert_new_salary,
               (emp_no, tomorrow, date(9999, 1, 1,), new_salary))
# Commit the changes
cnx.commit()
cnx.close()

Поиск

 

Найди своих коллег!

Вы можете направить письмо администратору этой странички, Алексею Паутову. mailto:alexey.v.pautov@mail.ru