var db = project.Context["db"];
string name = project.Variables["name"].Value;
string login = project.Variables["login"].Value;
string pass = project.Variables["pass"].Value;
string mail = project.Variables["mail"].Value;
string pass_mail = project.Variables["pass_mail"].Value;
string avatar = project.Variables["avatar"].Value;
string date_of_birth = project.Variables["avatar"].Value;
string ID_acc = project.Variables["ID_acc"].Value;
string cookie = project.Variables["cookie"].Value;
string token_eaab = project.Variables["token_eaab"].Value;
string fp = project.Variables["fp"].Value;
string useragent = project.Variables["useragent"].Value;
string photo = project.Variables["photo"].Value;
string rk_id = project.Variables["rk_id"].Value;
string bm_id = project.Variables["bm_id"].Value;
string token_EAAG = project.Variables["token_EAAG"].Value;
string bm_ssylka = project.Variables["bm_ssylka"].Value;
string id = project.Variables["id"].Value;
if ( id != "" ){
// получаем текущее юникс-время
int unixtime = (int)(DateTime.UtcNow - new DateTime(1970,1,1)).TotalSeconds;
// обратно устанавливаем статус=0 (свободен) и время последнего использования устанавливаем на текущее
db.query("UPDATE Account_FB SET name= '"+ project.Variables["name"].Value.ToString() +"',login= '"+ project.Variables["login"].Value.ToString() +"',pass= '"+ project.Variables["pass"].Value.ToString() +"',mail= '"+ project.Variables["mail"].Value.ToString() +"',pass_mail= '"+ project.Variables["pass_mail"].Value.ToString() +"',avatar= '"+ project.Variables["avatar"].Value.ToString() +"',date_of_birth= '"+ project.Variables["date_of_birth"].Value.ToString() +"',ID_acc= '"+ project.Variables["ID_acc"].Value.ToString() +"',cookie= '"+ project.Variables["cookie"].Value.ToString() +"',token_eaab= '"+ project.Variables["token_eaab"].Value.ToString() +"',fp= '"+ project.Variables["fp"].Value.ToString() +"',useragent= '"+ project.Variables["useragent"].Value.ToString() +"',photo= '"+ project.Variables["photo"].Value.ToString() +"',rk_id= '"+ project.Variables["rk_id"].Value.ToString() +"',bm_id= '"+ project.Variables["bm_id"].Value.ToString() +"',token_EAAG= '"+ project.Variables["token_EAAG"].Value.ToString() +"',bm_ssylka= '"+ project.Variables["bm_ssylka"].Value.ToString() +"', status=0, use_time="+unixtime.ToString()+" WHERE id="+id);
}
// завершаем работу с БД
db.close();
Можно не создавать доп строку и отправить сразу переменную
UPDATE Account_FB SET 'mail'='"+project.Variables["mail"].Value+"' , status =0
сохраняй в безлопастном формате. JSON, base64. или экранируй проблемные символы, которые база данных не проглатывает.
Большое спасибо, работает. Как я понял надо явно указывать колонку через table.coulumn)
Вопрос снят! db.query("START TRANSACTION"); db.query("ROLLBACK"); db.query("COMMIT "); - прекрасно работают.
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.IO;
using System.Text.RegularExpressions;
using ZennoLab.CommandCenter;
using ZennoLab.InterfacesLibrary;
using ZennoLab.InterfacesLibrary.ProjectModel;
using ZennoLab.InterfacesLibrary.ProjectModel.Collections;
using ZennoLab.InterfacesLibrary.ProjectModel.Enums;
using ZennoLab.Macros;
using Global.ZennoExtensions;
using ZennoLab.Emulation;
using ZennoLab.CommandCenter.TouchEvents;
using ZennoLab.CommandCenter.FullEmulation;
using ZennoLab.InterfacesLibrary.Enums;
using ZennoLab.InterfacesLibrary.ZennoDroid;
using ZennoLab.InterfacesLibrary.ZennoDroid.Enums;
namespace ZennoLab.OwnCode
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;";
conn = new MySqlConnection(connectionString);
open();
}
public void open(){
conn.Open();
}
public void close(){
conn.Close();
}
public void query(string query){
MySqlCommand command = new MySqlCommand(query, conn);
command.ExecuteNonQuery();
}
public List<string> getAll(string query, string fieldSeparator="|"){
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<string> getRow(string query){
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 string getOne(string query){
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);
}
}
}
string db_host = "localhost"; // хост
string db_user = "root"; // username для подключения к MySQL
string db_pswd = ""; // пароль для подключения к MySQL
string db_database = "mydb"; // название БД с которой будет работа
string db_charset = "utf8"; // кодировка данных в таблицах
DB db = new DB(db_host, db_user, db_pswd, db_database, db_charset);
// сохраняем объект в контексте что бы использовать его в других кубиках
project.Context["db"] = db;string count = db.getOne("SELECT cena FROM test WHERE id=1");
project.SendInfoToLog("Кол-во аккаунтов: "+count,true); // выводим в лог ZP
