C&C++   发布时间:2022-04-03  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了C基础 mariadb处理的简单实例大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

引言

@H_41_0@mariaDB 是一款灰常不错开源数据库. 这里直接用它来解决业务问题.

业务需求

现在数据库中表示按照天分表的. 突然我们需要按照月来处理数据.

例如输入一个玩家id,查找这个玩家这个月内看了一件事几次. 我们先搭建一个环境.

操作系统:

Linux version 4.4.0-22-generic (buildd@lgw01-41)
(gcc version 5.3.1 20160413 (Ubuntu 5.3.1-14ubuntu2) ) 
#40-Ubuntu SMP Thu May 12 22:03:46 UTC 2016

首先安装 MariaDB数据库

sudo apt-get install mariadb-server
sudo apt-get install mariadb-client
sudo apt-get install libmariadb2
sudo apt-get install libmariadb-client-lgpl-dev
sudo apt-get install libreoffice-mysql-connector

后面是C访问 MariaDB驱动. 这里扯一点,目前关于MariaDB不懂问题,搜不见直接当成MysqL开始搜.

@H_41_0@mariaDB安装成功后认是开启的,看下面图描述

C基础 mariadb处理的简单实例

后面搭建测试环境 首先 看 oss_musicelves.sql

-- MysqL dump 10.10
--
-- Host: localhost  Database: oss_log
-- ------------------------------------------------------
-- Server version  5.5.24-tMysqL-1.4

/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
/*!40101 SET NAMES utf8 */;
/*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */;
/*!40103 SET TIME_ZONE='+00:00' */;
/*!40014 SET @OLD_UNIQUE_checKS=@@UNIQUE_checKS,UNIQUE_checKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_checKS=@@FOREIGN_KEY_checKS,FOREIGN_KEY_checKS=0 */;
/*!40101 SET @OLD_sql_mode=@@sql_mode,sql_mode='NO_AUTO_VALUE_ON_ZERO' */;
/*!40111 SET @OLD_sql_NOTES=@@sql_NOTES,sql_NOTES=0 */;

--
-- Table structure for table `oss_musicelves`
--

drop table IF EXISTS `oss_musicelves`;
create table `oss_musicelves` (
 `record_id` bigint(20) NOT NULL AUTO_INCREMENT,`account_id` bigint(20) NOT NULL,`server_id` int(11) NOT NULL,`char_id` bigint(20) NOT NULL,`char_sex` int(11) NOT NULL,`type_id` int(11) NOT NULL,`timestamp` datetiR_362_11845@e NOT NULL DEFAULT '0000-00-00 00:00:00',`ptype` int(11) NOT NULL,`specifytype` int(11) NOT NULL,`childtype` int(11) NOT NULL,PRIMARY KEY (`record_id`),KEY `idx_specifytype` (`specifytype`)
) ENGINE=InnoDB AUTO_INCREMENT=32 DEFAULT CHARSET=latin1;

--
-- Dumping data for table `oss_musicelves`
--


