更改数据库ACC转MySQL的简单实现（acc转mysql）

更改数据库：ACC转MySQL的简单实现

在项目开发中，数据库是必不可少的一部分，而依据需求和技术选择适合的数据库也是十分重要的。虽然Access（ACC）是我们在初学数据库时接触到的比较多的开源数据库，但是随着业务的发展需求，很多公司已经开始使用MySQL等其他大型数据库。因此，今天我们来讲一讲如何将目前的ACC数据库转换成MySQL数据库。

对于ACC转MySQL的操作，我们一般需要考虑以下几个步骤：

## 步骤一：先在MySQL中创建原来ACC中的数据库

我们需要确保 MySQL 中有一个与 ACC 数据库相同的数据库。我们需要在 MySQL 中创建一个新的数据库，并使用相同名称的 ACC 数据库：

CREATE DATABASE dbname;

上述代码中的 “dbname” 是 ACC 数据库的名称，通过该命令我们就可以在 MySQL 中创建一个新的数据库。

## 步骤二：将ACC的表转换成MySQL格式

MySQL和ACC的表格格式并不相同，所以我们需要将原有的 ACC 表格转换成和 MySQL 相匹配的格式。我们在 MySQL 数据库中建立表格，必须确保表名、字段名称和数据类型等信息与 ACC 数据库中的相同。ACC偏好使用单一主键，而MySQL则偏好使用复合主键，所以我们需要确保在 MySQL 中我们将单一主键改为复合主键。

这条语句可以将原来 ACC 表格中的数据格式粘贴到新的 MySQL 表格中：

SELECT INTO newtable IN 'C:\Path\To\Database\NewDatabase.mdb'    
FROM oldtable IN 'C:\Path\To\Database\Table.mdb';

## 步骤三：将ACC数据表结构转换成MySQL数据表结构

ACC数据库和MySQL数据库的数据结构是不同的，因此我们需要在将ACC表格导入MySQL表格之前调整ACC表格的结构以与MySQL数据库兼容。我们可以通过下面的代码实现：

SELECT 'ALTER TABLE table(column) mysql_datatype' & ";" AS Expr1
INTO alteredqueries
FROM AccessQUERIES
WHERE (((AccessQUERIES.ColumnName)="column"))
GROUP BY table, MySQL_Datatype;

上面的这句话通过查询 AccessQUERIES 表，查询修改 ACC 表的语句，其中“table”代表的是表名，“column”代表的是字段名称。

## 步骤四：导入ACC数据到MySQL

在经过以上步骤后，我们已经能将 ACC 表格的结构与 MySQL 数据库相匹配，并且数据表也已经被转换成可以导入 MySQL 数据库的新格式了。为了将ACC数据导入到 MySQL，我们需要运行以下命令：

INSERT INTO newtable(column1,column2,…)
SELECT column1,column2,… FROM oldtable;

这条命令将 ACC 中的数据插入到新建的 MySQL 数据表中。

通过以上几个步骤，我们已经成功的将 ACC 数据库转换成了MySQL数据库。同时，我们也可以通过Code for Conversion来实现不同格式数据库之间的转换，代码如下：

“`python

# ACC to MySQL

import pyodbc

import mysql.connector as mySqlConnection

# Access Database Source

acc_database = r’C:\path\to\acc_database.accdb’

# MySQL Destination

my_database = mySqlConnection.connect(

host=”localhost”,

user=”yourusername”,

password=”yourpassword”,

database=”databasename”

)

my_cursor = my_database.cursor()

# Read Access Database Schema from pyodbc and Convert to MySQL Schema

src_cnxn_string = (

r”Driver={{Microsoft Access Driver (*.mdb, *.accdb)}};”

r”Dbq={db_path};”.format(db_path=acc_database)

)

with pyodbc.connect(src_cnxn_string) as src_conn:

# Read DSN Information

for row in src_conn.cursor().tables():

if row.table_type == “TABLE”:

print(row.table_name)

# Read Columns Information

columns = []

for col in src_conn.cursor().columns(table=row.table_name):

columns.append(col.column_name)

# Generate CREATE TABLE Statement

table_definition = “( ” + “, “.join([“`{}` TEXT”.format(column_name) for column_name in columns]) + ” )”

create_statement = “””CREATE TABLE `{table_name}` {table_definition};”””.format(table_name=row.table_name, table_definition=table_definition)

print(create_statement)

my_cursor.execute(create_statement)

# Generate INSERT INTO Statement

insert_statement = “””INSERT INTO `{table_name}` ( {columns} ) VALUES ( {value_placeholders} ) “””.format(

table_name=row.table_name,

columns=”, “.join([ “`{}`”.format(column_name) for column_name in columns ]),

value_placeholders=”, “.join([ “%({})s”.format(column_name) for column_name in columns ])

)

print(insert_statement)

src_cursor = src_conn.cursor()

src_cursor.execute(“””SELECT * FROM `{table_name}`”””.format(table_name=row.table_name))

rows = src_cursor.fetchall()

for row in rows:

row_dict = {}

for idx, col in enumerate(columns):

row_dict[col] = row[idx]

my_cursor.execute(insert_statement, row_dict)

my_database.commit()

“`

如果需要将其他格式的数据库（如Oracle、SQL Server、SQLite、PostgreSQL等）数据格式转换成MySQL格式，也可以通过修改Code for Conversion中读取和转换的代码，再运用以上几个步骤就可以实现格式转换了。

一旦我们决定将 ACC 数据库转换成 MySQL 数据库，就需要确保数据的完整性和正确性。对于一些复杂的数据库结构，我们可以借助专业的工具来实现转换。但是通过以上步骤转换会帮助我们更好的理解不同的数据库结构和数据类型。