This commit is contained in:
azw 2023-08-20 13:14:56 +08:00
parent 3ac5b2b0c3
commit 9d1eeef81c
4 changed files with 31 additions and 44 deletions

6
app.go
View File

@ -64,8 +64,8 @@ func (this *app) init(userApp UserApp) {
_sysLog.init() _sysLog.init()
_tgLog = new(TGLog_) _tgLog = new(TGLog_)
_tgLog.init() _tgLog.init()
_pageQuery = new (pageQuery) _dbFilter = new (dbFilter)
_pageQuery.init() _dbFilter.init()
_httpCliMgr = new(HttpCliMgr) _httpCliMgr = new(HttpCliMgr)
_httpCliMgr.init() _httpCliMgr.init()
{ {
@ -92,7 +92,7 @@ func (this *app) init(userApp UserApp) {
func (this *app) unInit() { func (this *app) unInit() {
this.chGoLoopTimerExit <- 1 this.chGoLoopTimerExit <- 1
_httpCliMgr.unInit() _httpCliMgr.unInit()
_pageQuery.unInit() _dbFilter.unInit()
_timer.unInit() _timer.unInit()
_timer = nil _timer = nil
this.userApp.UnInit() this.userApp.UnInit()

View File

@ -107,7 +107,8 @@ func (this *dbPool) PageQuery(
page int32, page int32,
sql string, sql string,
params []string, params []string,
queryParam *PageQueryParam, filter DbQueryFilter,
orderBy string,
cb PageQueryCb) { cb PageQueryCb) {
var pagination Pagination var pagination Pagination
pagination.PerPage = q5.Max(1, perPage) pagination.PerPage = q5.Max(1, perPage)

View File

@ -5,7 +5,7 @@ var _timer *Timer
var _sysLog *SysLog_ var _sysLog *SysLog_
var _tgLog *TGLog_ var _tgLog *TGLog_
var _httpCliMgr *HttpCliMgr var _httpCliMgr *HttpCliMgr
var _pageQuery *pageQuery var _dbFilter *dbFilter
var _goStyleDb *dbPool var _goStyleDb *dbPool
var _jsStyleDb *dbPool var _jsStyleDb *dbPool
@ -29,8 +29,8 @@ func GetHttpCliMgr() *HttpCliMgr {
return _httpCliMgr return _httpCliMgr
} }
func GetPageQuery() *pageQuery { func GetDbFilter() *dbFilter {
return _pageQuery return _dbFilter
} }
func GetGoStyleDb() *dbPool { func GetGoStyleDb() *dbPool {

View File

@ -23,13 +23,13 @@ const (
QC_CUSTOM QC_CUSTOM
) )
type pageQuery struct { type dbFilter struct {
} }
type PageQueryFilter interface { type DbQueryFilter interface {
And() PageQueryFilter And() DbQueryFilter
Or() PageQueryFilter Or() DbQueryFilter
Not() PageQueryFilter Not() DbQueryFilter
GetLinkOp() LinkOp GetLinkOp() LinkOp
GenSql() string GenSql() string
} }
@ -46,30 +46,16 @@ type PageQueryOne struct {
type PageQueryComp struct { type PageQueryComp struct {
linkOp LinkOp linkOp LinkOp
not bool not bool
subFilters []PageQueryFilter subFilters []DbQueryFilter
} }
type PageQueryParam struct { func (this *dbFilter) init() {
Filter *PageQueryComp
OrderBy string
} }
func (this *PageQueryParam) genSql() string { func (this *dbFilter) unInit() {
sql := " "
/*
for _, field := range this.Filter {
}*/
sql += " " + this.OrderBy + " "
return sql
} }
func (this *pageQuery) init() { func (this *dbFilter) Like(fieldName string, val string) DbQueryFilter {
}
func (this *pageQuery) unInit() {
}
func (this *pageQuery) Like(fieldName string, val string) PageQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_LIKE, cond: QC_LIKE,
fieldName: fieldName, fieldName: fieldName,
@ -77,7 +63,7 @@ func (this *pageQuery) Like(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) EQ(fieldName string, val string) PageQueryFilter { func (this *dbFilter) EQ(fieldName string, val string) DbQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_EQ, cond: QC_EQ,
fieldName: fieldName, fieldName: fieldName,
@ -85,7 +71,7 @@ func (this *pageQuery) EQ(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) LT(fieldName string, val string) PageQueryFilter { func (this *dbFilter) LT(fieldName string, val string) DbQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_LT, cond: QC_LT,
fieldName: fieldName, fieldName: fieldName,
@ -93,7 +79,7 @@ func (this *pageQuery) LT(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) LE(fieldName string, val string) PageQueryFilter { func (this *dbFilter) LE(fieldName string, val string) DbQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_LE, cond: QC_LE,
fieldName: fieldName, fieldName: fieldName,
@ -101,7 +87,7 @@ func (this *pageQuery) LE(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) GT(fieldName string, val string) PageQueryFilter { func (this *dbFilter) GT(fieldName string, val string) DbQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_GT, cond: QC_GT,
fieldName: fieldName, fieldName: fieldName,
@ -109,7 +95,7 @@ func (this *pageQuery) GT(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) GE(fieldName string, val string) PageQueryFilter { func (this *dbFilter) GE(fieldName string, val string) DbQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_GE, cond: QC_GE,
fieldName: fieldName, fieldName: fieldName,
@ -117,7 +103,7 @@ func (this *pageQuery) GE(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) Custom(fieldName string, val string) PageQueryFilter { func (this *dbFilter) Custom(fieldName string, val string) DbQueryFilter {
f := &PageQueryOne{ f := &PageQueryOne{
cond: QC_CUSTOM, cond: QC_CUSTOM,
fieldName: fieldName, fieldName: fieldName,
@ -125,29 +111,29 @@ func (this *pageQuery) Custom(fieldName string, val string) PageQueryFilter {
return f return f
} }
func (this *pageQuery) Comp(subFilters ...PageQueryFilter) PageQueryFilter { func (this *dbFilter) Comp(subFilters ...DbQueryFilter) DbQueryFilter {
f := &PageQueryComp{ f := &PageQueryComp{
subFilters: subFilters} subFilters: subFilters}
return f return f
} }
func (this *PageQueryOne) IgnoreEmpy() PageQueryFilter { func (this *PageQueryOne) IgnoreEmpy() DbQueryFilter {
this.ignoreEmpty = true this.ignoreEmpty = true
return this return this
} }
func (this *PageQueryOne) And() PageQueryFilter { func (this *PageQueryOne) And() DbQueryFilter {
this.linkOp = LK_AND this.linkOp = LK_AND
return this return this
} }
func (this *PageQueryOne) Or() PageQueryFilter { func (this *PageQueryOne) Or() DbQueryFilter {
this.linkOp = LK_OR this.linkOp = LK_OR
return this return this
} }
func (this *PageQueryOne) Not() PageQueryFilter { func (this *PageQueryOne) Not() DbQueryFilter {
this.not = true this.not = true
return this return this
} }
@ -193,17 +179,17 @@ func (this *PageQueryOne) GenSql() string {
return sql return sql
} }
func (this *PageQueryComp) And() PageQueryFilter { func (this *PageQueryComp) And() DbQueryFilter {
this.linkOp = LK_AND this.linkOp = LK_AND
return this return this
} }
func (this *PageQueryComp) Or() PageQueryFilter { func (this *PageQueryComp) Or() DbQueryFilter {
this.linkOp = LK_OR this.linkOp = LK_OR
return this return this
} }
func (this *PageQueryComp) Not() PageQueryFilter { func (this *PageQueryComp) Not() DbQueryFilter {
this.not = true this.not = true
return this return this
} }