python将数据一条条插入数据库

可以使用Python中的MySQLdb模块来将数据一条条插入数据库，具体代码如下：

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()

这段代码可以将一条记录插入名为EMPLOYEE的表中，包括FIRST_NAME、LAST_NAME、AGE、SEX和INCOME字段。

相关问题

python向数据库每隔5分钟插入一条数据

Python可以使用第三方库如`pymysql`或`sqlite3`连接到数据库，并使用定时任务来每隔5分钟插入一条数据。以下是一个示例代码：

import pymysql
import time

# 连接到数据库
conn = pymysql.connect(
    host='localhost',
    user='root',
    password='password',
    database='testdb'
)

# 创建游标
cursor = conn.cursor()

def insert_data():
    # 获取当前时间
    current_time = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())
    
    # 构造插入数据的SQL语句
    sql = "INSERT INTO mytable (timestamp, value) VALUES (%s, %s)"
    
    try:
        # 执行插入数据的SQL语句
        cursor.execute(sql, (current_time, 'data_value'))
        conn.commit()
        print("数据插入成功！")
    except Exception as e:
        conn.rollback()
        print("数据插入失败：", e)

# 每隔5分钟执行一次插入数据的操作
while True:
    insert_data()
    time.sleep(300)  # 5分钟

上述代码中，我们首先使用`pymysql`库连接到数据库，并创建了一个游标。然后定义了一个`insert_data`函数，在函数中获取当前时间，并构造插入数据的SQL语句。使用`cursor.execute`方法执行SQL语句，并使用`conn.commit`提交事务。若插入数据过程中出现异常，可使用`conn.rollback`回滚事务。最后，使用一个无限循环和`time.sleep`函数来设置每隔5分钟执行一次插入数据的操作。请将代码中的相关参数（如数据库连接信息、表名、字段名等）根据实际情况进行修改。

flask将数据一条条插入数据库

在Flask中，可以使用SQLAlchemy来操作数据库。以下是一个简单的示例，演示如何将数据一条条插入数据库：

1. 首先，需要安装SQLAlchemy库。可以使用以下命令：

pip install sqlalchemy

2. 在Flask应用程序中，需要导入SQLAlchemy库和相关模块：

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

3. 创建Flask应用程序和SQLAlchemy实例：

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///test.db'
db = SQLAlchemy(app)

4. 创建一个模型类来表示数据库中的表：

class User(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(50))
    email = db.Column(db.String(50))

5. 在视图函数中，可以使用以下代码将数据一条条插入数据库：

@app.route('/add_user')
def add_user():
    user1 = User(name='John', email='john@example.com')
    user2 = User(name='Jane', email='jane@example.com')
    db.session.add(user1)
    db.session.add(user2)
    db.session.commit()
    return 'Users added to database'

在上面的代码中，首先创建了两个User对象，然后使用db.session.add()方法将它们添加到会话中，最后使用db.session.commit()方法提交会话，将数据插入数据库。

注意，这只是一个简单的示例，实际应用中可能需要更复杂的逻辑来插入数据。另外，还需要处理异常和错误情况，以确保数据插入成功。