public int AddVeinMessage(byte[] data)//插入數據庫 { using (BCSSqlConnection = new MySqlConnection(strConn)) { try { dbHelper = new DBHelper(BCSSqlConnection); StringBuilder sbSql = new StringBuilder(); sbSql.Append("insert into table1("); sbSql.Append("data)"); sbSql.Append(" values ("); sbSql.Append(" ?data)"); string strInsertSql = sbSql.ToString(); MySqlCommand cmd = dbHelper.GetSqlStringCommond(strInsertSql); dbHelper.AddInParameter(cmd, "?data", MySqlDbType.VarBinary, FINGERDATA); return dbHelper.ExecuteNonQuery(cmd); } catch (Exception ex) { System.Windows.Forms.MessageBox.Show("添加失敗了" + ex.Message); return 0; //表示數據庫異常 } finally { dbHelper.CloseSqlConnection(); //關閉數據庫 } } }
從數據庫中取出
public DataTable SelectVeinMessage() { using (BCSSqlConnection = new MySqlConnection(strConn)) { try { StringBuilder sbSql = new StringBuilder(); sbSql.Append("select data from table"); //設置MYSQL查詢語句用於查詢符合查詢條件的記錄 string strSql = sbSql.ToString(); dbHelper = new DBHelper(BCSSqlConnection); //調用DBHelper類中的GetSqlStringCommond()方法將返回的MySqlCommand對象賦給cmd MySqlCommand cmd = dbHelper.GetSqlStringCommond(strSql); // dbHelper.AddInParameter(cmd, "?FINGERDATA", MySqlDbType.VarChar, FINGERDATA); //調用DBHelper類的ExecuteDataSet()方法 DataTable dt = dbHelper.ExecuteDataTable(cmd); //返回DataTable對象dt return dt; } catch (Exception e) { throw new Exception(e.Message); } finally { dbHelper.CloseSqlConnection(); } } }
DataTable dt = mm.SelectVeinMessage1(); byte[] TemplateBuff = new byte[512]; for (int i = 0; i < dt.Rows.Count; i++) { TemplateBuff = (byte[])dt.Rows[i]["data"]; }