Skip to content

Commit

Permalink
remove unused functions
Browse files Browse the repository at this point in the history
  • Loading branch information
stremovsky committed Feb 13, 2020
1 parent 95fa565 commit cdbcb71
Showing 1 changed file with 4 additions and 33 deletions.
37 changes: 4 additions & 33 deletions src/qldb.go
Expand Up @@ -338,29 +338,6 @@ func (dbobj dbcon) countRecords(t Tbl, keyName string, keyValue string) (int64,
return int64(count), nil
}

func (dbobj dbcon) countRecords2(t Tbl, keyName string, keyValue string, keyName2 string, keyValue2 string) (int64, error) {
tbl := getTable(t)
q := "select count(*) from " + tbl + " WHERE " + escapeName(keyName) + "=$1" +
" AND " + escapeName(keyName2) + "=$2"
fmt.Printf("q: %s\n", q)

tx, err := dbobj.db.Begin()
if err != nil {
return 0, err
}
defer tx.Rollback()
row := tx.QueryRow(q, keyValue, keyValue2)
// Columns
var count int
err = row.Scan(&count)
if err != nil {
return 0, err
}
if err = tx.Commit(); err != nil {
return 0, err
}
return int64(count), nil
}
func (dbobj dbcon) updateRecord(t Tbl, keyName string, keyValue string, bdoc *bson.M) (int64, error) {
table := getTable(t)
filter := escapeName(keyName) + "=\"" + keyValue + "\""
Expand Down Expand Up @@ -434,16 +411,6 @@ func (dbobj dbcon) getRecord2(t Tbl, keyName string, keyValue string,
return dbobj.getRecordInTableDo(q, values)
}

func (dbobj dbcon) getRecordInTable2(table string, keyName string, keyValue string,
keyName2 string, keyValue2 string) (bson.M, error) {
q := "select * from " + table + " WHERE " + escapeName(keyName) + "=$1 AND " +
escapeName(keyName2) + "=$2"
values := make([]interface{}, 0)
values = append(values, keyValue)
values = append(values, keyValue2)
return dbobj.getRecordInTableDo(q, values)
}

func (dbobj dbcon) getRecordInTableDo(q string, values []interface{}) (bson.M, error) {
fmt.Printf("query: %s\n", q)

Expand Down Expand Up @@ -574,11 +541,14 @@ func (dbobj dbcon) deleteRecordInTable2(table string, keyName string, keyValue s
return num, err
}

/*
func (dbobj dbcon) deleteDuplicate2(t Tbl, keyName string, keyValue string, keyName2 string, keyValue2 string) (int64, error) {
tbl := getTable(t)
return dbobj.deleteDuplicateInTable2(tbl, keyName, keyValue, keyName2, keyValue2)
}
*/

/*
func (dbobj dbcon) deleteDuplicateInTable2(table string, keyName string, keyValue string, keyName2 string, keyValue2 string) (int64, error) {
q := "delete from " + table + " where " + escapeName(keyName) + "=$1 AND " +
escapeName(keyName2) + "=$2 AND rowid not in " +
Expand All @@ -601,6 +571,7 @@ func (dbobj dbcon) deleteDuplicateInTable2(table string, keyName string, keyValu
num, err := result.RowsAffected()
return num, err
}
*/

func (dbobj dbcon) deleteExpired0(t Tbl, expt int32) (int64, error) {
table := getTable(t)
Expand Down

0 comments on commit cdbcb71

Please sign in to comment.