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

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

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

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

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

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

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

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

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

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

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'
    }
)

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