连接 MySQL 数据库

Prev Next

请输入关键字

Recent Pages

文档

Download PDF

连接 MySQL 数据库

最后更新时间：2021-07-13 17:08:06

下载PDF

操作场景

目前，腾讯云原生数据库 TDSQL-C 已支持 Serverless MySQL 版本，做到按实际使用的计算和存储量计费，按秒计量，按小时结算。Serverless Framework 的 CynosDB 组件也已经支持该类型数据库的创建。

本文以 Node.js 开发语言的函数，指导您快速创建 TDSQL-C Serverless MySQL 实例，并在云函数中进行调用。

操作步骤

操作步骤	操作说明
步骤1：配置环境变量	-
步骤2：配置私有网络	通过 Serverless Framework VPC 组件创建 VPC 和子网，支持云函数和数据库的网络打通和使用。
步骤3：配置 Serverless DB	通过 Serverless Framework Cynosdb 组件创建 MySQL 实例，为云函数项目提供数据库服务。
步骤4：编写业务代码	通过 Serverless DB SDK 调用数据库，云函数支持直接调用 Serverless DB SDK，连接 PostgreSQL 数据库进行管理操作。
步骤5：部署应用	通过 Serverless Framework 部署项目至云端，并通过云函数控制台进行测试。
步骤6：移除项目（可选）	可通过 Serverless Framework 移除项目。

步骤1：配置环境变量

在本地建立目录，用于存放代码及依赖模块。本文以 test-MySQL 文件夹为例。
```
mkdir test-MySQL && cd test-MySQL
```
由于目前 TDSQL-C Serverless 只支持 ap-beijing-3，ap-guangzhou-4，ap-shanghai-2 和 ap-nanjing-1 四个区域，所以这里还需要配置下，只需要在项目根目录下创建 .env 文件，然后配置 REGION 和 ZONE 两个环境变量：
```
# .env
REGION=xxx  
ZONE=xxx 
```

步骤2：配置私有网络

在 test-MySQL 目录下创建文件夹 VPC。
```
mkdir VPC && cd VPC
```

在 VPC 中新建 serverless.yml 文件，使用 VPC 组件完成私有网络和子网的创建。
serverless.yml 示例内容如下（全量配置参考产品文档）：

#serverless.yml
app: mysql-app
stage: dev
component: vpc # (required) name of the component. In that case, it's vpc.
name: mysql-app-vpc # (required) name of your vpc component instance.
inputs:
    region: ${env:REGION}
    zone: ${env:ZONE}
    vpcName: serverless-mysql
    subnetName: serverless-mysql

步骤3：配置 Serverless DB

在 test-MySQL 下创建文件夹 DB。

在 DB 文件夹下新建 serverless.yml 文件，并输入以下内容，通过 Serverless Framework 组件完成云开发环境配置。
serverless.yml 示例内容如下（全量配置参考产品文档）：

# serverless.yml 
app: mysql-app
stage: dev
component: cynosdb
name: mysql-app-db
inputs:
  region: ${env:REGION}
  zone: ${env:ZONE}
  vpcConfig:
    vpcId: ${output:${stage}:${app}:mysql-app-vpc.vpcId}
    subnetId: ${output:${stage}:${app}:mysql-app-vpc.subnetId}

步骤4：编写业务代码与配置文件

在 test-MySQL 下创建文件夹 src，用于存放业务逻辑代码和相关依赖项。

在 src 文件夹下创建文件 index.js，并输入如下示例代码。在函数中通过 SDK 连接数据库，并在其中完成 MySQL 数据库的调用。

exports.main_handler = async (event, context, callback) =&gt; {
    var mysql      = require('mysql2');
    var connection = mysql.createConnection({
    host     : process.env.HOST,
    user     : 'root',
    password : process.env.PASSWORD
    });
    connection.connect();
    connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
    if (error) throw error;
    console.log('The solution is: ', results[0].solution);
    });
    connection.end();
 }

安装所需依赖模块。
```
npm install mysql2
```

完成业务代码编写和依赖安装后，创建 serverless.yml 文件，示例文件如下：

app: mysql-app
stage: dev
component: scf
name: mysql-app-scf

inputs:
  src: ./
  functionName: ${name}
  region: ${env:REGION}
  runtime: Nodejs10.15
  timeout: 30
  vpcConfig:
    vpcId: ${output:${stage}:${app}:mysql-app-vpc.vpcId}
    subnetId: ${output:${stage}:${app}:mysql-app-vpc.subnetId}
  environment:
    variables:
      HOST: ${output:${stage}:${app}:mysql-app-db.connection.ip}
      PASSWORD: ${output:${stage}:${app}:mysql-app-db.adminPassword}

步骤5：快速部署

