mysql怎么搭建接口 mysql数据库接口如何写( 二 )


Connection getConnection(String url,String user , String password)
例子:
import java.sql.Connection;
import java.sql.DriverManager;
public class Conn {
// 非链接池
public static Connection getConn() {
// 建立连接对象
Connection conn = null;
// 说明JDBC驱动类所在位置的字符串,与驱动所在目录对应 。
String driver = "com.mysql.jdbc.Driver";
// MySQL的JDBC URL 字符串
// 连接到本地主机,端口为3306,数据库为mysql , 
String sourse = "jdbc:mysql://127.0.0.1:3306/dq?characterEncoding=utf-8";
try {
// 初始化MySQL的JDBC桥驱动类
Class.forName(driver);
// 使用DriverManager类的getConnection方法建立连接 。url=sourse,用户名为root,密码为空 。
conn = DriverManager.getConnection(sourse, "root", "");
} catch (Exception e) {
System.out.println(e.toString());
}
// 返回连接对象
return conn;
}
public static void main(String[] args) {
System.out.println(Conn.getConn());
}
}
// import java.sql.*;
//
// public class mysqlDEMO{
// public static void main(String []args)throws Exception{
// //说明JDBC驱动类所在位置的字符串,与驱动所在目录对应
// String mysqldriver="org.mm.mysql.Driver";
// //MySQL的JDBC URL字符串
// //连接到本地主机,端口为3306 , 数据库为mysql,用户名为root,密码为空 。
// String url="jdbc:mysql://localhost:3306/mysql?user=root;password=";
// //建立连接对象
// Connection conn;
// //初始化MyJDBC的JDBC桥驱动类
// Class.forName(mysqldriver);
// //使用DriverManager类的getConnection方法建立连接
// conn=DriverManager.getConnection(url,"","");
// }
// } 驱动需要加载
如何将mysql代码封装成一个接口,然后留一个这个基本上有现成的组件,你需要封装什么?java开源的东西建议你去研究一下 。。
如何在vs2010中添加mysql 5.1数据库 api方法通过MySQL自定义的API函数进行连接
1、使用API的方式连接,需要加载mysql的头文件和lib文件 。
在VS2010的附加包含目录中添加\MySQL\MySQL Server 5.1\include 。在安装MySql的目录下找 。把libmysql.dll和libmysql.lib文件拷贝到所建的工程目录下 。然后在头文件里包含以下内容:
//mysql所需的头文件和库文件
#include "winsock.h"
#include "mysql.h"
#pragma comment(lib,"libmySQL.lib")
2、进行编码
(1)连接mysql数据库
头文件里定义数据源指针 MYSQL m_sqlCon;
//连接MySql数据库
try
{
mysql_init(m_sqlCon);
// localhost:服务器 root为账号密码 test为数据库名 3306为端口
if(!mysql_real_connect(m_sqlCon, "localhost","root","root","test",3306,NULL,0))
{
AfxMessageBox(_T("数据库连接失败!"));
return FALSE;
}
return TRUE;
}
catch (...)
{
return FALSE;
}
(2)关闭数据库
mysql_close(m_sqlCon);
(3)创建表
char* pQuery = "create table if not exists DS_Building( ID VARCHAR(10),Name VARCHAR(255),Descs VARCHAR(255),PRIMARY KEY (ID))"
if(mysql_real_query(m_sqlCon,pQuery,(UINT)strlen(pQuery))!=0)
{
const char* pCh = mysql_error(m_sqlCon);
return FALSE;
}
附MySQL的API接口:
mysql_affected_rows() 返回被最新的UPDATE, DELETE或INSERT查询影响的行数 。
mysql_close() 关闭一个服务器连接 。
mysql_connect() 连接一个MySQL服务器 。该函数不推荐;使用mysql_real_connect()代替 。
mysql_change_user() 改变在一个打开的连接上的用户和数据库 。
mysql_create_db() 创建一个数据库 。该函数不推荐;而使用SQL命令CREATE DATABASE 。

推荐阅读