<?php
// 数据库配置
$host = '127.0.0.1';
$dbname = 'mss_nahaichuan_c';
$username = 'mss_nahaichuan_c';
$password = 'MyNmyAaRj9yWKPKH';

try {
    // 连接数据库
    $pdo = new PDO("mysql:host=$host;dbname=$dbname;charset=utf8", $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    
    echo "数据库连接成功！\n";
    
    // 读取SQL文件
    $sqlFile = 'import_alcohol_goods_data_fixed.sql';
    if (!file_exists($sqlFile)) {
        throw new Exception("SQL文件不存在: $sqlFile");
    }
    
    $sql = file_get_contents($sqlFile);
    
    // 移除注释行
    $lines = explode("\n", $sql);
    $cleanedLines = array_filter($lines, function($line) {
        $line = trim($line);
        return !empty($line) && substr($line, 0, 2) !== '--';
    });
    $cleanedSql = implode("\n", $cleanedLines);
    
    // 分割SQL语句
    $statements = array_filter(explode(';', $cleanedSql), function($stmt) {
        return !empty(trim($stmt));
    });
    
    $successCount = 0;
    $errorCount = 0;
    
    foreach ($statements as $statement) {
        $statement = trim($statement);
        if (empty($statement)) {
            continue;
        }
        
        echo "准备执行: " . substr($statement, 0, 50) . "...\n";
        
        try {
            if (stripos($statement, 'SELECT') === 0) {
                // 对于SELECT语句，使用query并获取结果
                $result = $pdo->query($statement);
                if ($result) {
                    $data = $result->fetchAll(PDO::FETCH_ASSOC);
                    $result->closeCursor();
                    echo "查询成功，返回 " . count($data) . " 行数据\n";
                    if (!empty($data)) {
                        foreach ($data as $row) {
                            echo implode(' | ', $row) . "\n";
                        }
                    }
                }
            } else {
                // 对于INSERT、UPDATE、DELETE等语句，使用exec
                $affectedRows = $pdo->exec($statement);
                echo "执行成功，影响 $affectedRows 行: " . substr($statement, 0, 50) . "...\n";
            }
            $successCount++;
        } catch (PDOException $e) {
            $errorCount++;
            echo "执行失败: " . $e->getMessage() . "\n";
            echo "SQL: " . substr($statement, 0, 100) . "...\n";
        }
    }
    
    echo "\n导入完成！\n";
    echo "成功执行: $successCount 条语句\n";
    echo "执行失败: $errorCount 条语句\n";
    
} catch (Exception $e) {
    echo "错误: " . $e->getMessage() . "\n";
}
?>