0

我正在学习使用从 mysql.org 网站下载的 MySQL Connector/Python 库来访问 MySQL 数据库。我的环境是 OS X 10.6、带有 PyDev 的 Eclipse Indigo，以及新安装的 MySql（5.5.28，64 位）、Sequel Pro 和 phpMyAdmin 版本。

我的测试数据库有一个表“Employees”，其中包含“id”、“name”和“ssn”列。最初，有两行：(1, Lucy, 1234) 和 (2, Alex, 3456)。

这是 Python 脚本。变量“config”包含数据库的有效访问信息。

import mysql.connector
from mysql.connector import errorcode

config = {…}

try:
    cnx = mysql.connector.connect(**config)
except mysql.connector.Error as err:
    if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
        print("Something is wrong your username or password")
    elif err.errno == errorcode.ER_BAD_DB_ERROR:
        print("Database does not exist")
    else:
        print(err)
else:
    print ("original database contents")

    cursor = cnx.cursor()
    query = ("SELECT name, ssn FROM Employees")  # fetches all employees names and ssns
    cursor.execute(query)
    for (name, ssn) in cursor:  # iterates over fetched data
        print(name, ssn)  # print one employee per line
    cursor.close;

    # block 1: insert a new employee into row 3
    cursor = cnx.cursor()
    cursor.execute("INSERT INTO Employees (id, name, ssn) VALUES (3, 'Sam', '5678')")
    cnx.commit()
    cursor.close()

    # block 2: update the name in the first row
    cursor = cnx.cursor()
    cursor.execute("UPDATE Employees SET name='Ethel' WHERE id=1")
    cnx.commit;
    cursor.close()

    print ("after inserting Sam and updating Lucy to Ethel")

    cursor = cnx.cursor()
    query = ("SELECT name, ssn FROM Employees")  # fetches all employees' names and ssns
    cursor.execute(query)
    for (name, ssn) in cursor:  # iterates over fetched data
        print(name, ssn)  # print one employee per line
    cursor.close;

cnx.close()

print ("end of database test")

使用插入在初始数据库上运行 Python 脚本，然后更新产生：

original database contents
(u'Lucy', u'1234')
(u'Alex', u'3456')
after inserting Sam and updating Lucy to Ethel
(u'Ethel', u'1234')
(u'Alex', u'3456')
(u'Sam', u'5678')
end of database test

使用 phpMyAdmin 或 Sequel Pro 查看数据库仍然会在第 1 行显示“Lucy”作为名称。

在初始数据库上运行 Python 脚本并进行更新，然后插入（颠倒脚本中块 1 和块 2 的顺序）产生：

original database contents
(u'Lucy', u'1234')
(u'Alex', u'3456')
after inserting Sam and updating Lucy to Ethel
(u'Ethel', u'1234')
(u'Alex', u'3456')
(u'Sam', u'5678')
end of database test

使用 phpMyAdmin 或 Sequel Pro 查看数据库现在显示“Ethel”作为第 1 行中的名称。

从 Sequel Pro 中打开的初始数据库开始，我可以按任意顺序执行这两个查询并获得正确的结果。

似乎与提交对数据库的更改有关的事情出错了，但作为一个新手，我没有看到它。我会很感激诊断这个问题的帮助。

4

1 回答 1

4

您需要调用commit 方法将您的更改提交到数据库，否则事务永远不会保存，其他连接也不会看到更改。

cnx.commit()

您省略了()代码中的括号。

您还可以cursor.close在多个位置引用该方法而不调用它；并不像 Python 会通过垃圾收集自动清理它们那么重要。

于 2012-11-21T16:51:32.357 回答