mysql.connector和python的案例
时间: 2024-01-16 13:40:57 浏览: 33
以下是一个使用mysql.connector和Python的简单案例,该案例连接到MySQL数据库并执行一些查询和插入操作:
```python
import mysql.connector
# 连接到MySQL数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="mydatabase"
)
# 创建一个查询游标
mycursor = mydb.cursor()
# 执行一个查询语句
mycursor.execute("SELECT * FROM customers")
# 获取查询结果
myresult = mycursor.fetchall()
# 打印查询结果
for x in myresult:
print(x)
# 插入一条新记录
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)
# 提交更改
mydb.commit()
# 打印新记录的ID
print("1 条记录已插入,ID:", mycursor.lastrowid)
```
这个案例连接到本地MySQL服务器,并查询名为“customers”的表,然后打印结果。然后,它插入一条新记录并提交更改。最后,它打印新记录的ID。
相关问题
python mysql 传入变量案例
下面是一个 Python 使用 MySQL 的传入变量的示例:
```
import mysql.connector
# 建立数据库连接
conn = mysql.connector.connect(user='user', password='password', host='host', database='database')
# 创建游标对象
cursor = conn.cursor()
# 定义变量
user_id = 1
# 使用变量作为查询参数
query = "SELECT * FROM users WHERE id=%s"
cursor.execute(query, (user_id,))
# 获取查询结果
result = cursor.fetchone()
# 打印结果
print(result)
# 关闭游标和连接
cursor.close()
conn.close()
```
在这个例子中,我们首先使用 `mysql.connector` 库连接到数据库,然后创建了一个游标对象。然后我们定义了一个变量 `user_id` 并使用它作为查询的参数。最后,我们执行了查询并获取结果,并将结果打印出来。
用python写一个postgre传数据到mysql的案例
首先需要安装相应的Python库:`psycopg2`和`mysql-connector-python`。
然后,可以按照以下步骤将PostgreSQL中的数据传输到MySQL中:
1. 连接到PostgreSQL数据库。
```python
import psycopg2
# 连接到PostgreSQL数据库
conn_pg = psycopg2.connect(
host="localhost",
database="mydb",
user="myuser",
password="mypassword"
)
```
2. 从PostgreSQL中选择要传输的数据。
```python
# 从PostgreSQL中选择要传输的数据
cur_pg = conn_pg.cursor()
cur_pg.execute("SELECT * FROM mytable")
data = cur_pg.fetchall()
```
3. 连接到MySQL数据库。
```python
import mysql.connector
# 连接到MySQL数据库
conn_mysql = mysql.connector.connect(
host="localhost",
user="myuser",
password="mypassword",
database="mydb"
)
```
4. 将数据插入到MySQL中。
```python
# 将数据插入到MySQL中
cur_mysql = conn_mysql.cursor()
for row in data:
cur_mysql.execute("INSERT INTO mytable VALUES (%s, %s, %s)", row)
conn_mysql.commit()
# 关闭连接
cur_pg.close()
cur_mysql.close()
conn_pg.close()
conn_mysql.close()
```
完整代码示例:
```python
import psycopg2
import mysql.connector
# 连接到PostgreSQL数据库
conn_pg = psycopg2.connect(
host="localhost",
database="mydb",
user="myuser",
password="mypassword"
)
# 从PostgreSQL中选择要传输的数据
cur_pg = conn_pg.cursor()
cur_pg.execute("SELECT * FROM mytable")
data = cur_pg.fetchall()
# 连接到MySQL数据库
conn_mysql = mysql.connector.connect(
host="localhost",
user="myuser",
password="mypassword",
database="mydb"
)
# 将数据插入到MySQL中
cur_mysql = conn_mysql.cursor()
for row in data:
cur_mysql.execute("INSERT INTO mytable VALUES (%s, %s, %s)", row)
conn_mysql.commit()
# 关闭连接
cur_pg.close()
cur_mysql.close()
conn_pg.close()
conn_mysql.close()
```