mirror of
https://github.com/pocketbase/pocketbase.git
synced 2024-12-03 03:18:56 +02:00
107 lines
2.8 KiB
Go
107 lines
2.8 KiB
Go
package daos
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/pocketbase/dbx"
|
|
"github.com/pocketbase/pocketbase/models"
|
|
)
|
|
|
|
// HasTable checks if a table (or view) with the provided name exists (case insensitive).
|
|
func (dao *Dao) HasTable(tableName string) bool {
|
|
var exists bool
|
|
|
|
err := dao.DB().Select("count(*)").
|
|
From("sqlite_schema").
|
|
AndWhere(dbx.HashExp{"type": []any{"table", "view"}}).
|
|
AndWhere(dbx.NewExp("LOWER([[name]])=LOWER({:tableName})", dbx.Params{"tableName": tableName})).
|
|
Limit(1).
|
|
Row(&exists)
|
|
|
|
return err == nil && exists
|
|
}
|
|
|
|
// TableColumns returns all column names of a single table by its name.
|
|
func (dao *Dao) TableColumns(tableName string) ([]string, error) {
|
|
columns := []string{}
|
|
|
|
err := dao.DB().NewQuery("SELECT name FROM PRAGMA_TABLE_INFO({:tableName})").
|
|
Bind(dbx.Params{"tableName": tableName}).
|
|
Column(&columns)
|
|
|
|
return columns, err
|
|
}
|
|
|
|
// TableInfo returns the `table_info` pragma result for the specified table.
|
|
func (dao *Dao) TableInfo(tableName string) ([]*models.TableInfoRow, error) {
|
|
info := []*models.TableInfoRow{}
|
|
|
|
err := dao.DB().NewQuery("SELECT * FROM PRAGMA_TABLE_INFO({:tableName})").
|
|
Bind(dbx.Params{"tableName": tableName}).
|
|
All(&info)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// mattn/go-sqlite3 doesn't throw an error on invalid or missing table
|
|
// so we additionally have to check whether the loaded info result is nonempty
|
|
if len(info) == 0 {
|
|
return nil, fmt.Errorf("empty table info probably due to invalid or missing table %s", tableName)
|
|
}
|
|
|
|
return info, nil
|
|
}
|
|
|
|
// TableIndexes returns a name grouped map with all non empty index of the specified table.
|
|
//
|
|
// Note: This method doesn't return an error on nonexisting table.
|
|
func (dao *Dao) TableIndexes(tableName string) (map[string]string, error) {
|
|
indexes := []struct {
|
|
Name string
|
|
Sql string
|
|
}{}
|
|
|
|
err := dao.DB().Select("name", "sql").
|
|
From("sqlite_master").
|
|
AndWhere(dbx.NewExp("sql is not null")).
|
|
AndWhere(dbx.HashExp{
|
|
"type": "index",
|
|
"tbl_name": tableName,
|
|
}).
|
|
All(&indexes)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
result := make(map[string]string, len(indexes))
|
|
|
|
for _, idx := range indexes {
|
|
result[idx.Name] = idx.Sql
|
|
}
|
|
|
|
return result, nil
|
|
}
|
|
|
|
// DeleteTable drops the specified table.
|
|
//
|
|
// This method is a no-op if a table with the provided name doesn't exist.
|
|
//
|
|
// Be aware that this method is vulnerable to SQL injection and the
|
|
// "tableName" argument must come only from trusted input!
|
|
func (dao *Dao) DeleteTable(tableName string) error {
|
|
_, err := dao.DB().NewQuery(fmt.Sprintf(
|
|
"DROP TABLE IF EXISTS {{%s}}",
|
|
tableName,
|
|
)).Execute()
|
|
|
|
return err
|
|
}
|
|
|
|
// Vacuum executes VACUUM on the current dao.DB() instance in order to
|
|
// reclaim unused db disk space.
|
|
func (dao *Dao) Vacuum() error {
|
|
_, err := dao.DB().NewQuery("VACUUM").Execute()
|
|
|
|
return err
|
|
}
|