【腾讯犀牛鸟开源课题实战】对接mysql sdk

CMakeLists.txt

@@ -158,6 +158,7 @@ include(snappy)
 include(lz4)
 include(toml11)
 include(flatbuffers)
+include(mysqlclient)
 
 #---------------------------------------------------------------------------------------
 # Set complie options and include other libs if options are ON

cmake/config/trpc_config.cmake

@@ -55,7 +55,8 @@ set(INCLUDE_PATHS   ${TRPC_ROOT_PATH}
                     ${TRPC_ROOT_PATH}/cmake_third_party/nghttp2/lib/includes
                     ${TRPC_ROOT_PATH}/cmake_third_party/picohttpparser
                     ${TRPC_ROOT_PATH}/cmake_third_party/snappy
-                    ${TRPC_ROOT_PATH}/cmake_third_party/lz4)
+                    ${TRPC_ROOT_PATH}/cmake_third_party/lz4
+                    ${TRPC_ROOT_PATH}/cmake_third_party/mysqlclient/include)
 
 # When use tRPC as a third-party library, selectively inject the header files at including any-lib.cmake.
 set(TARGET_INCLUDE_PATHS  ${TRPC_ROOT_PATH})
@@ -106,6 +107,7 @@ set(LIBS_BASIC
                     snappy
                     lz4
                     flatbuffers
+                    mysqlclient
                     pthread
                     z
                     dl

cmake/mysqlclient.cmake

@@ -0,0 +1,52 @@
+# mysqlclient.cmake
+
+include(FetchContent)
+
+
+if(NOT DEFINED MYSQLCLIENT_VERSION_TAG)
+    set(MYSQLCLIENT_VERSION_TAG 8.0.39)
+endif()
+
+string(REGEX REPLACE "^([0-9]+\\.[0-9]+)\\..*" "\\1" MYSQLCLIENT_MAJOR_VER "${MYSQLCLIENT_VERSION_TAG}")
+set(MYSQLCLIENT_URL "https://dev.mysql.com/get/Downloads/MySQL-${MYSQLCLIENT_MAJOR_VER}/mysql-${MYSQLCLIENT_VERSION_TAG}-linux-glibc2.17-x86_64-minimal.tar.xz")
+
+
+FetchContent_Declare(
+        mysqlclient
+        URL         ${MYSQLCLIENT_URL}
+        SOURCE_DIR  ${TRPC_ROOT_PATH}/cmake_third_party/mysqlclient
+)
+
+FetchContent_GetProperties(mysqlclient)
+if(NOT mysqlclient_POPULATED)
+    FetchContent_Populate(mysqlclient)
+endif()
+
+set(MYSQLCLIENT_INCLUDE_DIR "${mysqlclient_SOURCE_DIR}/include")
+set(MYSQLCLIENT_LIB_DIR "${mysqlclient_SOURCE_DIR}/lib")
+
+
+file(MAKE_DIRECTORY "${MYSQLCLIENT_INCLUDE_DIR}/mysqlclient")
+file(GLOB MYSQL_HEADERS "${mysqlclient_SOURCE_DIR}/include/*.h")
+
+# for #include "mysqlclient/mysql.h", otherwise we will directly #include "mysql.h"
+file(COPY ${MYSQL_HEADERS} DESTINATION "${MYSQLCLIENT_INCLUDE_DIR}/mysqlclient")
+
+
+add_library(mysqlclient STATIC IMPORTED)
+
+set_target_properties(mysqlclient PROPERTIES
+        IMPORTED_LOCATION "${MYSQLCLIENT_LIB_DIR}/libmysqlclient.a"
+        INTERFACE_INCLUDE_DIRECTORIES "${MYSQLCLIENT_INCLUDE_DIR}"
+)
+
+target_link_libraries(mysqlclient INTERFACE
+        "${MYSQLCLIENT_LIB_DIR}/private/libcrypto.so"
+        "${MYSQLCLIENT_LIB_DIR}/private/libssl.so"
+)
+
+add_library(trpc_mysqlclient ALIAS mysqlclient)
+
+
+set(TARGET_INCLUDE_PATHS ${TARGET_INCLUDE_PATHS} ${TRPC_ROOT_PATH}/cmake_third_party/mysqlclient/include)
+set(TARGET_LINK_LIBS  ${TARGET_LINK_LIBS} trpc_mysqlclient)

examples/features/mysql/CMakeLists.txt

@@ -0,0 +1,18 @@
+
+cmake_minimum_required(VERSION 3.14)
+
+include(../cmake/common.cmake)
+
+#---------------------------------------------------------------------------------------
+# Compile project
+#---------------------------------------------------------------------------------------
+project(features_mysql)
+
+# compile client
+file(GLOB SRC_FILES ${CMAKE_CURRENT_SOURCE_DIR}/client/fiber/*.cc)
+add_executable(fiber_client ${SRC_FILES})
+target_link_libraries(fiber_client ${LIBRARY})
+
+file(GLOB SRC_FILES ${CMAKE_CURRENT_SOURCE_DIR}/client/future/*.cc)
+add_executable(future_client ${SRC_FILES})
+target_link_libraries(future_client ${LIBRARY})

examples/features/mysql/client/create_table.sql

@@ -0,0 +1,20 @@
+CREATE DATABASE IF NOT EXISTS test;
+
+USE test;
+
+DROP TABLE IF EXISTS users;
+
+CREATE TABLE `users` (
+ `id` int NOT NULL AUTO_INCREMENT,
+ `username` varchar(50) NOT NULL,
+ `email` varchar(100) DEFAULT NULL,
+ `created_at` timestamp NULL DEFAULT CURRENT_TIMESTAMP,
+ `meta` blob,
+ PRIMARY KEY (`id`)
+);
+
+INSERT INTO users (username, email, created_at, meta) VALUES
+              ('alice', 'alice@example.com', '2024-09-08 13:16:24', NULL),
+              ('bob', 'bob@abc.com', '2024-09-08 13:16:24', NULL),
+              ('carol', 'carol@example.com', '2024-09-08 13:16:24', NULL),
+              ('rose', NULL, '2024-09-08 13:16:53', NULL);

examples/features/mysql/client/fiber/BUILD

@@ -0,0 +1,15 @@
+cc_binary(
+    name = "fiber_client",
+    srcs = ["fiber_client.cc"],
+    deps = [
+        "@com_github_gflags_gflags//:gflags",
+        "@trpc_cpp//trpc/client:client_context",
+        "@trpc_cpp//trpc/client:make_client_context",
+        "@trpc_cpp//trpc/client:trpc_client",
+        "@trpc_cpp//trpc/client/mysql:mysql_service_proxy",
+        "@trpc_cpp//trpc/common:runtime_manager",
+        "@trpc_cpp//trpc/common:trpc_plugin",
+        "@trpc_cpp//trpc/coroutine:fiber",
+        "@trpc_cpp//trpc/util:latch",
+    ],
+)