本文整理汇总了C#中MySql.Data.MySqlClient.MySqlConnection类的典型用法代码示例。如果您正苦于以下问题:C# MySql.Data.MySqlClient.MySqlConnection类的具体用法?C# MySql.Data.MySqlClient.MySqlConnection怎么用?C# MySql.Data.MySqlClient.MySqlConnection使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MySql.Data.MySqlClient.MySqlConnection类属于命名空间,在下文中一共展示了MySql.Data.MySqlClient.MySqlConnection类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: GetForecastFromDatabase
public CityForeCast[] GetForecastFromDatabase()
{
//SqlConnection connection = new SqlConnection(@"Data Source=(LocalDb)\MSSQLLocalDb;Initial Catalog=weatherForecast;Integrated Security=True;Pooling=False");
MySql.Data.MySqlClient.MySqlConnection connection = new MySql.Data.MySqlClient.MySqlConnection(@"Server=eu-cdbr-azure-west-c.cloudapp.net;Database=BDMeteo;Uid=b95badd8e1dbad;Pwd=bde4c7b6;Pooling=True");
connection.Open();
MySql.Data.MySqlClient.MySqlCommand cmd = new MySql.Data.MySqlClient.MySqlCommand("SELECT * FROM tablemeteo", connection);
MySql.Data.MySqlClient.MySqlDataReader reader = cmd.ExecuteReader();
List<CityForeCast> forecasts = new List<CityForeCast>();
while (reader.Read())
{
CityForeCast forecast = new CityForeCast();
forecast.City = (string)reader["City"];
forecast.description = (string)reader["Description"];
forecast.MaxTemp = (decimal)reader["Temperature"];
forecasts.Add(forecast);
}
reader.Close(); // Fermer le reader avant de fermer la connection
connection.Close();
return forecasts.ToArray();
//var ctx = new weatherForecastEntities();
//var forecast = ctx.Tables.Select(f => new CityForeCast()
//{
// City = f.City,
// description = f.Description,
// MaxTemp = (decimal)f.Temperature
//});
//return forecast;
}
开发者ID:Racuine,项目名称:MeteoApplication,代码行数:29,代码来源:dataAccess.cs
示例2: SqlScalar
/// <summary>
/// Для выполнения запросов к MySQL с возвращением 1 параметра.
/// </summary>
/// <param name="sql">Текст запроса к базе данных</param>
/// <param name="connection">Строка подключения к базе данных</param>
/// <returns>Возвращает значение при успешном выполнении запроса, текст ошибки - при ошибке.</returns>
public static MyResult SqlScalar(string sql, string connection)
{
MyResult result = new MyResult();
try
{
MySql.Data.MySqlClient.MySqlConnection connRC = new MySql.Data.MySqlClient.MySqlConnection(connection);
MySql.Data.MySqlClient.MySqlCommand commRC = new MySql.Data.MySqlClient.MySqlCommand(sql, connRC);
connRC.Open();
try
{
result.ResultText = commRC.ExecuteScalar().ToString();
result.HasError = false;
}
catch (Exception ex)
{
result.ErrorText = ex.Message;
result.HasError = true;
}
connRC.Close();
}
catch (Exception ex)//Этот эксепшн на случай отсутствия соединения с сервером.
{
result.ErrorText = ex.Message;
result.HasError = true;
}
return result;
}
开发者ID:nebosvod,项目名称:notify,代码行数:34,代码来源:Main.cs
示例3: FetchePassword
public static string FetchePassword()
{
string passwordStr = string.Empty;
MySql.Data.MySqlClient.MySqlConnection msqlConnection = null;
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=technicise;database=sptdb;persist security info=False");
try
{ //define the command reference
MySql.Data.MySqlClient.MySqlCommand msqlCommand = new MySql.Data.MySqlClient.MySqlCommand();
msqlCommand.Connection = msqlConnection;
msqlConnection.Open();
msqlCommand.CommandText = "Select password from sptinfo;";
MySql.Data.MySqlClient.MySqlDataReader msqlReader = msqlCommand.ExecuteReader();
msqlReader.Read();
passwordStr = msqlReader.GetString("password");
}
catch (Exception er)
{
//Assert//.Show(er.Message);
}
finally
{
//always close the connection
msqlConnection.Close();
}
return passwordStr;
}
开发者ID:shuiping150,项目名称:SalesPurchaseTracker,代码行数:34,代码来源:FetchSPTSettings.cs
示例4: button1_Click
private void button1_Click(object sender, EventArgs e)
{
MySql.Data.MySqlClient.MySqlConnection con = new MySql.Data.MySqlClient.MySqlConnection(string.Format("Server={1};Port={2};Uid={3};Pwd={4};Database={0};", "sagaeco", "127.0.0.001", "3306", "root", "lh630206"));
string sqlstr = string.Format("INSERT INTO `login`(`username`,`password`,`deletepass`) VALUES ('{0}','{1}','{2}')", this.textBox1.Text, GetMD5(this.textBox2.Text), GetMD5(this.textBox3.Text));
con.Open();
MySql.Data.MySqlClient.MySqlHelper.ExecuteNonQuery(con, sqlstr, null);
}
开发者ID:yasuhiro91,项目名称:SagaECO,代码行数:7,代码来源:Form1.cs
示例5: DeleteStock
private void DeleteStock(string stockToDelete)
{
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=technicise;database=sptdb;persist security info=False");
try
{ //define the command reference
MySql.Data.MySqlClient.MySqlCommand msqlCommand = new MySql.Data.MySqlClient.MySqlCommand();
msqlCommand.Connection = msqlConnection;
msqlConnection.Open();
msqlCommand.CommandText = "DELETE FROM stock WHERE id= @vendorIdToDelete";
msqlCommand.Parameters.AddWithValue("@vendorIdToDelete", stockToDelete);
MySql.Data.MySqlClient.MySqlDataReader msqlReader = msqlCommand.ExecuteReader();
}
catch (Exception er)
{
MessageBox.Show(er.Message);
}
finally
{
//always close the connection
msqlConnection.Close();
}
}
开发者ID:shuiping150,项目名称:SalesPurchaseTracker,代码行数:26,代码来源:StockManagerWindow.xaml.cs
示例6: EditSptInfo
private void EditSptInfo(SettingsData returnEditedsettingsData)
{
MySql.Data.MySqlClient.MySqlConnection msqlConnection = null;
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=technicise;database=sptdb;persist security info=False");
try
{ //define the command reference
MySql.Data.MySqlClient.MySqlCommand msqlCommand = new MySql.Data.MySqlClient.MySqlCommand();
msqlCommand.Connection = msqlConnection;
msqlConnection.Open();
int idSptinfo = 1;
msqlCommand.CommandText = "UPDATE sptinfo SET name='" + returnEditedsettingsData.Name + "', address='" + returnEditedsettingsData.Address + "', phone='" +
returnEditedsettingsData.Phone + "', bill_disclaimer='" + returnEditedsettingsData.BillDisclaimer + "', invoice_prefix='" + returnEditedsettingsData.InvoicePrefix +
"' WHERE id_sptinfo='" + idSptinfo + "'; ";
msqlCommand.ExecuteNonQuery();
}
catch (Exception er)
{
MessageBox.Show(er.Message);
}
finally
{
//always close the connection
msqlConnection.Close();
}
}
开发者ID:shuiping150,项目名称:SalesPurchaseTracker,代码行数:29,代码来源:SPTSettingsWindow.xaml.cs
示例7: EditSptPassword
public static void EditSptPassword(string passwordStr)
{
MySql.Data.MySqlClient.MySqlConnection msqlConnection = null;
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=technicise;database=sptdb;persist security info=False");
try
{ //define the command reference
MySql.Data.MySqlClient.MySqlCommand msqlCommand = new MySql.Data.MySqlClient.MySqlCommand();
msqlCommand.Connection = msqlConnection;
msqlConnection.Open();
int idSptinfo = 1;
msqlCommand.CommandText = "UPDATE sptinfo SET password='" + passwordStr + "' WHERE id_sptinfo='" + idSptinfo + "'; ";
msqlCommand.ExecuteNonQuery();
}
catch (Exception er)
{
//MessageBox.Show(er.Message);
}
finally
{
//always close the connection
msqlConnection.Close();
}
}
开发者ID:shuiping150,项目名称:SalesPurchaseTracker,代码行数:26,代码来源:FetchSPTSettings.cs
示例8: Form1_Load
private void Form1_Load(object sender, EventArgs e)
{
var cn = new MySql.Data.MySqlClient.MySqlConnection();
cn.ConnectionString = "Server=mysql2.altaortopedia.com.br;Database=altaortopedia;Uid=altaortopedia;[email protected]";
cn.Open();
cn.Close();
}
开发者ID:jnbv,项目名称:alta-erp,代码行数:8,代码来源:Form1.cs
示例9: button1_Click_1
private void button1_Click_1(object sender, EventArgs e)
{
MySql.Data.MySqlClient.MySqlConnection myconn = null;
myconn = new MySql.Data.MySqlClient.MySqlConnection("Database=qsgj;Data Source=127.0.0.1;User Id=root;Password=;pooling=false;CharSet=utf8;port=3306");
myconn.Open();
myconn.Close();
}
开发者ID:qq54605802,项目名称:qsgjxt_client,代码行数:9,代码来源:Shezhi.cs
示例10: Execute
public static int Execute(string sql)
{
using (var conn = new MySql.Data.MySqlClient.MySqlConnection(ConnectString()))
{
conn.Open();
var cmd = new MySql.Data.MySqlClient.MySqlCommand(sql, conn);
int i = cmd.ExecuteNonQuery();
conn.Close();
return i;
}
}
开发者ID:gofixiao,项目名称:HYPDM_Pro,代码行数:11,代码来源:MySqlUtil.cs
示例11: Processor
/// <summary>
/// Add all associated models to the models data structure prior to calling process
/// </summary>
public Processor()
{
models = new List<Model>();
// Connect to our SQL Server Instance Running Locally
this.sqlserver_conn = new System.Data.SqlClient.SqlConnection();
this.sqlserver_conn.ConnectionString = sqlserver_conn_string;
// Connect to our MySQL Server Instance Running Locally
this.mysql_conn = new MySql.Data.MySqlClient.MySqlConnection();
this.mysql_conn.ConnectionString = mysql_conn_string;
}
开发者ID:NightsongEntertainment,项目名称:Data-Migrator,代码行数:15,代码来源:Processor.cs
示例12: Query
public static DataTable Query(string sql)
{
using (var conn = new MySql.Data.MySqlClient.MySqlConnection(ConnectString()))
{
conn.Open();
var adapter = new MySql.Data.MySqlClient.MySqlDataAdapter(sql, conn);
var ds = new DataSet();
var reader = adapter.Fill(ds);
conn.Close();
return ds.Tables[0];
}
}
开发者ID:gofixiao,项目名称:HYPDM_Pro,代码行数:12,代码来源:MySqlUtil.cs
示例13: OpenDbConnection
private static MySql.Data.MySqlClient.MySqlConnection OpenDbConnection()
{
MySql.Data.MySqlClient.MySqlConnection msqlConnection = null;
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=" + passwordCurrent + ";database=" + dbmsCurrent + ";persist security info=False");
//open the connection
if (msqlConnection.State != System.Data.ConnectionState.Open)
msqlConnection.Open();
return msqlConnection;
}
开发者ID:sayan801,项目名称:PhotoManipulator,代码行数:12,代码来源:MainWindow.xaml.cs
示例14: TruncateMinuteWiseMeasures
internal void TruncateMinuteWiseMeasures()
{
using (var mySqlConn = new MySql.Data.MySqlClient.MySqlConnection(_connectionString))
{
mySqlConn.Open();
var sqlCom = mySqlConn.CreateCommand();
sqlCom.CommandText = @"TRUNCATE TABLE minute_wise;";
sqlCom.ExecuteNonQuery();
mySqlConn.Close();
}
}
开发者ID:Epstone,项目名称:mypvlog,代码行数:12,代码来源:TestDbSetup.cs
示例15: pasar_consulta_datatable
/*Devolvemos un datatable con el resultado de la consulta que esta como paramatro en la bd cuyo string de conexion esta el parametro conexion del fichero de confi
guracon*/
public System.Data.DataTable pasar_consulta_datatable(string consulta)
{
MySql.Data.MySqlClient.MySqlConnection mscon = new MySql.Data.MySqlClient.MySqlConnection(Properties.Settings.Default.conexion);
MySql.Data.MySqlClient.MySqlDataAdapter mda = new MySql.Data.MySqlClient.MySqlDataAdapter(consulta, mscon);
mda.SelectCommand.CommandTimeout = 0;
System.Data.DataTable dt = new System.Data.DataTable();
mda.Fill(dt);
mscon.Close();
return dt;
}
开发者ID:raulgl,项目名称:ADO_utiles,代码行数:15,代码来源:DAO.cs
示例16: RunTableList
public void RunTableList()
{
using (var connection = new MySql.Data.MySqlClient.MySqlConnection(MySql))
{
var dr = new DatabaseSchemaReader.DatabaseReader(connection);
dr.Owner = "sakila";
var schema = dr.ReadAll();
var tableList = dr.TableList();
var tables = dr.AllTables();
var views = dr.AllViews();
Assert.NotEmpty(tableList);
}
}
开发者ID:shiningrise,项目名称:dbschemareader,代码行数:13,代码来源:TestMySql.cs
示例17: Mysql_File_Save
public int Mysql_File_Save(int PropertyObject, int FileSize, string FileName, string Content_Type,
int Height, int Width, byte[] Image, byte[] ImagePreview, bool IsDeleted)
{
int result = -1;
using (MySql.Data.MySqlClient.MySqlConnection oConn =
new MySql.Data.MySqlClient.MySqlConnection(this.connStr))
{
oConn.Open();
MySql.Data.MySqlClient.MySqlCommand cmd = oConn.CreateCommand();
cmd.Connection = oConn;
//Add new
//oCommand.CommandText = "insert into cust_file(customer_id, filename, filedata, contenttype, length) " +
// "values( ?in_customer_id, ?in_filename, ?in_filedata, ?in_contenttype, ?in_length)";
//INSERT INTO myrealty.images (id, img) VALUES (<INT(11)>, <LONGBLOB>);
cmd.CommandText = @"SET GLOBAL max_allowed_packet=16*1024*1024;
INSERT INTO ObjectImages (PropertyObject_Id, FileSize, FileName, Content_Type, Height, Width,
Image, ImagePreview, IsDeleted) VALUES (?PropertyObject, ?FileSize, ?FileName, ?Content_Type, ?Height, ?Width,
?Image, ?ImagePreview, ?IsDeleted); select last_insert_id();";
//oCommand.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("?PropertyObject", PropertyObject);
cmd.Parameters.Add("?FileSize", FileSize);
cmd.Parameters.Add("?FileName", FileName);
cmd.Parameters.Add("?Content_Type", Content_Type);
cmd.Parameters.Add("?Height", Height);
cmd.Parameters.Add("?Width", Width);
cmd.Parameters.Add("?Image", MySql.Data.MySqlClient.MySqlDbType.LongBlob);
cmd.Parameters["?Image"].Value = Image;
cmd.Parameters.Add("?ImagePreview", MySql.Data.MySqlClient.MySqlDbType.LongBlob);
cmd.Parameters["?ImagePreview"].Value = ImagePreview;
cmd.Parameters.Add("?IsDeleted", IsDeleted);
result = Convert.ToInt32(cmd.ExecuteScalar());
oConn.Close();
}
return result;
}
开发者ID:MaxIakovliev,项目名称:asp.net-mvc-real-estate,代码行数:51,代码来源:SqlObjectManipulation.cs
示例18: ConnectFetchFromSaleslistTable
private void ConnectFetchFromSaleslistTable()
{
//define the connection reference and initialize it
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=technicise;database=sptdb;persist security info=False");
try
{
//define the command reference
MySql.Data.MySqlClient.MySqlCommand msqlCommand = new MySql.Data.MySqlClient.MySqlCommand();
//define the connection used by the command object
msqlCommand.Connection = msqlConnection;
//open the connection
if (msqlConnection.State != System.Data.ConnectionState.Open)
msqlConnection.Open();
TimeSpan diff = (TimeSpan)(endDatePicker.SelectedDate - startDatePicker.SelectedDate);
msqlCommand.CommandText = "SELECT * FROM saleslist where date(saleslist.dateSales) >= DATE_SUB( @enddate, INTERVAL @diff DAY);";
msqlCommand.Parameters.AddWithValue("@enddate", endDatePicker.SelectedDate);
msqlCommand.Parameters.AddWithValue("@diff", diff.Days);
MySql.Data.MySqlClient.MySqlDataReader msqlReader = msqlCommand.ExecuteReader();
_salesDataCollection.Clear();
while (msqlReader.Read())
{
SalesData salesData = new SalesData();
salesData.customerId = msqlReader.GetString("customerId");
salesData.customerName = msqlReader.GetString("customerName"); //add
salesData.dateSales = msqlReader.GetDateTime("dateSales");
salesData.invoiceNo = msqlReader.GetString("invoiceNo");
salesData.payment = msqlReader.GetDouble("payment");
salesData.totalAmount = msqlReader.GetDouble("totalAmount");
//salesData.serialNo = (_salesDataCollection.Count + 1).ToString();
_salesDataCollection.Add(salesData);
}
}
catch (Exception er)
{
MessageBox.Show(er.Message);
}
finally
{
//always close the connection
msqlConnection.Close();
}
}
开发者ID:shuiping150,项目名称:SalesPurchaseTracker,代码行数:51,代码来源:SalesReportWindow.xaml.cs
示例19: ConnectFetchFromSaleslistTable
private void ConnectFetchFromSaleslistTable(string invoiceNumber)
{
//define the connection reference and initialize it
msqlConnection = new MySql.Data.MySqlClient.MySqlConnection("server=localhost;user id=root;Password=technicise;database=sptdb;persist security info=False");
try
{
//define the command reference
MySql.Data.MySqlClient.MySqlCommand msqlCommand = new MySql.Data.MySqlClient.MySqlCommand();
//define the connection used by the command object
msqlCommand.Connection = msqlConnection;
//open the connection
if (msqlConnection.State != System.Data.ConnectionState.Open)
msqlConnection.Open();
msqlCommand.CommandText = "SELECT * FROM salesBilling WHERE invoiceNo = @invoiceNo;";
msqlCommand.Parameters.AddWithValue("@invoiceNo", invoiceNumber);
MySql.Data.MySqlClient.MySqlDataReader msqlReader = msqlCommand.ExecuteReader();
double totalVat = 0.0;
while (msqlReader.Read())
{
BillingData billedData = new BillingData();
billedData.amount = msqlReader.GetDouble("amount");
billedData.productName = msqlReader.GetString("description");
billedData.quantity = msqlReader.GetDouble("quantity");
billedData.vat = msqlReader.GetDouble("vat");
billedData.calVat = Convert.ToDouble(billedData.amount) * Convert.ToDouble(billedData.vat) * (.01); ;
totalVat += billedData.calVat;
billedData.rate = msqlReader.GetDouble("rate");
billedData.serialNo = billingItemListView.Items.Count + 1; //msqlReader.GetString("serialNo");
_billingCollection.Add(billedData);
vatAmount.Content = totalVat;
}
}
catch (Exception er)
{
MessageBox.Show(er.Message);
}
finally
{
//always close the connection
msqlConnection.Close();
}
}
开发者ID:shuiping150,项目名称:SalesPurchaseTracker,代码行数:50,代码来源:BillDetailsWindow.xaml.cs
示例20: Connect
public void Connect()
{
m_connString = System.Configuration.ConfigurationManager.ConnectionStrings["db-utos"].ConnectionString;
Disconnect();
try
{
m_connection = new MySql.Data.MySqlClient.MySqlConnection();
m_connection.ConnectionString = m_connString;
m_connection.Open();
}
catch (MySql.Data.MySqlClient.MySqlException ex)
{
MessageBox.Show(ex.Message);
}
}
开发者ID:Oleksandr93,项目名称:MyWorks,代码行数:15,代码来源:UtosForm.cs
注:本文中的MySql.Data.MySqlClient.MySqlConnection类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论