mysql 查询数据循环插入数据-CFANZ编程社区

实现“mysql 查询数据循环插入数据”流程

概述

在mysql数据库开发中，有时候我们需要将一个表中的数据插入到另一个表中，而且需要循环遍历源表的每一行数据，然后逐行插入到目标表中。本文将介绍如何使用代码实现这个过程，并提供相应的示例代码以及注释。

流程图

flowchart TD
    开始 --> 连接数据库
    连接数据库 --> 执行查询语句
    执行查询语句 --> 获取查询结果
    获取查询结果 --> 循环遍历结果
    循环遍历结果 --> 插入数据
    插入数据 --> 结束

详细步骤

1. 连接数据库

首先，我们需要通过代码连接到mysql数据库。这可以使用mysql的官方驱动程序或第三方库来实现。以下是使用mysql官方驱动程序的示例代码：

import mysql.connector

# 建立数据库连接
cnx = mysql.connector.connect(user='username', password='password',
                              host='localhost', database='database_name')

请将username、password和database_name替换为实际的数据库用户名、密码和数据库名称。

2. 执行查询语句

接下来，我们需要执行一个查询语句来获取源表中的数据。以下是一个示例查询语句：

query = "SELECT * FROM source_table"
cursor = cnx.cursor()
cursor.execute(query)

请将source_table替换为实际的源表名称。

3. 获取查询结果

执行查询语句后，我们可以通过fetchall()方法获取查询结果。以下是一个示例代码：

results = cursor.fetchall()

4. 循环遍历结果并插入数据

接下来，我们需要遍历查询结果并将每一行数据插入到目标表中。以下是一个示例代码：

insert_query = "INSERT INTO target_table (column1, column2, column3) VALUES (%s, %s, %s)"
for row in results:
    data = (row[0], row[1], row[2])  # 替换为实际的列名和数据
    cursor.execute(insert_query, data)
    cnx.commit()

请将target_table替换为实际的目标表名称，column1、column2、column3替换为实际的列名，并根据需要修改插入的数据。

5. 关闭数据库连接

完成插入操作后，我们需要关闭数据库连接。以下是一个示例代码：

cursor.close()
cnx.close()

类图

classDiagram
    class Developer {
        - name: string
        - experience: int
        + teachNewbie(): void
    }
    class Newbie {
        - name: string
        - learningProgress: int
        + learnFrom(developer: Developer): void
    }
    Developer --> Newbie