匿名用户

1级

2018-11-19 回答

static string myConnstr = "server=ip;user id=root; password=passwd;database=db;pooling=false;charset=gbk;";

//System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;

public static MySqlConnection GetMyConnection()

{

MySqlConnection conn = new MySqlConnection(myConnstr);

return conn;

}

public static DataTable GetMyDataTable(string cmdText)

{

DataTable dt = new DataTable();

MySqlConnection conn = GetMyConnection();

if (conn != null)

conn.Close();

try

{

conn.Open();

MySqlDataAdapter da = new MySqlDataAdapter(cmdText, conn);

MySqlCommandBuilder cb = new MySqlCommandBuilder(da);

da.Fill(dt);

return dt;

}

finally

{

if (conn != null)

conn.Close();

}

}

public static void Execute(MySqlConnection conn, string cmdText, params MySqlParameter[] cmdParms)

{

MySqlCommand cmd = new MySqlCommand(cmdText, conn);

if (conn != null && conn.State != ConnectionState.Open) conn.Open();

foreach (MySqlParameter param in cmdParms)

{

cmd.Parameters.Add(param);

}

cmd.ExecuteNonQuery();

cmd.Parameters.Clear();

}

public static int ExecuteInt(MySqlConnection conn, string cmdText, params MySqlParameter[] cmdParms)

{

MySqlCommand cmd = new MySqlCommand(cmdText, conn);

if (conn != null && conn.State != ConnectionState.Open) conn.Open();

foreach (MySqlParameter param in cmdParms)

{

cmd.Parameters.Add(param);

}

object o = cmd.ExecuteScalar();

cmd.Parameters.Clear();

return Convert.ToInt32(o);

}

调用:

DataTable dt = GetMyDataTable("select count(1) as totals from uchome_blogfield" );

我也是粘贴的，只是粘的是我自己的代码。