完成创建后，项目目录结构如下：

  ./test-MySQL
  ├── vpc
  │   └── serverless.yml # vpc 配置文件
  ├── db
  │   └── serverless.yml # db 配置文件
  ├── src
  │   ├── serverless.yml # scf 组件配置文件
  │   ├── node_modules # 项目依赖文件
  │   └── index.js # 入口函数
  └── .env # 环境变量文件

使用命令行在 test-MySQL 下，执行以下命令进行部署。

sls deploy

说明：

部署时需要扫码授权，如果没有腾讯云账号，请先注册新账号。

如果是子账号，请参考子账号权限配置完成授权。

返回结果如下所示，即为部署成功。

mysql-app-vpc: 
  region:        xxx
  zone:          xxx
  vpcId:         xxxx-xxx
  ...

mysql-app-db: 
  dbMode:        xxxx
  region:        xxxx
  zone:          xxxx
  ...

mysql-app-scf: 
  functionName:  xxxx
  description:   xxx
  ...

59s › test-MySQL › "deploy" ran for 3 apps successfully.

部署成功后，您可通过云函数控制台，查看并进行函数调试。

步骤6：移除项目（可选）

在 test-MySQL 目录下，执行以下命令可移除项目。

sls remove

返回如下结果，即为成功移除。

serverless ⚡ framework
4s › test-MySQL › Success

示例代码

Python

Python 可使用云函数环境已经内置的 pymysql 依赖包进行数据库连接。示例代码如下：

# -*- coding: utf8 -*-
from os import getenv

import pymysql
from pymysql.err import OperationalError

mysql_conn = None

def __get_cursor():
    try:
        return mysql_conn.cursor()
    except OperationalError:
        mysql_conn.ping(reconnect=True)
        return mysql_conn.cursor()

def main_handler(event, context):
    global mysql_conn
    if not mysql_conn:
        mysql_conn = pymysql.connect(
        host        = getenv('DB_HOST', '<your db="" host="">'),
        user        = getenv('DB_USER','<your db="" user="">'),
        password    = getenv('DB_PASSWORD','<your db="" password="">'),
        db          = getenv('DB_DATABASE','<your db="" database="">'),
        port        = int(getenv('DB_PORT','<your db="" port="">')),
        charset     = 'utf8mb4',
        autocommit  = True
        )
    
    with __get_cursor() as cursor:
        cursor.execute('select * from employee')
        myresult = cursor.fetchall()
        print(myresult)
        for x in myresult:
            print(x)

Node.js

Node.js 支持使用连接池进行连接，连接池具备自动重连功能，可有效避免因云函数底层或者数据库释放连接造成的连接不可用情况。示例代码如下：

说明：

使用连接池前需先安装 mysql2 依赖包，详情请参见依赖安装。

'use strict';

const DB_HOST       = process.env[`DB_HOST`]
const DB_PORT       = process.env[`DB_PORT`]
const DB_DATABASE   = process.env[`DB_DATABASE`]
const DB_USER       = process.env[`DB_USER`]
const DB_PASSWORD   = process.env[`DB_PASSWORD`]

const promisePool = require('mysql2').createPool({
  host              : DB_HOST,
  user              : DB_USER,
  port              : DB_PORT,
  password          : DB_PASSWORD,
  database          : DB_DATABASE,
  connectionLimit   : 1
}).promise();

exports.main_handler = async (event, context, callback) =&gt; {
  let result = await promisePool.query('select * from employee');
  console.log(result);
}

PHP

PHP 可使用 pdo_mysql 或 mysqli 依赖包进行数据连接。示例代码如下：

pdo_mysql

<?php
function handler($event, $context) {
try{
$pdo = new PDO('mysql:host= getenv("DB_HOST");dbname= getenv("DB_DATABASE"),getenv("DB_USER"),getenv("DB_PASSWORD")');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
}catch(PDOException $e){
echo '数据库连接失败: '.$e->getMessage();
exit;
}
}

mysqli

<?php
function main_handler($event, $context) {
 $host = "";
$username = "";
$password = "";
  // 创建连接
$conn = mysqli_connect($servername, $username, $password);
 // 检测连接
if (!$conn) {
    die("Connection failed: " . mysqli_connect_error());
    }
echo "连接成功"; 
 mysqli_close($conn);
echo "断开连接"; 
}
?>

Java

请参考依赖安装，安装以下依赖。

<dependencies>
    <dependency>
        <groupid>com.tencentcloudapi</groupid>
        <artifactid>scf-java-events</artifactid>
        <version>0.0.2</version>
    </dependency>
    <dependency>
        <groupid>com.zaxxer</groupid>
        <artifactid>HikariCP</artifactid>
        <version>3.2.0</version>
    </dependency>
    <dependency>
        <groupid>mysql</groupid>
        <artifactid>mysql-connector-java</artifactid>
        <version>8.0.11</version>
    </dependency>
