def insert_into_mysql(phone_numbers, prefix, province, city):
    try:
        connection = get_db_connection()
        cursor = connection.cursor()
        
        data_to_insert = []
        for phone_number in phone_numbers:
            if len(phone_number) == 11:
                suffix = phone_number[-4:]
                data_to_insert.append((prefix, suffix, phone_number, province, city))
        
        cursor.executemany(INSERT_QUERY, data_to_insert)
        connection.commit()
        return True
    
    except Exception as e:
        print(f"插入數(shù)據(jù)失敗: {e}")
        if connection:
            connection.rollback()
        return False
    
    finally:
        if cursor:
            cursor.close()
        if connection:
            connection.close()

def insert_into_mysql(phone_numbers, prefix, province, city, url=None):
    connection = None
    cursor = None
    try:
        connection = get_db_connection()
        if not connection:
            print("數(shù)據(jù)庫連接失敗")
            return False

        cursor = connection.cursor()
        data_to_insert = []
        
        for phone_number in phone_numbers:
            if len(phone_number) == 11:
                suffix = phone_number[-4:]
                data_to_insert.append((prefix, suffix, phone_number, province, city))

        if not data_to_insert:
            print("警告: 沒有有效的手機號可插入")
            return False

        cursor.executemany(INSERT_QUERY, data_to_insert)
        connection.commit()
        print(f"成功插入 {len(data_to_insert)} 條數(shù)據(jù)")
        return True

    except Exception as e:
        print(f"插入數(shù)據(jù)失敗: {e}")
        if connection:
            connection.rollback()
        
        # 檢查是否是唯一鍵沖突
        if "Duplicate entry" in str(e):
            if url:  # 確保url有效
                update_is_deal(url, province, city)  # 執(zhí)行額外邏輯
        
        return False
    
    finally:
        if cursor:
            cursor.close()
        if connection:
            connection.close()

import java.sql.*;
import java.util.List;

public class PhoneNumberDao {
    private static final String INSERT_QUERY = 
        "INSERT INTO phone_numbers (prefix, suffix, phone_number, province, city) " +
        "VALUES (?, ?, ?, ?, ?)";

    public boolean insertIntoMysql(List<String> phoneNumbers, String prefix, 
                                  String province, String city, String url) {
        Connection connection = null;
        PreparedStatement statement = null;
        
        try {
            connection = DatabaseUtil.getConnection(); // 獲取數(shù)據(jù)庫連接
            connection.setAutoCommit(false); // 開啟事務(wù)
            
            statement = connection.prepareStatement(INSERT_QUERY);
            
            for (String phoneNumber : phoneNumbers) {
                if (phoneNumber.length() == 11) {
                    String suffix = phoneNumber.substring(7); // 后4位
                    statement.setString(1, prefix);
                    statement.setString(2, suffix);
                    statement.setString(3, phoneNumber);
                    statement.setString(4, province);
                    statement.setString(5, city);
                    statement.addBatch(); // 加入批處理
                }
            }
            
            statement.executeBatch(); // 執(zhí)行批處理
            connection.commit(); // 提交事務(wù)
            return true;
            
        } catch (SQLIntegrityConstraintViolationException e) {
            // 捕獲唯一鍵沖突異常
            System.err.println("插入數(shù)據(jù)失?。ㄎㄒ绘I沖突）: " + e.getMessage());
            if (connection != null) {
                try {
                    connection.rollback(); // 回滾事務(wù)
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            
            if (url != null) {
                updateIsDeal(url, province, city); // 執(zhí)行額外邏輯
            }
            return false;
            
        } catch (SQLException e) {
            System.err.println("插入數(shù)據(jù)失敗: " + e.getMessage());
            if (connection != null) {
                try {
                    connection.rollback();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            return false;
            
        } finally {
            // 關(guān)閉資源
            try {
                if (statement != null) statement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    private void updateIsDeal(String url, String province, String city) {
        // 實現(xiàn)更新邏輯
        System.out.println("檢測到重復(fù)數(shù)據(jù)，更新狀態(tài): " + url);
    }
}