c读取数据库
A. c语言操作Mysql数据库的基本步骤指南c使用mysql步骤
C语言是一种强大且广泛应用于软件开发的编程语言。在很多应用中，C语言需要与数据库进行交互。MySQL数据库是一种常用且开源的关系型数据库，本文将介绍C语言操作MySQL数据库的基本步骤。
一、安装MySQL数据库和C语言相关库文件
要操作MySQL数据库，首先需要安装MySQL数据库和相关的C语言库文件。逐步完成以下操作：
1. 从官网下载MySQL数据库安装程序，安装程序自带了C语言库文件。
2. 在C语言程序中，需要包括mysql.h头文件，该头文件是关于MySQL数据库的声明和定义。
3. 在C语言程序中还需要包括链接器库libmysql.dll的定义。
二、连接MySQL数据库
在C语言中连接MySQL数据库需要进行以下步骤：
1. 初始化MySQL连接
在C语言程序中连接MySQL数据库，首先需要初始化连接。MySQL提供了初始化函数mysql_init()，该函数返回一个类型为MYSQL*的指针，该指针用于连接MySQL服务器。下面是一个示例代码：
MYSQL *conn_ptr;
//初始化连接
conn_ptr = mysql_init(NULL);
if (!conn_ptr)
{
fprintf(stderr, “mysql_init对象出错 %s\n”, mysql_error(conn_ptr));
exit(1);
}
2. 连接MySQL数据库
调用mysql_real_connect()函数连接MySQL数据库，将返回值与MYSQL*对象做比较。下面是一些常用的参数：
mysql_real_connect(MYSQL * mysql, const char * host, const char * user, const char * passwd, const char * db,
unsigned int port, const char * unix_socket, unsigned long clientflag);
参数解释：
mysql：使用mysql_init()函数初始化后的MYSQL*对象。
host：MySQL服务器的主机名或IP地址。
user：MySQL用户名。
passwd：MySQL密码。
db：连接到的数据库名称。
port：MySQL服务器的端口号。
unix_socket：连接到MySQL服务器使用的Unix套接字。
clientflag：客户端属性。
下面是连接MySQL数据库的示例代码：
MYSQL *conn_ptr;
//连接MySQL数据库
conn_ptr = mysql_real_connect(conn_ptr, “localhost”, “root”, “password”, “test”, 3306, NULL, 0);
if (conn_ptr)
{
printf(“连接成功!\n”);
}
else
{
printf(“连接失败: %s \n”, mysql_error(conn_ptr));
}
三、查询MySQL数据库
在C语言中查询MySQL数据库需要以下步骤：
1. 执行查询语句
调用mysql_real_query()函数执行SELECT语句并返回结果集。
下面是函数的声明：
int mysql_real_query(MYSQL *mysql, const char *query, unsigned long length);
参数解释：
mysql：一个MYSQL*对象。
query：SQL查询语句。
length：指定查询缓冲区的长度。
下面是一个查询MySQL数据库的示例代码：
MYSQL *conn_ptr;
MYSQL_RES *res_ptr;
MYSQL_ROW sqlrow;
//执行查询语句
mysql_real_query(conn_ptr, “SELECT * FROM student”, (unsigned int)strlen(“SELECT * FROM student”));
res_ptr = mysql_store_result(conn_ptr);
if (res_ptr)
{
printf(“查询成功!\n”);
while ((sqlrow = mysql_fetch_row(res_ptr)))
{
printf(“%s \n”, sqlrow[0]);
}
mysql_free_result(res_ptr);
}
else
{
printf(“查询失败: %s \n”, mysql_error(conn_ptr));
}
四、断开MySQL数据库
在完成MySQL数据库操作后，需要断开与MySQL服务器的连接。调用mysql_close()函数即可。以下是函数的示例代码：
MYSQL *conn_ptr;
//断开MySQL数据库连接
mysql_close(conn_ptr);
在使用C语言操作MySQL数据库时，需贯彻于以上这些基本步骤，以确保代码的完整性。
B. c语言可以连接access数据库
#import "C:\program files\common files\system\ado\msado15.dll " no_namespace rename( "EOF ", "adoEOF ")
//#import "c:\program files\common files\system\ado\msado15.dll " rename ( "EOF ", "adoEOF ") no_namespace
#define CREATEiNSTANCE(sp,riid) { HRESULT _hr =sp .CreateInstance( __uuidof( riid ) ); \
if (FAILED(_hr)) _com_issue_error(_hr); }
#define RsITEM(rs,x) ((rs-> Fields-> Item[_variant_t(x)]-> Value))
class CHmbAdoDB
{
public:
BOOL m_bOpen;
_ConnectionPtr m_DbConn;
CString m_ErrMsg;
CString m_SQLState;
long mSqlCode;
public:
void Cancel();
BOOL IsOpen();
void RollbackTrans();
void CommitTrans();
long BeginTrans();
void Close();
BOOL Open(LPCSTR lpszConnect);
BOOL Execute(LPCTSTR lpSQL);
void ProviderError();
CHmbAdoDB()
{
}
virtual ~CHmbAdoDB()
{
}
};
class CHmbAdoDBRs : public CObject
{
public:
_RecordsetPtr m_Rs;
public:
CHmbAdoDBRs();
virtual ~CHmbAdoDBRs();
BOOL Open( CHmbAdoDB *pDB, LPCSTR szSource,long option=-1);
void Close();
void GetRs(_variant_t x,_bstr_t &ret);
void GetRs(_variant_t x,CString &ret);
BOOL IsEOF();
BOOL IsOpen();
BOOL MoveNext();
BOOL MovePrev();
BOOL MoveFirst();
BOOL MoveLast();
};
#endif // !defined(AFX_RfidAdoDB_H__7C539954_1C62_47B6_AB6E_1A5BB73A67E5__INCLUDED_) truct InitOle
{
InitOle() { ::CoInitialize(NULL); }
~InitOle() { ::CoUninitialize(); }
} _init_InitOle_;
long mSqlCode;
BOOL CHmbAdoDB::Open(LPCSTR lpszConnect)
{
try
{
CREATEiNSTANCE(m_DbConn,Connection);
m_DbConn-> Open(lpszConnect, " ", " ", adModeUnknown );
}
catch( _com_error &e)
{
return FALSE;
}
catch(...)
{
return FALSE;
}
return TRUE;
}
void CHmbAdoDB::Close()
{
if( IsOpen() )
{
m_DbConn-> Close();
}
}
long CHmbAdoDB::BeginTrans()
{
return m_DbConn-> BeginTrans();
}
void CHmbAdoDB::CommitTrans()
{
m_DbConn-> CommitTrans();
}
void CHmbAdoDB::RollbackTrans()
{
m_DbConn-> RollbackTrans();
}
void CHmbAdoDB::Cancel()
{
m_DbConn-> Cancel();
}
BOOL CHmbAdoDB::IsOpen()
{
return ( (m_DbConn-> GetState() != 0) ? TRUE : FALSE );
}
BOOL CHmbAdoDB::Execute(LPCTSTR lpSQL)
{
if (!IsOpen())
{
AfxMessageBox( "Network error, Database do not open. ");
return FALSE;
}
CString strSQL(lpSQL);
strSQL.TrimLeft();
strSQL.TrimRight();
try
{
m_DbConn-> Execute(_bstr_t(strSQL), NULL, adExecuteNoRecords);
}
catch( _com_error &e)
{
return FALSE;
}
catch(...)
{
return FALSE;
}
return TRUE;
}
void CHmbAdoDB::ProviderError()
{
// Print Provider Errors from Connection object.
// pErr is a record object in the Connection 's Error collection.
ErrorPtr pErr = NULL;
if( (m_DbConn-> Errors-> Count) > 0)
{
long nCount = m_DbConn-> Errors-> Count;
// Collection ranges from 0 to nCount -1.
for(long i = 0; i < nCount; i++)
{
pErr = m_DbConn-> Errors-> GetItem(i);
mSqlCode = pErr-> NativeError;
m_ErrMsg.Format( "SQLCODE : %ld\t%s ",mSqlCode, LPCTSTR(pErr-> Description));
m_SQLState.Format( "%s ",(char*)pErr-> SQLState);
printf( "%s // %s\n ",m_SQLState,m_ErrMsg);
}
}
m_DbConn-> Errors-> Clear();
}
CHmbAdoDBRs::CHmbAdoDBRs( )
{
}
CHmbAdoDBRs::~CHmbAdoDBRs()
{
}
BOOL CHmbAdoDBRs::Open( CHmbAdoDB *pDB, LPCSTR szSource,long option )
{
CString strSQL;
strSQL = CString(szSource);
strSQL.TrimLeft();
strSQL.TrimRight();
_variant_t vRecsAffected(0L);
// CREATEiNSTANCE( m_Rs,Recordset) ;
// m_Rs-> PutRefActiveConnection( pDB-> m_DbConn );
try
{
m_Rs = pDB-> m_DbConn-> Execute(_bstr_t(strSQL),
&vRecsAffected,
adOptionUnspecified);
m_Rs-> AddRef();
// m_Rs-> Open(szSource, vtMissing, adOpenKeyset, adLockBatchOptimistic, adOptionUnspecified);
// m_Rs-> Open(szSource, vtMissing, adOpenKeyset, adLockReadOnly, option);
// m_Rs-> Open(szSource,pDB-> m_DbConn.GetInterfacePtr(),adOpenDynamic,adLockOptimistic, adCmdText);
}
catch( _com_error &e)
{
//ErrorMessage();
m_Rs-> Close();
m_Rs-> Release();
return FALSE;
}
catch(...)
{
m_Rs-> Close();
m_Rs-> Release();
return FALSE;
}
return TRUE;
}
void CHmbAdoDBRs::Close()
{
m_Rs-> Close();
m_Rs-> Release();
}
void CHmbAdoDBRs::GetRs(_variant_t x,_bstr_t &ret)
{
ret = (m_Rs-> Fields-> Item[x]-> Value);
}
void CHmbAdoDBRs::GetRs(_variant_t x,CString &ret)
{
_bstr_t retVal;
try{
retVal = (m_Rs-> Fields-> Item[x]-> Value);
}
catch(...){
ret = " ";
return;
}
ret = CString((char*) retVal);
}
BOOL CHmbAdoDBRs::IsEOF()
{
return m_Rs-> adoEOF;
}
BOOL CHmbAdoDBRs::IsOpen()
{
return ( (m_Rs-> GetState() != 0) ? TRUE : FALSE );
}
BOOL CHmbAdoDBRs::MoveNext() { return (FAILED(m_Rs-> MoveNext()) ? FALSE : TRUE ); }
BOOL CHmbAdoDBRs::MovePrev() { return (FAILED(m_Rs-> MovePrevious()) ? FALSE : TRUE ); }
BOOL CHmbAdoDBRs::MoveFirst() { return (FAILED(m_Rs-> MoveFirst()) ? FALSE : TRUE ) ; }
BOOL CHmbAdoDBRs::MoveLast() { return (FAILED(m_Rs-> MoveLast()) ? FALSE : TRUE ) ; }
以上为一个ADO的封装类.
c语言如何连接access数据库
现在一般是用ADO的方法.
C. C#读取数据库IMAGE字段的内容。
读取... 读取长二进制为图片..
string sql = "select photo from studentinfo where studentid = " + this.Tag.ToString();
OleDbCommand cmd = new OleDbCommand(sql, connection1);
if (Convert.DBNull != cmd.ExecuteScalar())
pictureBox1.Image = Image.FromStream(new MemoryStream((Byte[])cmd.ExecuteScalar()));
放大就不知道了
保存:
string filename= textBox1.Text;//"c:\\IMG_0117.jpg";
BinaryReader reader=null;
FileStream myfilestream = new FileStream(filename,FileMode.Open);
try
{
reader=new BinaryReader(myfilestream);
byte[] image = reader.ReadBytes((int)myfilestream.Length);
using (SqlConnection conn = new SqlConnection("server=test05;database=esdb2;uid=datatran;pwd=qyrl"))
{
using (SqlCommand command = conn.CreateCommand())
{
command.CommandText =@"INSERT INTO photo(photo) VALUES (@photo)";
command.Parameters.Add("@photo", image);
conn.Open();
command.ExecuteNonQuery();
conn.Close();
MessageBox.Show("文件保存成功！","提示",MessageBoxButtons.OK,MessageBoxIcon.Information);
}
}
}
catch(IOException ee)
{
MessageBox.Show(ee.Message.ToString());
}
finally
{
if(reader!=null)
reader.Close();
}
D. C语言实现MySQL数据库连接驱动cmysql连接驱动
C语言实现MySQL数据库连接驱动
MySQL是一种流行的关系型数据库管理系统，它可以轻松存储和管理大量数据。为了连接MySQL数据库，需要使用一种称为“驱动”的软件。
在本文中，我们将学习如何使用C语言来实现MySQL数据库连接驱动。我们将涵盖以下内容：
1. 安装MySQL Connector/C
2. 建立连接
3. 查询数据库
4. 插入、更新和删除数据
第一步：安装MySQL Connector/C
MySQL Connector/C是一个MySQL数据库连接器，它可以允许你从C语言编程环境中连接到MySQL服务器。你需要先安装这个连接器，才能开始实现我的下面的代码。
打开命令行窗口，输入以下命令：
sudo apt-get install libmysqlclient-dev
这会安装最新的Connector/C库。
第二步：建立连接
为了建立连接，我们需要在程序中包含MySQL的库头文件mysql.h，并调用相关的函数。
#include
#include
int mn()
{
MYSQL *conn;
conn = mysql_init(NULL);
if (!mysql_real_connect(conn, “localhost”, “username”, “password”, “database”, 0, NULL, 0))
{
printf(“Connection Fled: %s\n”, mysql_error(conn));
}
else
{
printf(“Connection Successful\n”);
}
mysql_close(conn);
return 0;
}
在上面的程序中，我们使用了mysql_init()函数来初始化连接对象，然后使用mysql_real_connect()函数来实际建立连接。这个函数需要四个参数：
1. 主机名或IP地址（本地主机为“localhost”）
2. 用户名
3. 密码
4. 数据库名
如果连接成功，这个函数将返回一个MYSQL对象，我们可以用它来进行后续的操作。否则，我们需要使用mysql_error()函数来显示错误信息。
我们用mysql_close()函数来关闭连接对象。
第三步：查询数据库
一旦我们建立了连接，我们就可以开始查询数据库。这个过程涉及使用mysql_query()函数来执行SQL语句。
在这个例子中，我们将查询一个名为“table”的表格，显示每一行的数据。
#include
#include
int mn()
{
MYSQL *conn;
conn = mysql_init(NULL);
if (!mysql_real_connect(conn, “localhost”, “username”, “password”, “database”, 0, NULL, 0))
{
printf(“Connection Fled: %s\n”, mysql_error(conn));
}
else
{
printf(“Connection Successful\n”);
if (mysql_query(conn, “SELECT * FROM table”))
{
printf(“Query Fled: %s\n”, mysql_error(conn));
}
else
{
MYSQL_RES *res = mysql_store_result(conn);
MYSQL_ROW row;
while ((row = mysql_fetch_row(res)) != NULL)
{
printf(“%s %s\n”, row[0], row[1]);
}
mysql_free_result(res);
}
}
mysql_close(conn);
return 0;
}
在这个例子中，我们使用了mysql_query()函数来执行一个SELECT查询。如果查询失败，我们需要使用mysql_error()函数来输出错误信息。否则，我们将返回一个MYSQL_RES对象，它包含了查询结果。
这里我们使用了mysql_fetch_row()函数来以行的方式读取MYSQL_RES对象中的结果，直到NULL为止。我们将每一行的第一列和第二列输出。
我们用mysql_free_result()函数来释放MYSQL_RES对象。
第四步：插入、更新和删除数据
我们可以使用mysql_query()函数来执行插入、更新和删除等操作。
在下面的例子中，我们将插入一个新的行，然后更新一个行的数据。
#include
#include
int mn()
{
MYSQL *conn;
conn = mysql_init(NULL);
if (!mysql_real_connect(conn, “localhost”, “username”, “password”, “database”, 0, NULL, 0))
{
printf(“Connection Fled: %s\n”, mysql_error(conn));
}
else
{
printf(“Connection Successful\n”);
if (mysql_query(conn, “INSERT INTO table (col1, col2) VALUES (‘value1’, ‘value2’)”))
{
printf(“Query Fled: %s\n”, mysql_error(conn));
}
else
{
printf(“Insert Successful\n”);
}
if (mysql_query(conn, “UPDATE table SET col1 = ‘new_value’ WHERE col2 = ‘value2′”))
{
printf(“Query Fled: %s\n”, mysql_error(conn));
}
else
{
printf(“Update Successful\n”);
}
}
mysql_close(conn);
return 0;
}
在这个例子中，我们使用了mysql_query()函数来执行一个INSERT INTO查询和一个UPDATE查询。我们可以用相同的方式删除一个行，只需在查询中使用DELETE FROM语句即可。
总结
在本文中，我们学习了如何使用C语言来实现MySQL数据库连接驱动。我们已经了解了如何安装MySQL Connector/C、建立连接、查询数据库和插入、更新和删除数据。对于需要从程序中访问MySQL数据库的开发人员，这些都是非常有用的技能。
E. c璇瑷涓璁块梾鏁版嵁搴挞兘鐢ㄥ埌浜嗗摢浜涚被锛
鍦–璇瑷涓锛岃块梾鏁版嵁搴挞氩父娑夊强浣跨敤鏁版嵁搴撴搷浣滃簱锛岃繖浜涘簱鎻愪緵浜嗕竴浜涚被鍜屽嚱鏁版潵镓ц屾暟鎹搴撴搷浣溿傛渶甯哥敤镄勬暟鎹搴撴搷浣滃簱鏄疧DBC锛圤pen Database Connectivity锛夛纴瀹冨厑璁镐娇鐢ㄦ爣鍑嗙殑API鎺ュ彛𨱒ヨ繛鎺ュ拰镎崭綔涓嶅悓绫诲瀷镄勬暟鎹搴撱备互涓嬫槸鍦–璇瑷涓璁块梾鏁版嵁搴撴椂鍙鑳芥秹鍙婄殑涓浜涚被鍜岀浉鍏虫傚康锛
1. **ODBC API锛** ODBC API鏄鏁版嵁搴撹块梾镄勬牳蹇冿纴瀹冩彁渚涗简涓绯诲垪鍑芥暟鐢ㄤ簬杩炴帴鏁版嵁搴撱佹墽琛孲QL镆ヨ銆佽幏鍙栨煡璇㈢粨鏋灭瓑镎崭綔銆
2. **鏁版嵁搴撹繛鎺ョ被锛** 鏁版嵁搴撹繛鎺ョ被鐢ㄤ簬寤虹珛鍜岀＄悊涓庢暟鎹搴撶殑杩炴帴銆傚湪ODBC涓锛屽彲浠ヤ娇鐢╜SQLHDBC`鏁版嵁绫诲瀷琛ㄧず鏁版嵁搴撹繛鎺ュ彞镆勚
3. **SQL璇鍙ユ墽琛岀被锛** 杩欎簺绫荤敤浜庢墽琛孲QL镆ヨ㈣鍙ワ纴鍖呮嫭SELECT銆両NSERT銆乁PDATE銆丏ELETE绛夈傚彲浠ヤ娇鐢╜SQLExecDirect`鍑芥暟镓ц孲QL璇鍙ャ
4. **缁撴灉闆嗙被锛** 褰撴墽琛孲ELECT镆ヨ㈡椂锛屼细鐢熸垚涓涓缁撴灉闆嗭纴琛ㄧず镆ヨ㈢粨鏋溿傚彲浠ヤ娇鐢╜SQLHSTMT`鏁版嵁绫诲瀷琛ㄧず缁撴灉闆嗗彞镆勶纴骞朵娇鐢╜SQLFetch`鍑芥暟銮峰彇缁撴灉闆嗕腑镄勬暟鎹銆
5. **阌栾澶勭悊绫伙细** 鐢ㄤ簬澶勭悊鏁版嵁搴撴搷浣滀腑镄勯敊璇鍜屽纾甯搞傚彲浠ヤ娇鐢╜SQLHENV`鏁版嵁绫诲瀷琛ㄧず鐜澧冨彞镆勶纴骞朵娇鐢╜SQLError`鍑芥暟銮峰彇阌栾淇℃伅銆
6. **鍙傛暟鍖栨煡璇㈢被锛** 鐢ㄤ簬镓ц屽弬鏁板寲镄凷QL镆ヨ锛岄槻姝SQL娉ㄥ叆绛夊畨鍏ㄩ梾棰樸
7. **浜嫔姟绠＄悊绫伙细** 鐢ㄤ簬绠＄悊鏁版嵁搴撶殑浜嫔姟镎崭綔锛屽寘𨰾鎻愪氦鍜屽洖婊氢簨锷°
8. **鏁版嵁搴撹繛鎺ユ睁绫伙细** 鏁版嵁搴撹繛鎺ユ睁鐢ㄤ簬绠＄悊澶氢釜鏁版嵁搴撹繛鎺ワ纴鎻愰珮镐ц兘鍜岃祫婧愬埄鐢ㄧ巼銆
闇瑕佹敞镒忕殑鏄锛孋璇瑷链韬骞舵病链夌被镄勬傚康锛岃屾槸浣跨敤缁撴瀯浣撱佹寚阍埚拰鍑芥暟绛夋潵瀹炵幇闱㈠悜瀵硅薄镄勫姛鑳姐傛暟鎹搴撴搷浣滃簱浼氭彁渚涗竴浜涙暟鎹绫诲瀷鍜屽嚱鏁版潵灏佽呮暟鎹搴撶浉鍏虫搷浣滐纴浣呜繖浜涘苟涓嶆槸浼犵粺镒忎箟涓婄殑绫汇傚湪瀹为檯寮鍙戜腑锛屽彲浠ユ牴鎹镓浣跨敤镄勬暟鎹搴撴搷浣滃簱镄勬枃妗ｅ拰绀轰緥𨱒ヤ简瑙ｅ备綍杩涜屾暟鎹搴撴搷浣溿
F. c语言直接读取sql数据库 直接用读取txt文件的方式行不行
单纯的用c语言不可以，需要混编才能访问数据库。txt文件，单纯的c就可以。
G. c语言如何调用Mysql数据库文件并进行对数据库的操作呢。
MYSQL m_sqlCon;//声明
mysql_init(&m_sqlCon);//初始化
mysql_real_connect(&m_sqlCon, "127.0.0.1", abc, "root", "hibernate", atoi("3306"),NULL,0)//链接
mysql_query(&m_sqlCon, "SET NAMES GB2312"); //设置查询编码格式
res = mysql_query(&m_sqlCon,"select * from ms_sendlist where flag = 1 order by style desc");//查询
mysql_query(&m_sqlCon, sql);//插入，删除