</dependencies>

使用 Hikari 连接池进行连接，示例代码如下：

package example;

import com.qcloud.scf.runtime.Context;
import com.qcloud.services.scf.runtime.events.APIGatewayProxyRequestEvent;
import com.qcloud.services.scf.runtime.events.APIGatewayProxyResponseEvent;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

public class Http {
    private DataSource dataSource;

    public Http() {
        HikariConfig config = new HikariConfig();
        config.setJdbcUrl("jdbc:mysql://" + System.getenv("DB_HOST") + ":"+ System.getenv("DB_PORT") + "/" + System.getenv("DB_DATABASE"));
        config.setUsername(System.getenv("DB_USER"));
        config.setPassword(System.getenv("DB_PASSWORD"));
        config.setDriverClassName("com.mysql.jdbc.Driver");
        config.setMaximumPoolSize(1);
        dataSource = new HikariDataSource(config);
    }
    
    public String mainHandler(APIGatewayProxyRequestEvent requestEvent, Context context) {
        System.out.println("start main handler");
        System.out.println("requestEvent: " + requestEvent);
        System.out.println("context: " + context);
    
        try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM employee")) {
            ResultSet rs = ps.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getInt("id"));
                System.out.println(rs.getString("first_name"));
                System.out.println(rs.getString("last_name"));
                System.out.println(rs.getString("address"));
                System.out.println(rs.getString("city"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    
        APIGatewayProxyResponseEvent apiGatewayProxyResponseEvent = new APIGatewayProxyResponseEvent();
        apiGatewayProxyResponseEvent.setBody("API GW Test Success");
        apiGatewayProxyResponseEvent.setIsBase64Encoded(false);
        apiGatewayProxyResponseEvent.setStatusCode(200);
    
        Map<string, string=""> headers = new HashMap&lt;&gt;();
        headers.put("Content-Type", "text");
        headers.put("Access-Control-Allow-Origin", "*");
        apiGatewayProxyResponseEvent.setHeaders(headers);
    
        return apiGatewayProxyResponseEvent.toString();
    }
}

SCF DB SDK for MySQL

为了方便使用，云函数团队将 Node.js 和 Python 连接池相关代码封装为 SCF DB SDK for MySQL，请参考依赖安装进行安装使用。通过该 SDK，您可以在云函数代码中连接 MySQL、TDSQL-C 或 TDSQL MySQL版数据库，并实现对数据库的插入、查询等操作。

SCF DB SDK for MySQL 具备以下特点：

自动从环境变量初始化数据库客户端。
SDK 会在全局维护一个数据库长连接，并处理连接中断后的重连。
云函数团队会持续关注 issue，确保获得连接即可用，不需要关注数据库连接。

1. Node.js SDK

'use strict';
const database = require('scf-nodejs-serverlessdb-sdk').database;

exports.main_handler = async (event, context, callback) =&gt; {
  let pool = await database('TESTDB2').pool()
  pool.query('select * from coffee',(err,results)=&gt;{
    console.log('db2 callback query result:',results)
  })
  // no need to release pool

  console.log('db2 query result:',result)
}

说明：

Node.js SDK 具体使用方法请参考 SCF DB SDK for MySQL。

2. Python SDK

from serverless_db_sdk import database

def main_handler(event, context):
    print('Start Serverlsess DB SDK function')

    connection = database().connection(autocommit=False)
    cursor = connection.cursor()
    
    cursor.execute('SELECT * FROM name')
    myresult = cursor.fetchall()
    
    for x in myresult:
        print(x)

联系我们

联系我们，为您的业务提供专属服务。

技术支持

如果你想寻求进一步的帮助，通过工单与我们进行联络。我们提供7x24的工单服务。

7x24 电话支持

tencent cloud

Recent Pages

连接 MySQL 数据库

操作场景

操作步骤

步骤1：配置环境变量

步骤2：配置私有网络

步骤3：配置 Serverless DB

步骤4：编写业务代码与配置文件

步骤5：快速部署

步骤6：移除项目（可选）

示例代码

Python

Node.js

PHP

Java

SCF DB SDK for MySQL

本页内容是否解决了您的问题？

本页内容是否解决了您的问题？

tencent cloud

注册

登录

Recent Pages

连接 MySQL 数据库

操作场景

操作步骤

步骤1：配置环境变量

步骤2：配置私有网络

步骤3：配置 Serverless DB

步骤4：编写业务代码与配置文件

步骤5：快速部署

步骤6：移除项目（可选）

示例代码

Python

Node.js

PHP

Java

SCF DB SDK for MySQL

本页内容是否解决了您的问题？

本页内容是否解决了您的问题？