simdb

func AddBDDir ¶

func AddBDDir(dir string)

func AddIKeyOneByStrKey ¶

func AddIKeyOneByStrKey(tbname, TXT, skey string, val int64) string

Увеличивает значение одной записи целочисленного ключа по строковому

func AddOneTextByStrKey ¶

func AddOneTextByStrKey(tbname, TXT, skey string, ikey int64)

находит запись с таким ключом и добавляет текст туда

func AddString ¶

func AddString(tbname, TXT, skey string, ikey int64)

==============ADD UPDATE==============================================

func ClearTable ¶

func ClearTable(tbname string)

-----------------------------

func DeleteOneBySKey ¶

func DeleteOneBySKey(tbname, skey string) string

удалить одну сроку по строковому ключу

func DeleteTable ¶

func DeleteTable(tbname string)

-----------------------------

func GetGobStructBySKEY ¶

func GetGobStructBySKEY(tbname string, s interface{}, skey string)

func GetJsonStructBySKEY ¶

func GetJsonStructBySKEY(tbname string, s interface{}, skey string)

-----------------------------

func GetStringByKeys ¶

func GetStringByKeys(tbname, skey string, ikey int64) string

func GetStringBySKey ¶

func GetStringBySKey(tbname, skey string) string

----------------------------------------------------------

func GetStringBySKeyToSym ¶

func GetStringBySKeyToSym(tbname, skey, split_sym string) string

----------------------------------------------------------

func GetStructByUID ¶

func GetStructByUID(tbname, uid string, s interface{})

-----------------------------

func GetTBListAsText ¶

func GetTBListAsText() string

-----------------------------

func GetTBListSlice ¶

func GetTBListSlice() []string

func LoadDBFilesFromDir ¶

func LoadDBFilesFromDir(dir string)

func RemoteCall ¶

func RemoteCall(IPP, Method string, args interface{}, resp interface{}) error

func RunTimers ¶

func RunTimers()

func (l *T_TABLE) load_from_json(dirname string) {
	ftbname := server.storpath + dirname + l.Name + ".json"
	fmt.Println("Открываю:" + ftbname)
	var err error
	var data []byte
	data, err = ioutil.ReadFile(ftbname)
	if err != nil {
		fmt.Println(err.Error())
		return
	}
	err = json.Unmarshal(data, l)

	if err != nil {
		fmt.Println(err.Error())
	}
	if l.SAVETIMER == 0 {
		l.SAVETIMER = 10
	}
	l.FILE = ftbname
}

func load_all_from_json() {
	files, err := ioutil.ReadDir(server.storpath)
	if err != nil {
		fmt.Println(err.Error())
		return
	} else {
		load_dir_from_json("", &files)
	}
	for _, d := range server.dirs {
		files, err := ioutil.ReadDir(server.storpath + d + "/")
		if err != nil {
			fmt.Println(err.Error())
			//return
		} else {
			load_dir_from_json(d+"/", &files)
		}
	}

}

func load_dir_from_json(dirname string, files *[]os.FileInfo) {
	for _, f := range *files {

		fnm := strings.Split(f.Name(), ".")

		lfnm := len(fnm)
		if lfnm > 1 && !f.IsDir() {
			if fnm[lfnm-1] == "json" {
				//fmt.Println(f.Name())
				on := ""
				if lfnm == 2 {
					on = fnm[0]
				} else {
					for i := 0; i < lfnm-2; i++ {
						on += fnm[i] + "."
					}
					on += fnm[lfnm-2]
				}
				fmt.Println(dirname + on)
				//fmt.Println(dirname + "/" + on)
				Thread.Lock()
				t := get_by_tbname(on)
				t.load_from_json(dirname)
				Thread.Unlock()
			}
		}
	}
}

func SetBackUpDuration ¶

func SetBackUpDuration(tbname string, seconds int) string

func SetSize ¶

func SetSize(tbname, size string)

func SetTimeFormat ¶

func SetTimeFormat(tbname, tformat string)

func StartServer ¶

func StartServer(rpcipp, dbstorpath string) string

func StartSqlite3Server ¶

func StartSqlite3Server(ipport, dbfile, backupfile string) error

IPPORT 127.0.0.1:300 and full paths "./backup/"

func StartServer(ipport, stropath, backuppath string, savepersec int) error {
	log.Println("Start SIMDB server "+ipport, stropath, backuppath)

		server.Sqlite3 = false
		server.savepersec = savepersec
		if stropath != "" {
			server.storpath = stropath
		} else {
			server.storpath = "./"
		}
		if backuppath == "" {
			server.backuppath = "./backup/"

		} else {
			server.backuppath = backuppath
		}
		load_all_from_json()
		server.savetimer = time.NewTicker(time.Second * time.Duration(savepersec))
		go saver()
		if ipport != "" {

			e := nt.StartTCPServer(ipport, msgreciever)
			if e != nil {
				return e
			}
		}

	return nil
}

func StructToGobBySKEY ¶

func StructToGobBySKEY(tbname string, s interface{}, skey string, ikey int64) string

func StructToJsonBySKEY ¶

func StructToJsonBySKEY(tbname string, s interface{}, skey string, ikey int64) string

обновляет json структурой одну запись с таким ключом

func TableConnectRemote ¶

func TableConnectRemote(name, netaddr string) string

подключение сетевой таблицы

func TableGetParamsFromRemoteServer ¶

func TableGetParamsFromRemoteServer(name, servaddr string)

получить параметры таблицы с другого сервера. не доделал. лень...

func TableLoadFromFile ¶

func TableLoadFromFile(name, file string, savetimesec, droptimesec, size int)

загрузить таблицу из файла и ообновить параметры

func TableRegisterAsFile ¶

func TableRegisterAsFile(REMOTEIPP, NAME string)

регистрация локальной таблицы как файла

func TableRegisterAsRemote ¶

func TableRegisterAsRemote(REMOTEIPP, LOCALIPP, NAME string)

регистрация своей таблицы на другом сервере

func TableRegisterFile ¶

func TableRegisterFile(name, file string)

func TableSaveToFile ¶

func TableSaveToFile(name, file string, savetimesec, droptimesec, size int)

сохранить таблицу

func TableUpdateParams ¶

func TableUpdateParams(name, file string, savetimesec, droptimesec, size int)

обновление параметров таблицы

func UpdateAllByStrKey ¶

func UpdateAllByStrKey(tbname, TXT, skey string, ikey int64) string

обновляет все записи с таким ключом. если не найдено то создает новую запись

func UpdateAllStructToJsonBySKEY ¶

func UpdateAllStructToJsonBySKEY(tbname string, s interface{}, skey string, ikey int64) string

обновляет json структурой все записи с таким ключом

func UpdateByIntKey ¶

func UpdateByIntKey(tbname, TXT, sik string)

--Upd BY KEY

func UpdateOneByKeys ¶

func UpdateOneByKeys(tbname, TXT, skey string, ikey int64) string

func UpdateOneBySKey ¶

func UpdateOneBySKey(tbname, TXT, skey string, ikey int64) string

обновляет одну запись с таким ключом.если не найдено то создает новую