Mysql

关注公众号 jb51net

关闭
首页 > 数据库 > Mysql > SQLite转换MySQL数据库

PbootCMS的SQLite数据库转换为MySQL数据库几种方法步骤

作者:weixin_54645949

随着业务的发展,数据从一个系统迁移到另一个系统是一个常见的需求,这篇文章主要介绍了PbootCMS的SQLite数据库转换为MySQL数据库几种方法步骤,文中通过代码介绍的非常详细,需要的朋友可以参考下

将 PbootCMS 的 SQLite 数据库转换为 MySQL 数据库,可以按照以下步骤操作:

方法一:使用第三方工具转换(推荐)

1. 准备工作

2. 使用数据库管理工具

Navicat Premium(最方便):

  1. 连接 SQLite 数据库
  2. 连接 MySQL 数据库
  3. 使用"数据传输"功能,直接将 SQLite 数据库迁移到 MySQL
  4. 注意调整数据类型映射

DBeaver(免费):

  1. 同时连接 SQLite 和 MySQL
  2. 右键 SQLite 数据库 → 工具 → 导出数据
  3. 选择目标为 MySQL 数据库
  4. 调整字段类型映射

3. 使用在线转换工具

https://www.rebasedata.com/convert-sqlite-to-mysql-online

上传 SQLite 文件,下载 MySQL 格式的 SQL 文件。

方法二:手动转换步骤

1. 导出 SQLite 结构

-- 使用 SQLite 命令行工具
sqlite3 yourdb.db

-- 导出表结构
.output schema.sql
.schema
.output stdout

2. 修改 SQL 语句适应 MySQL

需要修改的内容:

数据类型转换

-- SQLite 格式
CREATE TABLE pboot_content (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    ...
);

-- 改为 MySQL 格式
CREATE TABLE pboot_content (
    id INT PRIMARY KEY AUTO_INCREMENT,
    ...
);

常见类型映射

移除 SQLite 特定语法

3. 导出数据

-- 导出数据为 INSERT 语句
.mode insert
.output data.sql
SELECT * FROM table1;
SELECT * FROM table2;
...
.quit

4. 导入 MySQL

# 导入表结构
mysql -u username -p database_name < schema_mysql.sql

# 导入数据
mysql -u username -p database_name < data.sql

方法三:使用 PHP 脚本转换

<?php
// SQLite 转 MySQL 转换脚本
class SqliteToMysqlConverter {
    private $sqliteDb;
    private $mysqlDb;
    
    public function __construct($sqliteFile, $mysqlConfig) {
        // 连接 SQLite
        $this->sqliteDb = new SQLite3($sqliteFile);
        
        // 连接 MySQL
        $this->mysqlDb = new mysqli(
            $mysqlConfig['host'],
            $mysqlConfig['username'],
            $mysqlConfig['password'],
            $mysqlConfig['database']
        );
    }
    
    public function convert() {
        // 获取所有表
        $tables = $this->getTables();
        
        foreach ($tables as $table) {
            // 转换表结构
            $this->convertTableStructure($table);
            
            // 转换数据
            $this->convertTableData($table);
        }
    }
    
    private function getTables() {
        $result = $this->sqliteDb->query(
            "SELECT name FROM sqlite_master WHERE type='table' AND name NOT LIKE 'sqlite_%'"
        );
        
        $tables = [];
        while ($row = $result->fetchArray(SQLITE3_ASSOC)) {
            $tables[] = $row['name'];
        }
        return $tables;
    }
    
    private function convertTableStructure($tableName) {
        // 获取 SQLite 表结构
        $result = $this->sqliteDb->query("SELECT sql FROM sqlite_master WHERE type='table' AND name='$tableName'");
        $row = $result->fetchArray(SQLITE3_ASSOC);
        $sqliteSchema = $row['sql'];
        
        // 转换为 MySQL 语法
        $mysqlSchema = $this->convertSchema($sqliteSchema);
        
        // 在 MySQL 中创建表
        $this->mysqlDb->query($mysqlSchema);
    }
    
    private function convertSchema($sqliteSchema) {
        // 简单的类型转换
        $conversions = [
            '/INTEGER\s+PRIMARY\s+KEY\s+AUTOINCREMENT/i' => 'INT PRIMARY KEY AUTO_INCREMENT',
            '/AUTOINCREMENT/i' => 'AUTO_INCREMENT',
            '/INTEGER/i' => 'INT',
            '/TEXT/i' => 'TEXT',
            '/BLOB/i' => 'LONGBLOB',
            '/REAL/i' => 'FLOAT',
            '/NUMERIC/i' => 'DECIMAL(10,2)',
            '/\"/' => '`'  // 替换引号
        ];
        
        $mysqlSchema = $sqliteSchema;
        foreach ($conversions as $pattern => $replacement) {
            $mysqlSchema = preg_replace($pattern, $replacement, $mysqlSchema);
        }
        
        return $mysqlSchema;
    }
    
