package models

import (
    "database/sql"
    "log"
    "fmt"
)


func InsertNewJob(db *sql.DB, inputFilePath string, targetUrl1 string, targetUrl2 string, middlewarePath  string, status int, logString string) error {
    stmt, err := db.Prepare("INSERT jobs set inputFilePath=?, targetUrl1=?, targetUrl2=?, middlewarePath=?, status=?, log=?")
    if err != nil {
        fmt.Println("INSERT jobs set inputFilePath=?, targetUrl1=?, targetUrl2=?, middlewarePath=?, status=?, log=?")
        return err
    }

    res, err := stmt.Exec(inputFilePath, targetUrl1, targetUrl2, middlewarePath, status, logString)
	if err != nil {
        return err
    }

	lastId, err := res.LastInsertId()
	if err != nil {
        return err
    }

	rowCnt, err := res.RowsAffected()
	if err != nil {
        return err
    }

    log.Printf("ID = %d, affected = %d\n", lastId, rowCnt)
    return nil
}