在处理百万级CSV文件记录时，Go语言提供了高效的读取和数据库操作方式。以下是一个完整的示例，展示如何正确读取大型CSV文件并批量插入MySQL数据库，避免空指针异常。

package main

import (
    "database/sql"
    "encoding/csv"
    "fmt"
    "log"
    "os"
    "strconv"

    _ "github.com/go-sql-driver/mysql"
)

type Record struct {
    ID    int
    Name  string
    Email string
    Age   int
}

func main() {
    // 打开CSV文件
    file, err := os.Open("data.csv")
    if err != nil {
        log.Fatal("无法打开CSV文件:", err)
    }
    defer file.Close()

    // 创建CSV阅读器
    reader := csv.NewReader(file)
    
    // 可选：设置读取限制，对于大型文件
    reader.FieldsPerRecord = -1 // 允许可变字段数
    
    // 读取所有记录
    records, err := reader.ReadAll()
    if err != nil {
        log.Fatal("读取CSV记录失败:", err)
    }

    fmt.Printf("成功读取 %d 条记录\n", len(records))

    // 连接MySQL数据库
    db, err := sql.Open("mysql", "username:password@tcp(localhost:3306)/database")
    if err != nil {
        log.Fatal("数据库连接失败:", err)
    }
    defer db.Close()

    // 验证数据库连接
    err = db.Ping()
    if err != nil {
        log.Fatal("数据库连接验证失败:", err)
    }

    // 批量插入记录（每次1000条）
    batchSize := 1000
    for i := 1; i < len(records); i += batchSize {
        end := i + batchSize
        if end > len(records) {
            end = len(records)
        }

        batch := records[i:end]
        err := insertBatch(db, batch)
        if err != nil {
            log.Printf("批量插入失败 (记录 %d-%d): %v", i, end-1, err)
        } else {
            fmt.Printf("成功插入记录 %d-%d\n", i, end-1)
        }
    }
}

func insertBatch(db *sql.DB, records [][]string) error {
    // 开始事务
    tx, err := db.Begin()
    if err != nil {
        return err
    }

    // 准备插入语句
    stmt, err := tx.Prepare("INSERT INTO users (id, name, email, age) VALUES (?, ?, ?, ?)")
    if err != nil {
        tx.Rollback()
        return err
    }
    defer stmt.Close()

    // 遍历记录并插入
    for _, record := range records {
        // 数据验证和转换
        if len(record) < 4 {
            continue // 跳过不完整的记录
        }

        // 转换ID
        id, err := strconv.Atoi(record[0])
        if err != nil {
            continue // 跳过无效的ID
        }

        name := record[1]
        email := record[2]

        // 转换Age
        age, err := strconv.Atoi(record[3])
        if err != nil {
            age = 0 // 为无效年龄设置默认值
        }

        // 检查空值
        if name == "" || email == "" {
            continue // 跳过必需字段为空的记录
        }

        // 执行插入
        _, err = stmt.Exec(id, name, email, age)
        if err != nil {
            tx.Rollback()
            return err
        }
    }

    // 提交事务
    return tx.Commit()
}

对于更高效的内存使用，可以使用流式处理：

func processCSVStreaming(filePath string, db *sql.DB) error {
    file, err := os.Open(filePath)
    if err != nil {
        return err
    }
    defer file.Close()

    reader := csv.NewReader(file)
    
    // 跳过标题行（如果存在）
    if _, err := reader.Read(); err != nil {
        return err
    }

    batch := make([][]string, 0, 1000)
    recordCount := 0

    for {
        record, err := reader.Read()
        if err != nil {
            break
        }

        batch = append(batch, record)
        recordCount++

        if len(batch) >= 1000 {
            if err := insertBatch(db, batch); err != nil {
                return err
            }
            batch = batch[:0] // 清空批次
        }
    }

    // 插入剩余记录
    if len(batch) > 0 {
        if err := insertBatch(db, batch); err != nil {
            return err
        }
    }

    fmt.Printf("总共处理了 %d 条记录\n", recordCount)
    return nil
}

关键要点：

1. 使用事务和批量插入提高数据库性能
2. 实现数据验证避免空指针异常
3. 对于超大文件使用流式处理减少内存占用
4. 正确处理错误和资源释放

确保MySQL连接参数正确，数据库表结构匹配CSV文件格式。