/*!40000 alter table `oss_musicelves` DISABLE KEYS */;
LOCK TABLES `oss_musicelves` WRITE;
INSERT INTO `oss_musicelves` VALUES (1,411948833,84869352,27899597414400801,1812,'2016-05-31 14:27:41',1,1),(2,1344702709,90964200,30422720614402293,'2016-05-31 14:58:26',(3,706409913,30422720614401465,'2016-05-31 14:58:27',2),(4,392964857,'2016-05-31 14:58:59',2,4),(5,(6,'2016-05-31 15:04:52',(7,'2016-05-31 15:05:54',(8,(9,'2016-05-31 15:10:29',(10,'2016-05-31 15:10:32',(11,'2016-05-31 15:10:54',(12,3145910262,29520779366416374,'2016-05-31 15:30:00',(13,1372825842,30173879500803314,'2016-05-31 15:30:01',(14,'2016-05-31 15:30:04',(15,(16,'2016-05-31 15:34:24',(17,(18,'2016-05-31 15:40:14',(19,'2016-05-31 15:40:16',(20,'2016-05-31 15:42:19',(21,(22,1027763684,30175730790400484,'2016-05-31 16:56:33',(23,'2016-05-31 16:56:50',(24,'2016-05-31 16:57:37',3),(25,(26,'2016-05-31 17:04:33',(27,(28,'2016-05-31 17:14:15',(29,'2016-05-31 17:14:50',(30,(31,751699770,30175199027201850,'2016-05-31 18:14:59',1);
UNLOCK TABLES;
/*!40000 alter table `oss_musicelves` ENABLE KEYS */;
/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;

/*!40101 SET sql_mode=@OLD_sql_mode */;
/*!40014 SET FOREIGN_KEY_checKS=@OLD_FOREIGN_KEY_checKS */;
/*!40014 SET UNIQUE_checKS=@OLD_UNIQUE_checKS */;
/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;
/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;
/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
/*!40111 SET sql_NOTES=@OLD_sql_NOTES */;

这个 oss_musicelves.sql 文件主要功能是创建 oss_musicelves数据库,并填充数据.

还有一个 搭建环境 的 脚本 mariadb_test.sql 和上一个sql文件放在同一个目录下

# 创建一个测试数据库
create database oss_log;

# 进入oss_log 数据库
use oss_log;

# 创建 oss_musicelves 数据库,并导入数据
source oss_musicelves.sql;

# 批量创建表和数据
create table 2016_6_1_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_2_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_3_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_4_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_5_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_9_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_10_oss_musicelves SELEct * from oss_musicelves;
create table 2016_6_12_oss_musicelves SELEct * from oss_musicelves;

# 查询表是否创建成功
show tables;

# 这里处理 拿到的数据
SELEct disTinct table_name from information_scheR_362_11845@a.columns where table_name like '2016_6_%_oss_musicelves';

直接放在 MariaDB控制台中直接刷进去. 搭建的具体环境如下

C基础 mariadb处理的简单实例

到这里环境基本搭建好了. MariaDB入门等等,完全可以当做MysqL 学习温故一遍.

前言

上面问题就是 原本 是 SELEct * from oss_musicelves; 就可以解决的问题.

这里 需要 输入年和月 外加一些特殊条件 . SELEct * from %_%_%_oss_musicelves; 解决. 单纯用sql脚本也可以解决.非常复杂.用的不熟.

这里首先通过 sHell 脚本处理

touch getmouths.sh
chmod +x getmouths.sh
vi getmouths.sh

 具体的脚本 内容 如下

#!/bin/sh

#得到输入的玩家ptid
if [ $# -lt 1 ]
then
  echo "uage: $0 [ptid]"
  exit -1
fi
ptid=$1

mouth=$(date +%m | sed s'/^0//')
#第一个参数是月份
if [ $# -ge 2 ]
then
  mouth=$2
fi

#第二个参数是年
year=$(date +%Y)
if [ $# -ge 3 ]
then
  year=$3
fi

#得到查询随机表名
tbname="\"${year}_${mouth}_%_oss_musicelves\""

#这里得到MysqL 中所有合法表名
rm -rf __tmp
touch __tmp

#开始查询数据库了,需要以root权限启动这个脚本
MysqL -e "SELEct disTinct table_name from information_scheR_362_11845@a.columns where table_name like $tbname" | awk 'NR>1' | while read name
do
  MysqL -e "SELEct count(*) from oss_log.$name where specifytype = 1 and char_id = $ptid" | awk 'NR>1' | while read cut
  do
    echo "$name : $cut"
    echo $cut >> __tmp
    break
  done
done

#统计表里面的数据
sum=$(cat __tmp | awk '{s+=$1} END {print s}')
rm -rf __tmp

# 最后输出统计结果
echo "$year-$mouth sum: $sum"

使用脚本  截图

C基础 mariadb处理的简单实例

通过sHell可以完成 我们的需求. Linux上sHell真好用. window的bat不好用.

正文

第一部分 : 让C@L_649_59@mariaDB跑通

先看 测试Demo mariadb_demo.c

#include <stdio.h>
#include <stdlib.h>
#include <MysqL.h>

/*
 * 第一个 mariadb程序
 */
int main(int argc,char *argv[]) {
  // 创建数据连接对象
  MysqL *con = MysqL_init(null);
   if (con == NULL) {
    fprintf(stderr,"%s\n",MysqL_error(con));
    exit(EXIT_FAILURE);
   }

   if (!MysqL_real_connect(con,"localhost","root","",NULL,0)) {
    fprintf(stderr,MysqL_error(con));
     MysqL_close(con);
     exit(EXIT_FAILURE);
   } 

   if (MysqL_query(con,"show databases;")) {
    fprintf(stderr,MysqL_error(con));
    MysqL_close(con);
    exit(EXIT_FAILURE);
   }

  puts("mariadb is connect and run succesed!");
  MysqL_close(con);  

  return 0;
}

具体的编译 命令

su root
gcc -Wall -ggdb2 -I/usr/include/mariadb -o mariadb_demo.out mariadb_demo.c -lMysqLclient
./mariadb_demo.out 

运行结果 如下 

@H_673_135@

到这里基本C 调用 MariaDB 基本流程跑通了. 但是很不爽. 只能通过root用户使用.

那我们改变这里不爽. 进入第二部分. 扩展资料  c in mariadb  http://stackoverflow.com/questions/17265471/using-mariadb-in-c

第二部分 : 通过普通用户完成业务需求.

先创建普通用户 csz,密码是 1413222,并并且给其 SELEct 读权限

su root
MysqL

drop user csz;
create user 'csz'@'%' identified by '13142222';
grant SELEct on *.* to 'csz'@'%';
# 立即刷新
flush privileges;

后面登录试试

MysqL -ucsz -p1314222 -h127.0.0.1

 

C基础 mariadb处理的简单实例

 主要是mariadb关闭远程访问. 后面我们开启安全访问模式试试

su root/etc/init.d/MysqL stopMysqLd_safe --skip-grant-tables

 

C基础 mariadb处理的简单实例

后面再开启一个会话 . 重新输入 MysqL -ucsz -p1314222 -h127.0.0.1,解决可以了
 

C基础 mariadb处理的简单实例

#目标拼接 串内容
SELEct sum(c) from (
SELEct count(*) as c from 2016_6_1_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_2_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_3_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_4_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_5_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_9_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_10_oss_musicelves where specifytype=1 and char_id = 30422720614402293
union all
SELEct count(*) from 2016_6_12_oss_musicelves where specifytype=1 and char_id = 30422720614402293
) as t;

具体看 getmouths.c 文件 内容

#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <MysqL.h>

#define _INT_BUF (4098)
// 得到查询数据表内容
#define _STR_sqlTABLES \
  "SELEct disTinct table_name from information_scheR_362_11845@a.columns where table_name like '%d_%d_%%_oss_musicelves'"
#define _STR_sqlSELECT \
  "SELEct count(*) as c from %s where specifytype=1 and char_id = %lld"

// 基础的mariadb 错误关闭函数
static inline void _err_mariadb(MysqL *con) {
  fprintf(stderr,"_err_mariadb error: %s\n",MysqL_error(con));
  MysqL_close(con);
  exit(EXIT_FAILURE);
}

/*
 * 处理 oss_musicelves 一个月的所有表.
 */
int main(int argc,char* argv[]) {
  long long ptid;
  time_t rt = time(null);
  struct tm *pt = localtime(&rt);
  int year = pt->tm_year + 1900;
  int mouth = pt->tm_mon + 1;  

  // 先简单检测输入
  if(argc <= 1) {
    fprintf(stderr,"%s [ptid] [mouth] [year]\n",argv[0]);
    exit(EXIT_FAILURE);
  }  

  // 先得到 ptid 数据
  ptid = atoll(argv[1]);  
  // 得到当前月份
  if(argc >= 3)
    mouth = atoi(argv[2]);
  // 得到当前年份
  if(argc >= 4)
    year = atoi(argv[3]);
  // 简单检测结果是否合法
  if(ptid < 0 || mouth <=0 || mouth>12 || year<1900) {
    fprintf(stderr,"%s %lld %d %d is error!\n",argv[0],ptid,mouth,year);
    exit(EXIT_FAILURE);
  } 

  // 输出结果
  printf("%s %lld %d %d start run!\n",year);

  // 开始用MysqL 访问我们需要访问的数据结果了
  MysqL *con = MysqL_init(null);
  if(con == NULL) {
   fprintf(stderr,"MysqL_init error: %s\n",MysqL_error(con));
   exit(EXIT_FAILURE);
   }
   if(!MysqL_real_connect(con,"127.0.0.1","csz","1314222","oss_log",0))
    _err_mariadb(con);
  
  char sqls[_INT_BUF];
  int sqlen = 0;
  sprintf(sqls,_STR_sqlTABLES,year,mouth);
  if(MysqL_query(con,sqls))
    _err_mariadb(con);
  
  // 开始得到结果
  MysqL_RES *ret = MysqL_store_result(con);
  if(NULL == ret)
    _err_mariadb(con);
  MysqL_ROW row;
  int i = 0,nr = 0;
  while(!!(row = MysqL_fetch_row(ret))) {  
    if(i == 0) {
      sqlen = sprintf(sqls,"SELEct sum(c) from (\n" _STR_sqlSELECT,row[0],ptid);
      i = 1;
      conTinue;
    }    
    // 后面正常拼接
    nr = sprintf(sqls + sqlen,"\nunion all\n" _STR_sqlSELECT,ptid);
    if((sqlen += nr) >= _INT_BUF) {
      fprintf(stderr,"sprintf while %d too length.\n",sqlen);
      goto __return_free;
    }
  }
  if(i == 0)   {
    printf("sum %lld %d/%d: 0\n",mouth);
    goto __return_free;
  }
  
  // 这里处理有的数据
  nr = sprintf(sqls + sqlen,"\n) as t;");  
  if((sqlen += nr) >= _INT_BUF) {
    fprintf(stderr,"sprintf end %d too length.\n",sqlen);
    goto __return_free;
  }
  // 内存用完了就直接释放
  MysqL_free_result(ret);
  ret = NULL;
  

  printf("sql : \n\t%s\n",sqls);
  // 开始输出统计结果
  if(MysqL_query(con,sqls))
    _err_mariadb(con);
  if((ret = MysqL_store_result(con))==NULL)
    _err_mariadb(con);
  //得到结果直接返回
  if(!!(row=MysqL_fetch_row(ret)))
    printf("sum %lld %d/%d: %s\n",row[0]);
  else
    puts("SELEct is empty!");

    
__return_free:
  // 释放用过的内存
  MysqL_free_result(ret);
  // 关闭打开的 数据库访问对象
   MysqL_close(con);
  return 0;
}

编译命令

gcc -Wall -ggdb2 -I/usr/include/mariadb -o getmouths.out getmouths.c -lMysqLclient

最终运行结果是

C基础 mariadb处理的简单实例

如果想详细了解关于mariadb c驱动的api使用,可以参照老外写的很好理解.

 MysqLc demo http://zetcode.com/db/MysqLc/

到这里就结束了,关于C 访问数据库能力也基本打通了.

后记

错误是难免,欢迎学习进步~~~   未来什么都不确定,可以确定是没有未来,只有现在还在装逼 . 

以上这篇C基础 mariadb处理的简单实例就是小编分享给大家的全部内容了,希望能给大家一个,也希望大家多多支持编程小技巧。

大佬总结

以上是大佬教程为你收集整理的C基础 mariadb处理的简单实例全部内容,希望文章能够帮你解决C基础 mariadb处理的简单实例所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签:处理