FilesExpand file tree

 master

/

mysql_sample.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

76 lines (65 loc) · 2.49 KB

 master

/

mysql_sample.py

Copy path

Top

File metadata and controls

• Code
• Blame

76 lines (65 loc) · 2.49 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

# Copyright 2018 Google LLC

#

# Licensed under the Apache License, Version 2.0 (the 'License');

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

#

# http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an 'AS IS' BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

# [START functions_sql_mysql]

from os import getenv

import pymysql

from pymysql.err import OperationalError

# TODO(developer): specify SQL connection details

CONNECTION_NAME = getenv(

'INSTANCE_CONNECTION_NAME',

'<YOUR INSTANCE CONNECTION NAME>')

DB_USER = getenv('MYSQL_USER', '<YOUR DB USER>')

DB_PASSWORD = getenv('MYSQL_PASSWORD', '<YOUR DB PASSWORD>')

DB_NAME = getenv('MYSQL_DATABASE', '<YOUR DB NAME>')

mysql_config = {

'user': DB_USER,

'password': DB_PASSWORD,

'db': DB_NAME,

'charset': 'utf8mb4',

'cursorclass': pymysql.cursors.DictCursor,

'autocommit': True

}

# Create SQL connection globally to enable reuse

# PyMySQL does not include support for connection pooling

mysql_conn = None

def __get_cursor():

"""

Helper function to get a cursor

PyMySQL does NOT automatically reconnect,

so we must reconnect explicitly using ping()

"""

try:

return mysql_conn.cursor()

except OperationalError:

mysql_conn.ping(reconnect=True)

return mysql_conn.cursor()

def mysql_demo(request):

global mysql_conn

# Initialize connections lazily, in case SQL access isn't needed for this

# GCF instance. Doing so minimizes the number of active SQL connections,

# which helps keep your GCF instances under SQL connection limits.

if not mysql_conn:

try:

mysql_conn = pymysql.connect(**mysql_config)

except OperationalError:

# If production settings fail, use local development ones

mysql_config['unix_socket'] = f'/cloudsql/{CONNECTION_NAME}'

mysql_conn = pymysql.connect(**mysql_config)

# Remember to close SQL resources declared while running this function.

# Keep any declared in global scope (e.g. mysql_conn) for later reuse.

with __get_cursor() as cursor:

cursor.execute('SELECT NOW() as now')

results = cursor.fetchone()

return str(results['now'])

# [END functions_sql_mysql]