    private function convertTableData($tableName) {
        $result = $this->sqliteDb->query("SELECT * FROM $tableName");
        
        while ($row = $result->fetchArray(SQLITE3_ASSOC)) {
            $columns = array_keys($row);
            $values = array_values($row);
            
            // 转义值
            $escapedValues = array_map(function($value) {
                return $this->mysqlDb->real_escape_string($value);
            }, $values);
            
            $columnsStr = '`' . implode('`, `', $columns) . '`';
            $valuesStr = "'" . implode("', '", $escapedValues) . "'";
            
            $sql = "INSERT INTO $tableName ($columnsStr) VALUES ($valuesStr)";
            $this->mysqlDb->query($sql);
        }
    }
}

// 使用示例
$converter = new SqliteToMysqlConverter(
    '/path/to/your.db',
    [
        'host' => 'localhost',
        'username' => 'root',
        'password' => 'password',
        'database' => 'pbootcms'
    ]
);

$converter->convert();
?>

方法四:使用 Python 脚本

import sqlite3
import pymysql
import re

def convert_type(sqlite_type):
    """转换数据类型"""
    type_mapping = {
        'INTEGER': 'INT',
        'TEXT': 'TEXT',
        'BLOB': 'LONGBLOB',
        'REAL': 'FLOAT',
        'NUMERIC': 'DECIMAL(10,2)'
    }
    
    for key, value in type_mapping.items():
        if key in sqlite_type.upper():
            return value
    return 'TEXT'

def convert_schema(sqlite_schema):
    """转换表结构"""
    # 替换 AUTOINCREMENT
    mysql_schema = sqlite_schema.replace('AUTOINCREMENT', 'AUTO_INCREMENT')
    
    # 替换引号
    mysql_schema = re.sub(r'\"(\w+)\"', r'`\1`', mysql_schema)
    
    return mysql_schema

def convert_database(sqlite_path, mysql_config):
    # 连接 SQLite
    sqlite_conn = sqlite3.connect(sqlite_path)
    sqlite_cursor = sqlite_conn.cursor()
    
    # 连接 MySQL
    mysql_conn = pymysql.connect(**mysql_config)
    mysql_cursor = mysql_conn.cursor()
    
    # 获取所有表
    sqlite_cursor.execute(
        "SELECT name FROM sqlite_master WHERE type='table' AND name NOT LIKE 'sqlite_%'"
    )
    tables = sqlite_cursor.fetchall()
    
    for table in tables:
        table_name = table[0]
        print(f"转换表: {table_name}")
        
        # 获取表结构
        sqlite_cursor.execute(
            f"SELECT sql FROM sqlite_master WHERE type='table' AND name='{table_name}'"
        )
        schema = sqlite_cursor.fetchone()[0]
        
        # 转换并创建表
        mysql_schema = convert_schema(schema)
        mysql_cursor.execute(f"DROP TABLE IF EXISTS {table_name}")
        mysql_cursor.execute(mysql_schema)
        
        # 迁移数据
        sqlite_cursor.execute(f"SELECT * FROM {table_name}")
        rows = sqlite_cursor.fetchall()
        
        if rows:
            # 获取列名
            sqlite_cursor.execute(f"PRAGMA table_info({table_name})")
            columns = [col[1] for col in sqlite_cursor.fetchall()]
            
            # 插入数据
            placeholders = ', '.join(['%s'] * len(columns))
            columns_str = '`' + '`, `'.join(columns) + '`'
            
            insert_sql = f"INSERT INTO {table_name} ({columns_str}) VALUES ({placeholders})"
            mysql_cursor.executemany(insert_sql, rows)
    
    mysql_conn.commit()
    
    # 关闭连接
    sqlite_conn.close()
    mysql_conn.close()

# 使用
convert_database(
    'yourdb.db',
    {
        'host': 'localhost',
        'user': 'root',
        'password': 'password',
        'database': 'pbootcms',
        'charset': 'utf8mb4'
    }
)

重要注意事项

  1. 备份数据:转换前务必备份 SQLite 和 MySQL 数据

  2. 字符编码:确保 MySQL 使用 utf8mb4 字符集

  3. 索引和外键:检查并重新创建索引

  4. 特殊字段

    • PbootCMS 的 content 表的 content 字段可能包含大量文本
    • 日期时间字段可能需要格式转换
  5. 修改配置文件
    转换完成后,修改 PbootCMS 的数据库配置:

// config/database.php
return array(
    'database' => array(
        'type' => 'mysql',  // 改为 mysql
        'host' => 'localhost',
        'user' => 'your_mysql_user',
        'passwd' => 'your_mysql_password',
        'port' => '3306',
        'dbname' => 'pbootcms'
    )
);
  1. 测试验证

建议使用 Navicat PremiumDBeaver 进行转换,这些工具自动化程度高,可以处理大多数兼容性问题。如果数据量不大,手动转换也可以确保最佳的控制精度。

总结

到此这篇关于PbootCMS的SQLite数据库转换为MySQL数据库几种方法步骤的文章就介绍到这了,更多相关SQLite转换MySQL数据库内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文