SQL学习小记（三）

功能实现
- 思路
- 代码
- 部分名词解释
代码打包为可执行文件

功能说明：使用python代码，将数据库database1中的表格table1同步到数据库database2中

功能实现

思路

假设 database1 和 database2的信息分别为：

	IP地址	端口号	用户名	密码	数据库名
database1	10.10.0.0	7890	root1	123456	database1
database2	10.10.0.1	7891	root2	123456	database2

代码

import schedule
import time
from datetime import datetime, timedelta
import sqlite3
import pymysql
# 数据库连接
def mysql_link(host, port, user, password, db):
    try:
        db = pymysql.connect(host=host,  # IP地址
                             port=port,  # 端口号
                             user=user,  # 用户名
                             password=password,  # 密码
                             db=db,  # 数据库名
                             charset='utf8')# 文本数据编码方式
        return db		#返回数据库
    except:
        print("could not connect to mysql server") # 没有连接到数据库
# 数据库更新
def update_database():
    # 连接到数据库
    # 更新数据库table1
    # conn_a和cursor_b 为数据库对象
    conn_a = mysql_link("10.10.0.0", 7890, "root1", "123456", "database1")  # database1数据库
    cursor_a = conn_a.cursor()	# cursor_a的游标
    conn_b = mysql_link("10.10.0.1", 7891, "root2", "123456", "database2")  # database2数据库
    cursor_b = conn_b.cursor()  # cursor_b的游标
    # 判断表是否存在
    table_name = 'table1'
    conn_b_db = 'database2'
    query = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = %s AND TABLE_NAME = %s"
    cursor_b.execute(query, (conn_b_db, table_name))	# 在数据库conn_b_db的表table_name中查询query
    existing_table = cursor_b.fetchone()	# 查询结果中提取下一行数据
    if existing_table:
        print(f"Table '{table_name}' already exists.")
    else:
        # 不存在时创建表结构
        cursor_b.execute("CREATE TABLE table1("
                         "id varchar(32) PRIMARY KEY, name longtext , old longtext, year longtext, "
                         "sex longtext, score longtext, score2 longtext, score3 longtext,total_points longtext)")
        # 提交更改
        conn_b.commit()
        print(f"Table '{table_name}' created.")
    cursor_a.execute("SELECT * FROM table1")
    cursor_b.execute("SELECT * FROM table1")
    result = cursor_b.fetchone()
    if result:
        cursor_b.execute("TRUNCATE TABLE table1")	# 清空表
    rows = cursor_a.fetchall()
    for row in rows:
        cursor_b.execute("INSERT INTO table1VALUES (%s, %s, %s,%s,%s,%s, %s,%s,%s) ", row)
    conn_b.commit() 	# 提交更改
    conn_b.close()		# 关闭数据库
    conn_a.close()
if __name__ == '__main__':
    update_database()	# 数据库更新

部分名词解释

数据库游标（cursor）是用来在数据库连接上执行SQL查询和操作的对象。当建立了数据库连接之后，可以使用游标来执行各种数据库操作，如查询数据、插入数据、更新数据和删除数据。
游标本质上是一个指针，它指向数据库中的某个位置，可以遍历查询结果集中的各行数据。通过游标，可以执行SQL语句，检索并处理查询结果，以及提交更改到数据库中。