Как подружить go и Sphinx?

Question

[Дмитрий Свиридов]

Пытаюсь подключиться к Sphinx в Go-шной программе через драйвер MySQL - и получаю ошибку commands out of sync. Did you run multiple statements at once? при любом запросе. Вот пример программы. В данном случае ошибку возвращает метод Ping(). Параметр ?multiStatements=true в DSN-строке пробовал (хотя он тут, думаю, не при чем) - не помогло. Что я делаю не так, и как решить проблему?

package main

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


func main() {
	db, err := sql.Open("mysql", "tcp(127.0.0.1:9312)/")
	if err != nil {
		fmt.Println(err)
	}
	defer db.Close()
	fmt.Println(db.Ping())
}

P.s. со Sphinx точно все в порядке, php-шный проект с ним успешно взаимодействует.

Comments

[Дмитрий Свиридов]

Максим Федоров, да, потому что они совместимы. Более того, народ так и делает. А как вообще в Go со Sphinx взаимодействовать иначе? Есть такой пакет, но он устаревший и не потокобезопасный. Альтернативы нет.

[Максим Грищенко]

Дмитрий Свиридов, да, понял :)

Answer 1

[Владислав]

Уберите Ping, в Sphinx урезанный набор mysql команд.
Так же не используйте prepared statements, они им тоже не поддерживаются. Но не бойтесь, sql injection в Sphinx не грозит.

Comments

[Дмитрий Свиридов]

Спасибо. А как правильно тогда любой запрос сделать? В смысле Prepare и Exec приводят к той же самой ошибке

[Владислав]

Дмитрий Свиридов, писать в лоб (но никогда не делайте так в mysql)

SELECT * FROM images WHERE id IN("+strings.Join(ids, ", ")+")

и вызывать через db.Query/Exec без аргументов

db, err := sql.Open("mysql", "tcp(127.0.0.1:9312)/")
    if err != nil {
        log.Fatal(err)
    }

    ids := []string{"1","2","3","4"}
    rows, err := db.Query("SELECT * FROM images WHERE id IN("+strings.Join(ids, ", ")+")")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    imgs := make([]Image, 0)
    for rows.Next() {
        var img Image
        err := rows.Scan(&img.Title)
        if err != nil {
            log.Fatal(err)
        }
        imgs = append(imgs, img)
    }
    if err = rows.Err(); err != nil {
        log.Fatal(err)
    }

[Дмитрий Свиридов]

Владислав Фурсов, насчет "никогда не делайте так в mysqlникогда не делайте так в mysql" - это само собой. С утра попробую сделать, как Вы написали - большое спасибо.

[Владислав]

Дмитрий Свиридов, к сожалению, я находил подобное в реальных проектах, поэтому на всякий случай указываю, что так делать нельзя :-)

[Дмитрий Свиридов]

Владислав Фурсов, увы, не помогло.

package main

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


func main() {
	db, err := sql.Open("mysql", "tcp(127.0.0.1:9312)/")
	if err != nil {
		log.Fatal(fmt.Errorf("open connection: %v", err))
	}
	defer db.Close()
	res, err := db.Query("SELECT * FROM catalogue WHERE (@title тест) | (@tags тест)")
	if err != nil {
		log.Fatal(fmt.Errorf("query: %v", err))
	}
	fmt.Println(res)
}

Выдает ошибку:

2020/03/04 12:23:59 query: commands out of sync. Did you run multiple statements at once?
exit status 1

[Владислав]

Дмитрий Свиридов, а вы укажите индекс, который использовать
tcp(127.0.0.1:9312)/INDEX
может дело в этом.

[Дмитрий Свиридов]

Владислав Фурсов, к сожалению, то же самое :(

[Владислав]

Дмитрий Свиридов, посмотрите логи сфинкса, может что там есть.

[Владислав]

Дмитрий Свиридов, у вас не верно составлен запрос, вы пропустили MATCH sphinxsearch.com/docs/current/sphinxql-select.html

WHERE MATCH('(@categoryid 1 (@format SD | mHD | 720p | 1080p | 1080i @media Blu-ray/HD
DVD | Encode | Remux | WEB-DL) ) | (@categoryid 2 (@format MP3|FLAC @media CD | DVD) ) ')

[Владислав]

Дмитрий Свиридов, для вашего примера, полагаю, должно быть

SELECT * FROM catalogue WHERE MATCH('(@title тест) | (@tags тест)')

[Дмитрий Свиридов]

Владислав Фурсов, да, спасибо, я это тоже уже обнаружил, но на ту ошибку это никак не повлияло, к сожалению

Answer 2

[Дмитрий Свиридов]

Может пригодится кому-то. Сейчас Sphinx юзать нет смысла, т.к. есть Manticore - они совместимы. И для работы с Manticore для Go есть официальный sdk-клиент.

Answer 3

[Пума Тайланд]

А нахрена вы делаете припейр и какой то пинг? Вы почитайте что умеет сфинкскл

Comments

[Дмитрий Свиридов]

Просто для проверки работоспособности