Function InitSQLite

IceFireDB-SQLite/internal/sqlite/db.go:24–60

(ctx context.Context, filename string)

)

func InitSQLite(ctx context.Context, filename string) *sql.DB {
	var err error
	// var driver sqlite3.SQLiteDriver
	// conn, err := driver.Open(filename)
	db, err = sql.Open("sqlite3", filename)
	if err != nil {
		panic(err)
	}
	if config.Get().P2P.Enable {
		// create p2p element
		p2pHost = p2p.NewP2P(config.Get().P2P.ServiceDiscoveryID,
			config.Get().P2P.NodeHostIP,
			config.Get().P2P.NodeHostPort)

		logrus.Info("Completed P2P Setup")

		// Connect to peers with the chosen discovery method
		switch strings.ToLower(config.Get().P2P.ServiceDiscoverMode) {
		case "announce":
			p2pHost.AnnounceConnect() // KadDHT p2p net create
		case "advertise":
			p2pHost.AdvertiseConnect()
		default:
			p2pHost.AdvertiseConnect()
		}

		logrus.Info("Connected to P2P Service Peers")
		var err error
		p2pPubSub, err = p2p.JoinPubSub(p2pHost, "icefiredb-sqlite-client", config.Get().P2P.ServiceCommandTopic)
		if err != nil {
			panic(err)
		}
		logrus.Infof("Successfully joined [%s] P2P channel. \n", config.Get().P2P.ServiceCommandTopic)
		asyncSQL(ctx)
	}
	return db
}

var DMLSQL = []string{
	"BEGIN",