package db

import (
	"database/sql"
	"fmt"
	"strings"

	"gitee.com/sosotec/gwork"
)

func queryDataRows(model interface{}, cols string, where map[string]interface{}, size int, idx int) (
	table *tableInfo,
	rows *sql.Rows,
	values []sql.RawBytes,
	scans []interface{},
	columns []string,
) {

	//获取表信息
	table = getTableInfo(model)
	query := []string{}

	//如果字段为空
	if cols == "" {
		cols = "*"
	}

	//如果有数量
	if idx > 1 && size > 0 {
		query = append(query, fmt.Sprintf("OFFSET %d LIMIT %d", size*(idx-1), size))
	} else if size > 0 {
		query = append(query, fmt.Sprintf("LIMIT %d", size))
	}

	//组装SQL说句
	sqlText := fmt.Sprintf(
		"SELECT %s FROM %s %s",
		cols,
		table.TableName,
		strings.Join(query, " "),
	)

	fmt.Println(sqlText)

	// Execute the query
	rows, err := gwork.MySqlDb.Query(sqlText)
	if err != nil {
		panic(err.Error())
	}

	// Get column names
	columns, _ = rows.Columns()
	fields := len(columns)

	// Make a slice for the values
	values = make([]sql.RawBytes, fields)
	scans = make([]interface{}, fields)
	for i := range values {
		scans[i] = &values[i]
	}

	//返回
	return
}