Golang中如何调用JS的WebSQL

在Go中调用WebSQL需要通过syscall/js包与JavaScript交互，正确处理回调函数是关键。以下是实现示例：

package main

import (
    "syscall/js"
)

func main() {
    // 获取全局对象和openDatabase函数
    global := js.Global()
    openDatabase := global.Get("openDatabase")
    
    // 打开数据库
    db := openDatabase.Invoke(
        "mydb",
        "1.0",
        "Test DB",
        2*1024*1024,
    )
    
    // 定义成功回调函数
    successCallback := js.FuncOf(func(this js.Value, args []js.Value) interface{} {
        tx := args[0]
        results := args[1]
        
        rows := results.Get("rows")
        length := rows.Get("length").Int()
        
        statusDiv := global.Get("document").Call("querySelector", "#status")
        currentHTML := statusDiv.Get("innerHTML").String()
        
        // 添加行数信息
        statusDiv.Set("innerHTML", currentHTML + 
            "<p>Found rows: " + js.ValueOf(length).String() + "</p>")
        
        // 遍历结果
        for i := 0; i < length; i++ {
            row := rows.Call("item", i)
            logValue := row.Get("log").String()
            currentHTML = statusDiv.Get("innerHTML").String()
            statusDiv.Set("innerHTML", currentHTML + 
                "<p><b>" + logValue + "</b></p>")
        }
        
        return nil
    })
    defer successCallback.Release()
    
    // 定义错误回调函数
    errorCallback := js.FuncOf(func(this js.Value, args []js.Value) interface{} {
        // 处理错误
        js.Global().Call("console", "error", args[0])
        return nil
    })
    defer errorCallback.Release()
    
    // 执行事务
    transactionFunc := db.Get("transaction")
    transactionFunc.Invoke(js.FuncOf(func(this js.Value, args []js.Value) interface{} {
        tx := args[0]
        
        // 执行SQL查询
        executeSqlFunc := tx.Get("executeSql")
        executeSqlFunc.Invoke(
            "SELECT * FROM LOGS",
            js.ValueOf([]interface{}{}),
            successCallback,
            errorCallback,
        )
        
        return nil
    }))
    
    // 保持程序运行
    select {}
}

对于更结构化的实现，可以这样封装：

package main

import (
    "syscall/js"
)

type WebSQL struct {
    db js.Value
}

func NewWebSQL(name, version, desc string, size int) (*WebSQL, error) {
    openDatabase := js.Global().Get("openDatabase")
    db := openDatabase.Invoke(name, version, desc, size)
    return &WebSQL{db: db}, nil
}

func (w *WebSQL) Query(sql string, params []interface{}, 
    success, error js.Func) {
    
    transactionFunc := w.db.Get("transaction")
    transactionFunc.Invoke(js.FuncOf(func(this js.Value, args []js.Value) interface{} {
        tx := args[0]
        
        // 转换参数为JavaScript数组
        jsParams := js.Global().Get("Array").New(len(params))
        for i, param := range params {
            jsParams.SetIndex(i, param)
        }
        
        executeSqlFunc := tx.Get("executeSql")
        executeSqlFunc.Invoke(sql, jsParams, success, error)
        
        return nil
    }))
}

func main() {
    db, _ := NewWebSQL("mydb", "1.0", "Test DB", 2*1024*1024)
    
    success := js.FuncOf(func(this js.Value, args []js.Value) interface{} {
        results := args[1]
        rows := results.Get("rows")
        
        for i := 0; i < rows.Get("length").Int(); i++ {
            row := rows.Call("item", i)
            // 处理每一行数据
            _ = row.Get("log").String()
        }
        return nil
    })
    defer success.Release()
    
    error := js.FuncOf(func(this js.Value, args []js.Value) interface{} {
        // 错误处理
        return nil
    })
    defer error.Release()
    
    db.Query("SELECT * FROM LOGS", []interface{}{}, success, error)
    
    select {}
}

关键点：

1. 使用js.FuncOf创建Go函数作为JavaScript回调
2. 通过Get()方法获取JavaScript对象的属性和方法
3. 使用Invoke()调用JavaScript函数
4. 回调函数完成后需要调用Release()释放资源
5. 参数需要通过js.ValueOf()或直接传递JavaScript值

注意：WebSQL是已废弃的API，现代浏览器中可能不可用。在生产环境中建议考虑IndexedDB或其他存储方案。