Create is interface that defines functions need to create database transaction
type Create interface {
Exec(funcName, query string, args ...interface{}) (sql.Result, error)
Rebind(query string) string
Rollback(funcName string) error
Commit(funcName string) error
}
Migrator defines migrator
type Migrator struct {
Tx db.FabricCATx
CurLevels *util.Levels
SrvLevels *util.Levels
}
func NewMigrator(tx db.FabricCATx, curLevels, srvLevels *util.Levels) *Migrator
NewMigrator returns a migrator instance
func (m *Migrator) Commit() error
Commit is responsible for committing the migration db transcation
func (m *Migrator) MigrateAffiliationsTable() error
MigrateAffiliationsTable is responsible for migrating affiliations table SQLite has limited support for altering table columns, to upgrade the schema we require renaming the current affiliations table to affiliations_old and then creating a new user table using the new schema definition. Next, we proceed to copy the data from the old table to new table, and then drop the old table.
func (m *Migrator) MigrateCertificatesTable() error
MigrateCertificatesTable is responsible for migrating certificates table SQLite has limited support for altering table columns, to upgrade the schema we require renaming the current certificates table to certificates_old and then creating a new certificates table using the new schema definition. Next, we proceed to copy the data from the old table to new table, and then drop the old table.
func (m *Migrator) MigrateCredentialsTable() error
MigrateCredentialsTable is responsible for migrating credentials table
func (m *Migrator) MigrateNoncesTable() error
MigrateNoncesTable is responsible for migrating nonces table
func (m *Migrator) MigrateRAInfoTable() error
MigrateRAInfoTable is responsible for migrating rainfo table
func (m *Migrator) MigrateUsersTable() error
MigrateUsersTable is responsible for migrating users table
func (m *Migrator) Rollback() error
Rollback is responsible for rollback transaction if an error is encountered
Sqlite defines SQLite database
type Sqlite struct {
SqlxDB db.FabricCADB
CreateTx Create
CAName string
MetricsProvider metrics.Provider
// contains filtered or unexported fields
}
func NewDB(datasource, caName string, metricsProvider metrics.Provider) *Sqlite
NewDB creates a SQLite database
func (s *Sqlite) Connect() error
Connect connects to a SQLite database
func (s *Sqlite) Create() (*db.DB, error)
Create creates database and tables
func (s *Sqlite) CreateTables() error
CreateTables creates table
func (s *Sqlite) PingContext(ctx context.Context) error
PingContext pings the database