nik-n
Client
- Регистрация
- 05.11.2016
- Сообщения
- 242
- Благодарностей
- 20
- Баллы
- 18
по C# + SQL - это самая простая и понятная инструкция из всех на форуме!
ps когда на форум добавят кнопку дабл лайк???? )
ps когда на форум добавят кнопку дабл лайк???? )
iskrakovrov
Client
- Регистрация
- 28.03.2015
- Сообщения
- 532
- Благодарностей
- 171
- Баллы
- 43
Обращаем Ваше внимание на то, что данный пользователь заблокирован.
Не рекомендуем проводить с iskrakovrov какие-либо сделки.
кодировку при обращении к бд выставить надо.
в общем коде добавить charset
hostname = db_hostname;
username = db_username;
password = db_password;
database = db_database;
charset = db_charset;
И в самом коде c#
string db_host = project.Variables["dbip"].Value; // хост
string db_user = project.Variables["dbuser"].Value; // username для подключения к MySQL
string db_pswd = project.Variables["dbpass"].Value; // пароль для подключения к MySQL
string db_database = project.Variables["dbname"].Value; // название БД с которой будет работа
string db_charset = "utf8"; // кодировка данных в таблицах
// коннект к MySQL и открытие сессии
DB db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
В примерах в теме это не прописано
в общем коде добавить charset
hostname = db_hostname;
username = db_username;
password = db_password;
database = db_database;
charset = db_charset;
И в самом коде c#
string db_host = project.Variables["dbip"].Value; // хост
string db_user = project.Variables["dbuser"].Value; // username для подключения к MySQL
string db_pswd = project.Variables["dbpass"].Value; // пароль для подключения к MySQL
string db_database = project.Variables["dbname"].Value; // название БД с которой будет работа
string db_charset = "utf8"; // кодировка данных в таблицах
// коннект к MySQL и открытие сессии
DB db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
В примерах в теме это не прописано
Всем привет. Помогите пжл правильно указать переменные в WHERE и строке UPDATE. Текущий код выдает ошибку на скрине
C#:
var db = project.Context["db"];
db.query("LOCK TABLES avito_get_zapros_table WRITE");
// берем строку у которой дата больше или равна чем впеременной проекта И ID равно перемнной проекта (INT)
List<string> row = db.getRow("SELECT id, uniq_string FROM avito_get_zapros_table WHERE date_time_zapros >= "'+ project.Variables["date_time_zapros"].Value +'" AND id = "'+ project.Variables["date_time_zapros"].Value +'"");
if ( row.Count > 0 ){
// запись перемнных
project.Variables["uniq_string"].Value = row[1];
// менем значение в uniq_string на рандомное цифровое значение находящееся в переменной проекта random_for_get
db.query("UPDATE avito_get_zapros_table SET uniq_string = '+ project.Variables["random_for_get"].Value +' WHERE id="+row[0]);
}
else {
project.SendInfoToLog("Не пришло время для взятия строки",true);
db.query("UNLOCK TABLES");
throw new Exception();
}
db.query("UNLOCK TABLES");
db.close();Вложения
usboff
Client
- Регистрация
- 25.08.2021
- Сообщения
- 88
- Благодарностей
- 48
- Баллы
- 18
Одинарные кавычки должны находиться ВНУТРИ двойных.
C#:
var db = project.Context["db"];
db.query("LOCK TABLES avito_get_zapros_table WRITE");
// берем строку у которой дата больше или равна чем впеременной проекта И ID равно перемнной проекта (INT)
List<string> row = db.getRow("SELECT id, uniq_string FROM avito_get_zapros_table WHERE date_time_zapros >= '"+ project.Variables["date_time_zapros"].Value +"' AND id = '"+ project.Variables["date_time_zapros"].Value +"'");
if ( row.Count > 0 ){
// запись перемнных
project.Variables["uniq_string"].Value = row[1];
// менем значение в uniq_string на рандомное цифровое значение находящееся в переменной проекта random_for_get
db.query("UPDATE avito_get_zapros_table SET uniq_string = '"+ project.Variables["test"].Value +"' WHERE id="+row[0]);
}
else {
project.SendInfoToLog("Не пришло время для взятия строки",true);
db.query("UNLOCK TABLES");
throw new Exception();
}
db.query("UNLOCK TABLES");
db.close();
C#:
// получаем текущее юникс-время
int unixtime = (int)(DateTime.UtcNow - new DateTime(1970,1,1)).TotalSeconds;
// обратно устанавливаем статус=0 (свободен) и время последнего использования устанавливаем на текущее
db.query("UPDATE accounts SET status=0, use_time="+unixtime.ToString()+" WHERE id="+acc_id);
}Какой тип данных должен быть в колонке use_time?
Там ведь для даты есть свои типы.
- Регистрация
- 04.04.2015
- Сообщения
- 1 763
- Благодарностей
- 1 391
- Баллы
- 113
Приветствую. В данном примере int unsigned ... но вы правы, для дат есть специализированные типы типа timestamp ... просто зачастую мне удобнее использовать просто int unsigned
Rimen
Client
- Регистрация
- 28.10.2019
- Сообщения
- 406
- Благодарностей
- 253
- Баллы
- 63
Работаю по этому мануалу уже давно, много где в сценариях прикрутил работу с базой данных. БД храню на хостинге, доступ по ip + логин + пароль
пару дней назад перестало работать, везде в шабах такая ошибка:
при этом нигде ничего не менял, на хостере доступы без обновлений тоже
подскажите куда копать?
пару дней назад перестало работать, везде в шабах такая ошибка:
Unable to connect to any of the specified MySQL hosts.при этом нигде ничего не менял, на хостере доступы без обновлений тоже
подскажите куда копать?
morpheus93
Client
- Регистрация
- 25.01.2012
- Сообщения
- 1 058
- Благодарностей
- 244
- Баллы
- 63
Здравствуйте,
отличная статья, большое спасибо. Я использую ваш подход в паре проектов, и он отлично работает.
Но возник один вопрос: Иногда, если в проекте проходит много времени между двумя действиями с базой данных, соединение с базой данных разрывается и больше не открывается. Когда ZP/PM доходит до следующего куба БД, он выдает ошибку. На другом сайте, если я добавлю код "open connection" в вершину каждого db-куба, то через некоторое время у меня будут открыты десятки неиспользуемых соединений.
Как я могу проверить, открыто ли еще соединение (и действительно ли оно) перед выполнением вставки/обновления (методы getOne, getRow) и если нет, то просто открыть его снова, иначе переходить непосредственно к db-действиям?
Спасибо
PS: Поскольку я не говорю по-русски, прошу извинить меня, если эта тема уже обсуждалась, и, возможно, дать мне ссылку на нее.
Переведено с помощью www.DeepL.com/Translator (бесплатная версия)
Koqpe
Client
- Регистрация
- 23.12.2014
- Сообщения
- 1 100
- Благодарностей
- 649
- Баллы
- 113
morpheus93
Client
- Регистрация
- 25.01.2012
- Сообщения
- 1 058
- Благодарностей
- 244
- Баллы
- 63
Спасибо, но я уже закрываю соединение с помощью db.close() в конце проекта (хороший/плохой конец).
Но мне нужна функция, которая проверяет состояние соединения во время выполнения проекта, если оно все еще открыто и действительно (так как соединение пропадает после того, как ZP поработает некоторое время на сайте).
Я нашел в документации библиотеки MySql.Data.dll, что есть свойство Connection.State, но я не уверен, что это правильное свойство и как его можно использовать.
Уже пробовал что-то вроде:
var db = project.Context["db"];
if(db.state() != "Open" ) {
db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
project.SendInfoToLog("Re-connected to DB", false);
db.open();
project.Context["db"] = db;
}
//LOCK
db.query("LOCK TABLES table1 WRITE;");
db.query(@"INSERT INTO table1
.....
.....
но, похоже, это не работает
Но мне нужна функция, которая проверяет состояние соединения во время выполнения проекта, если оно все еще открыто и действительно (так как соединение пропадает после того, как ZP поработает некоторое время на сайте).
Я нашел в документации библиотеки MySql.Data.dll, что есть свойство Connection.State, но я не уверен, что это правильное свойство и как его можно использовать.
Уже пробовал что-то вроде:
var db = project.Context["db"];
if(db.state() != "Open" ) {
db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
project.SendInfoToLog("Re-connected to DB", false);
db.open();
project.Context["db"] = db;
}
//LOCK
db.query("LOCK TABLES table1 WRITE;");
db.query(@"INSERT INTO table1
.....
.....
но, похоже, это не работает
Sardol
Client
- Регистрация
- 23.09.2020
- Сообщения
- 194
- Благодарностей
- 45
- Баллы
- 28
Я так проверяю:
C#:
var db = project.Context["db"];
db.query("LOCK TABLES name_tables WRITE");
db.query("UNLOCK TABLES");
bitardenko
Client
- Регистрация
- 27.12.2020
- Сообщения
- 91
- Благодарностей
- 73
- Баллы
- 18
Выкладываю свою слегка доработанную версию
Отличий примерно 3
Добавлены блоки try/catch, если возникает исключение, то вызывается open(), не знаю насколько это грамотно, но это полностью решило мои проблемы с постоянными ошибками о чем писал в теме выше.
Добавлены методы(вроде так это называется) getAllByName и getRowByName, можно получать значения по имени столбца, например
Dictionary<string, string> row = db.getRowByName("SELECT * FROM table");
return row["id"];
C#:
public class DB
{
private string hostname;
private string username;
private string password;
private string database;
private string charset;
private string result;
private MySqlConnection conn;
public DB(string db_hostname, string db_username, string db_password, string db_database, string db_charset="utf8"){
hostname = db_hostname;
username = db_username;
password = db_password;
database = db_database;
charset = db_charset;
result = String.Empty;
string db_port = "3306";
var m = db_hostname.Split(':');
if ( m.Length == 2 ){
db_hostname = m[0];
db_port = m[1];
}
var connectionString = "server="+db_hostname+";user="+db_username+";database="+db_database+";port="+db_port+";password="+db_password+";pooling=False;charset=utf8";
conn = new MySqlConnection(connectionString);
open();
}
public void open(){
conn.Open();
}
public void close(){
conn.Close();
}
public void query(string query){
if ( conn.State != ConnectionState.Open ){
open();
}
try{
MySqlCommand command = new MySqlCommand(query, conn);
command.ExecuteNonQuery();
}
catch (MySqlException ex){
open();
MySqlCommand command = new MySqlCommand(query, conn);
command.ExecuteNonQuery();
}
}
public List<string> getAll(string query, string fieldSeparator="|"){
if ( conn.State != ConnectionState.Open ){
open();
}
var result = new List<string>();
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
List<string> fields = new List<string>();
for(int i=0; i<reader.FieldCount; i++)
fields.Add(reader[i].ToString());
result.Add(string.Join(fieldSeparator,fields));
}
reader.Close();
return result;
}
public List<Dictionary<string, string>> getAllByName(string query){
if ( conn.State != ConnectionState.Open ){
open();
}
try
{
var result = new List<Dictionary<string, string>>();
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
Dictionary<string, string> fields = new Dictionary<string, string>();
for(int i=0; i<reader.FieldCount; i++)
fields[reader.GetName(i).ToString()] = reader[i].ToString();
result.Add(fields);
}
reader.Close();
return result;
}
catch(MySqlException ex)
{
open();
var result = new List<Dictionary<string, string>>();
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
Dictionary<string, string> fields = new Dictionary<string, string>();
for(int i=0; i<reader.FieldCount; i++)
fields[reader.GetName(i).ToString()] = reader[i].ToString();
result.Add(fields);
}
reader.Close();
return result;
}
}
public List<string> getRow(string query){
if ( conn.State != ConnectionState.Open ){
open();
}
try
{
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
if ( reader.Read() ){
List<string> result = new List<string>();
for(int i=0; i<reader.FieldCount; i++)
result.Add(reader[i].ToString());
reader.Close();
return result;
}
reader.Close();
return new List<string>();
}
catch (MySqlException ex)
{
open();
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
if ( reader.Read() ){
List<string> result = new List<string>();
for(int i=0; i<reader.FieldCount; i++)
result.Add(reader[i].ToString());
reader.Close();
return result;
}
reader.Close();
return new List<string>();
}
}
public Dictionary<string, string> getRowByName(string query){
if ( conn.State != ConnectionState.Open ){
open();
}
try{
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
if ( reader.Read() ){
Dictionary<string, string> result = new Dictionary<string, string>();
for(int i=0; i<reader.FieldCount; i++)
result[reader.GetName(i).ToString()] = reader[i].ToString();
reader.Close();
return result;
}
reader.Close();
return new Dictionary<string, string>();
}
catch (MySqlException ex)
{
open();
MySqlCommand command = new MySqlCommand(query, conn);
MySqlDataReader reader = command.ExecuteReader();
if ( reader.Read() ){
Dictionary<string, string> result = new Dictionary<string, string>();
for(int i=0; i<reader.FieldCount; i++)
result[reader.GetName(i).ToString()] = reader[i].ToString();
reader.Close();
return result;
}
reader.Close();
return new Dictionary<string, string>();
}
}
public string getOne(string query){
if ( conn.State != ConnectionState.Open ){
open();
}
MySqlCommand command = new MySqlCommand(query, conn);
string result = "";
try { result = command.ExecuteScalar().ToString(); } catch{}
return result;
}
public string escapeString(string text){
return MySql.Data.MySqlClient.MySqlHelper.EscapeString(text);
}
}Добавлены блоки try/catch, если возникает исключение, то вызывается open(), не знаю насколько это грамотно, но это полностью решило мои проблемы с постоянными ошибками о чем писал в теме выше.
Добавлены методы(вроде так это называется) getAllByName и getRowByName, можно получать значения по имени столбца, например
Dictionary<string, string> row = db.getRowByName("SELECT * FROM table");
return row["id"];
morpheus93
Client
- Регистрация
- 25.01.2012
- Сообщения
- 1 058
- Благодарностей
- 244
- Баллы
- 63
Большое спасибо, что поделились своим решением. Я попробую сделать это таким образом.
Можешь подсказать почему когда делаю так.
List<string> count = db.getRow("SELECT 'id_update' FROM offset WHERE 1");
то в переменной count[0] содержится название столбца id_update, а не его значение.
UPD : Разобрался, спасибо
Последнее редактирование:
Есть другой вопрос. Можно сделать подключение в общем коде, чтобы в каждом кубике C# процедуру подключения не делать?
bitardenko
Client
- Регистрация
- 27.12.2020
- Сообщения
- 91
- Благодарностей
- 73
- Баллы
- 18
А зачем её делать в каждом кубике?
Подключаемся в первом кубике
C#:
DB db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
project.Context["db"] = db;
C#:
var db = project.Context["db"];
Последнее редактирование:
Извиняюсь, такой вопрос еще
вот этот код добавляю в новый кубик. Когда просто запускаешь все работает, а если пошагово в режиме отладки, то вылазит ошибка и останавливает код
C#:
var db = project.Context["db"];
List<Dictionary<string, string>> userCount = db.getAllByName("SELECT * FROM message WHERE id_chat = "+project.Variables["chat_id"].Value);
//project.SendInfoToLog(project.Variables["chat_id"].ToString(),true);
project.SendInfoToLog(userCount[1]["text"],true);
C#:
Необработанное исключение Microsoft.CSharp.RuntimeBinder.RuntimeBinderException: Не удается выполнить привязки исполняющей среды по нулевой ссылке.
Выполнение действия CSharp OwnCode: Профиль. Microsoft.CSharp.RuntimeBinder.RuntimeBinderException: Не удается выполнить привязки исполняющей среды по нулевой ссылке.
Сбойное действие: Профиль
Последнее редактирование:
Код:
Тип Время Сообщение
03:11:44 Выполнение действия CSharp OwnCode. The connection is already open.Запускаю шаблон в зенке, все норм. Работает. Как только запускаю другой шаблон который обращается к этой же базе данных и делает подключение, вылазит эта ошибка
Последнее редактирование:
bitardenko
Client
- Регистрация
- 27.12.2020
- Сообщения
- 91
- Благодарностей
- 73
- Баллы
- 18
Ловил несколько раз подобные ошибки, но сейчас уже не помню как их решал, если не ошибаюсь в основном они были связаны с неправильным запросом/синтаксисом. Без FROM запрос отрабатывает?
Я бы рекомендовал начать с оригинальной версии, ручаться за свой высер я не могу потому что не программист и делаю всё методом тыка, хоть у меня он и работает стабильно в многопотоке.
bitardenko
Client
- Регистрация
- 27.12.2020
- Сообщения
- 91
- Благодарностей
- 73
- Баллы
- 18
А эта ошибка именно из-за моей версии, потому что как я писал если возникает исключение MySqlException, вызывается open(). Сделал я это потому что когда пропадала сессия, поднять её посредством кода вроде
C#:
if ( conn.State != ConnectionState.Open ){
open();
}Сама ваша проблема, вероятно, глубже, и MySqlException вызывает что-то еще, но однозначно стоит пока использовать оригинальную версию
Последнее редактирование:
Все работает. Единственное только не могу понять почему когда из контекста переношу подключение в другие кубики в режиме отладки выдает ошибку и останавливает кубик, а если запускать просто на работу, то все работает.
morpheus93
Client
- Регистрация
- 25.01.2012
- Сообщения
- 1 058
- Благодарностей
- 244
- Баллы
- 63
Рекомендуется ли устанавливать пулинг в true в строке подключения (var connectionString = "server="+db_hostname+";user="+db_username+";database="+db_database+";port="+db_port+";password="+db_password+";pooling=False;charset=utf8"
? Имеет ли это смысл или это приведет к неожиданным ошибкам и/или неправильному поведению?Большое спасибо.
artsmm
Client
- Регистрация
- 03.10.2018
- Сообщения
- 1 136
- Благодарностей
- 196
- Баллы
- 63
Привет. Как проверить наличие таблицы в базе данных с данной библиотекой? Составил запрос:
на создание БД.
в Sql мне приходит ответ, что есть дубликат таблицы. Как получить данный ответ в зенке?
вопрос решен через try catch
C#:
CREATE TABLE `test`.`OrdersPane` ( `OrderId` TEXT NOT NULL , `productSumm` TEXT NOT NULL , `keyword` TEXT NOT NULL , `tovid` TEXT NOT NULL, `brandName` TEXT NOT NULL, `Size` TEXT NOT NULL, `tovid` TEXT NOT NULL, `deliveryAdress` TEXT NOT NULL, `buyCounts` TEXT NOT NULL) ENGINE = InnoDBв Sql мне приходит ответ, что есть дубликат таблицы. Как получить данный ответ в зенке?
вопрос решен через try catch
Последнее редактирование:
Всем привет.
Подскажите как реализовать такую конструкцию в данном методе C# брать одну строку с удалением для многопотока
Один кубик добавляет в таблицу,
А второй берет строку с удалением (работает в многопотоке)
ПЕРВЫЙ КУБИК
Добавляем данные в таблицу
INSERT INTO `accounts` (`ID`) VALUES ('{-Variable.ran-}');
ВТОРОЙ КУБИК (работает в многопотоке)
Читаем сточку из таблицы
SELECT `ID` FROM `accounts` LIMIT 1
удаляем прочитанную строчку
DELETE FROM `accounts` WHERE ID={-Variable.mysql-}
Подскажите как реализовать такую конструкцию в данном методе C# брать одну строку с удалением для многопотока
Один кубик добавляет в таблицу,
А второй берет строку с удалением (работает в многопотоке)
ПЕРВЫЙ КУБИК
Добавляем данные в таблицу
INSERT INTO `accounts` (`ID`) VALUES ('{-Variable.ran-}');
ВТОРОЙ КУБИК (работает в многопотоке)
Читаем сточку из таблицы
SELECT `ID` FROM `accounts` LIMIT 1
удаляем прочитанную строчку
DELETE FROM `accounts` WHERE ID={-Variable.mysql-}