package main

import "fmt"
import "database/sql"
import _ "github.com/go-sql-driver/mysql"

type Fruits struct {
}

func (v Fruits) DeleteOneByID(id int) (int, error) {
    db, err := sql.Open("mysql", "b1:b1@/b1")
    if err != nil {
        return -1, fmt.Errorf("cant connect to database: %s", err.Error())
    }
    query := `
    DELETE FROM fruits
    WHERE fruit_id = ?`
    statement, err := db.Prepare(query)

    if err != nil {
        return -1, fmt.Errorf("repository: could not prepare query to database: %s", err.Error())
    }

    defer statement.Close()

    r, err := statement.Exec(id)
    if err != nil {
        return -1, fmt.Errorf("repository: could not exec query to database: %s", err.Error())
    }

    idInt64, err := r.RowsAffected()
    if err != nil {
        return -1, fmt.Errorf("repository: could not get row affected: %s", err.Error())
    }

    return int(idInt64), nil
}

func main() {
    v := Fruits{}
    v.DeleteOneByID(1)
}