参数说明
示例程序代码中的参数说明如下:
参数 | 说明 |
---|---|
host | MySQL实例的内网地址或外网地址。 1、内网地址:当应用部署在弹性云主机上,且该弹性云主机与MySQL实例处于同一区域,同一VPC时,建议单独使用内网IP连接弹性云主机与MySQL实例。 2、外网地址:其他情况均使用外网地址。 |
port | 根据您使用的连接地址选择对应的端口。 |
yourDatabase | 所连接的数据库名称。 |
yourUserName | 所访问MySQL实例的账号名称。 |
yourPassword | 所访问MySQL实例的账号对应的密码 |
示例程序代码
说明以下示例程序代码以数据库中的User表为例,实际运行中请按照您的需求填写。
- Java代码示例:
以Maven为例,需要在pom.xml文件中导入DriverManager依赖,例如:
</dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<version>8.1.0</version>
</dependency>
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class DbConnection
{
public static void main(String args[]) {
String connectionUrl= "jdbc:mysql://host:port/yourDatabase";
ResultSet resultSet;
try (Connection connection=DriverManager.getConnection(connectionUrl,"yourUsername","yourPassword");
Statement statement = connection.createStatement()) {
//输入您想要执行的SQL
String selectSql = "SELECT * FROM `User`"; 。
resultSet = statement.executeQuery(selectSql);
//打印出查询结果中想要的列
while (resultSet.next()) {
System.out.println(resultSet.getString("UserName"));
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}
- Python3代码示例:
说明
Python3安装命令:pip3 install PyMySQL
Python2安装命令:pip install pymysql==0.9.3
import pymysql
db_config = {
'host': 'host',
'user': 'user',
'port': port,
'password': 'yourPassword',
'database': 'yourDatabase'
}
connection = pymysql.connect(db_config)
try:
with connection.cursor() as cursor:
# 输入您想要执行的SQL
sql = "SELECT * FROM `User`"
cursor.execute(sql)
for result in cursor:
print(result)
finally:
connection.close()
- C代码示例:
说明运行环境需先安装mysql.h头文件,以CentOS为例,安装命令如下:
sudo yum install mysql-devel
#include <stdio.h>
#include <mysql.h>
#include <string.h>
int main(void)
{
MYSQL *t_mysql;
MYSQL_RES *res = NULL;
MYSQL_ROW row;
int rc, i, fields;
int rows;
char select[] = "select * from User"; // 输入希望执行的SQL。
t_mysql = mysql_init(NULL);
if(NULL == t_mysql){
printf("init failed\n");
}
if(NULL == mysql_real_connect(t_mysql, "host", "yourUsername", "yourPassword", "yourDatabase",
port>, NULL, 0)){
printf("connect failed\n");
}
if(mysql_real_query(t_mysql, select, strlen(select)) != 0){
printf("select failed\n");
}
res = mysql_store_result(t_mysql);
if (NULL == res) {
printf("mysql_restore_result(): %s\n", mysql_error(t_mysql));
return 0;
}
fields = mysql_num_fields(res);
while ((row = mysql_fetch_row(res))) {
for (i = 0; i < fields; i++) {
printf("%s\t", row[i]);
}
printf("\n");
}
mysql_close(t_mysql);
}