文档章节

数据库的使用

ruki
 ruki
发布于 2014/08/21 10:04
字数 1485
阅读 34
收藏 1

TBOX目前支持sqlite3、mysql两种关系型数据库(需要链接对应的libsqlite3.a和libmysql.a),并对其接口进行了封装,使用更加的方便简洁并且只需要换个url,就可以随时切换成其他数据库引擎,而不需要修改接口。

下面先看个简单的例子:

/* 初始化一个mysql数据库
 *
 * localhost:   主机名,也可以是ip地址
 * type:        数据库的类型,目前支持:mysql 和 sqlite3两种类型
 * username:    数据库用户名
 * password:    数据库用户密码
 * database:    要访问的数据库名称, 如果不设置则自动连接默认的数据库
 *
 * 若果逆向指定个端口,可以显示传入:
 * "sql://localhost:3306/?type=mysql&username=xxxx&password=xxxx&database=xxxx"
 *
 * sqlite3的数据库访问url为:
 * "sql:///home/file.sqlitedb?type=sqlite3"
 *
 * 或者直接传文件路径:
 * "/home/file.sqlite3"
 * "file:///home/file.sqlitedb"
 * "C://home/file.sqlite3"
 */
tb_database_sql_ref_t database = tb_database_sql_init("sql://localhost/?type=mysql&username=xxxx&password=xxxx&database=test");
if (database)
{
    // 打开数据库
    if (tb_database_sql_open(database))
    {
        // 执行sql语句,进行查询
        if (tb_database_sql_done(database, "select * from test"))
        {
            /* 加载结果集
             *
             * 如果是insert, update等非select语句执行,这个时候返回tb_null, 说明没有结果集
             *
             * 这个结果集完全采用迭代器模式,方便快速迭代访问。
             *
             * 后面的参数tb_true指示尽量一次性加载所有结果到内存,如果成功
             * 就可以通过tb_iterator_size(result)获取实际的结果集行数。
             *
             * 如果一次性加载失败或者传入的是tb_false, 说明只能通过fetch,一行行的回滚数据行
             * 这样占用内存的资源较少,但是没法提前获取到实际的行数,这个时候tb_iterator_size(result)
             * 返回的是一个超大值
             */
            tb_iterator_ref_t result = tb_database_sql_result_load(database, tb_true);
            if (result)
            {
                // 如果一次性加载成功,返回实际的结果行数
                tb_trace_i("row: size: %lu", tb_iterator_size(result));
                
                // 遍历所有行
                tb_for_all_if (tb_iterator_ref_t, row, result, row)
                {
                    // 显示行的列数
                    tb_trace_i("[row: %lu, col: size: %lu]: ", row_itor, tb_iterator_size(row));
                    
                    // 遍历这一行中的所有值
                    tb_for_all_if (tb_database_sql_value_t*, value, row, value)
                    {
                        /* tb_database_sql_value_name(value): 获取值所对应列名
                         * tb_database_sql_value_text(value):获取值的文本数据,如果是text类型的话
                         * tb_database_sql_value_type(value):获取值的类型
                         *
                         * ...
                         */
                        tb_tracet_i("[%s:%s] ", tb_database_sql_value_name(value), tb_database_sql_value_text(value));
                    }
                }
                
                // 释放结果集数据
                tb_database_sql_result_exit(database, result);
            }
        }
        else
        {
            // 执行失败,显示失败状态和原因
            tb_trace_e("done %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        }
    }
    else
    {
        // 打开失败,显示失败状态和原因
        tb_trace_e("open failed: %s", tb_state_cstr(tb_database_sql_state(database)));
    }
    
    // 退出数据库
    tb_database_sql_exit(database);
}

上面的例子没法处理二进制数据,如果要处理二进制数据,比如插入一个图像数据什么的可以使用statement模式,预编译一个sql语句,bind每个参数来实现,这种方式更加的灵活而且对于频繁处理某个sql语句的情况,效率更高,因为省去每次都要解析一遍sql语法的过程。

具体使用过程也很简单,下面先看个insert二进制数据的例子:

// done
tb_database_sql_statement_ref_t     stmt = tb_null;
tb_stream_ref_t                     stream = tb_null;
do
{
    // 初始化一个插入语句,需要自定义传入的参数用?代替, 并进行预编译处理
    if (!(stmt = tb_database_sql_statement_init(database, "insert into table2 values(?, ?, ?, ?, ?, ?, ?)")))
    {
        // trace
        tb_trace_e("stmt: init %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        break ;
    }
    
    // 初始化一个超大图像数据流
    stream = tb_stream_init_from_url("/tmp/large_image.png");
    tb_assert_and_check_break(stream);
    
    // 打开流
    if (!tb_stream_open(stream)) break;
    
    // 参数列表
    tb_database_sql_value_t list[7];

    // 绑定一个text类型的参数,sql中对应:text
    tb_database_sql_value_set_text(&list[0], "hello", 0);

    // 绑定一个uint16大小的blob数据参数,由于是小块数据,不用使用stream,sql中对应:blob
    tb_database_sql_value_set_blob16(&list[1], data, size);

    // 绑定一个uint8大小的超小数据块,节省存储空间,sql中对应:tinyblob
    tb_database_sql_value_set_blob8(&list[2], data, size);

    // 绑定一个uint32大小的超大数据块,sql中对应:longblob
    tb_database_sql_value_set_blob32(&list[3], data, size, tb_null);

    // 绑定一个uint32大小的超大数据流,这样比较节省内存,不会一次性加载数据到内存中来处理,sql中对应:longblob
    tb_database_sql_value_set_blob32(&list[4], tb_null, 0, stream);

    // 绑定一个int32整数,sql中对应int
    tb_database_sql_value_set_int32(&list[5], number);

    // 绑定一个int16整数,sql中对应smallint
    tb_database_sql_value_set_int16(&list[6], snumber);
    
    // 绑定参数列表
    if (!tb_database_sql_statement_bind(database, stmt, list, tb_arrayn(list)))
    {
        // trace
        tb_trace_e("stmt: bind %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        break ;
    }
    
    // 执行预编译的sql语句
    if (!tb_database_sql_statement_done(database, stmt))
    {
        // trace
        tb_trace_e("stmt: done %s failed, error: %s", sql, tb_state_cstr(tb_database_sql_state(database)));
        break ;
    }
    
} while (0);

// 删除sql语句对象
if (stmt) tb_database_sql_statement_exit(database, stmt);

// 退出数据流
if (stream) tb_stream_exit(stream);

对于获取对应结果集数据,使用的接口和第一个例子一样,可以直接进行迭代 也可以通过索引直接访问其中某列的数据:

// 按回滚方式加载结果集
tb_iterator_ref_t result = tb_database_sql_result_load(database, tb_false);
if (result)
{
    // 遍历行
    tb_for_all_if (tb_iterator_ref_t, row, result, row)
    {
        // 获取text数据
        tb_database_sql_value_t const* name = tb_iterator_item(row, 0);
        tb_assert_and_check_break(name);
        tb_tracet_i("[%s:%s] ", tb_database_sql_value_name(name), tb_database_sql_value_text(name));
        
        // 获取blob16数据
        tb_database_sql_value_t const* data = tb_iterator_item(row, 1);
        tb_assert_and_check_break(data);
        tb_tracet_i("[%s:%s] ", tb_database_sql_value_name(data), tb_database_sql_value_blob(data));
        
        // 获取blob32数据
        tb_database_sql_value_t const* ldata = tb_iterator_item(row, 4);
        tb_assert_and_check_break(ldata);
        {
            /* 优先尝试获取数据buffer,如果存在的话
             *
             * 针对小块数据进行了优化,就算是blob32的数据,如果数据大小
             * 本身不大,会直接存到内存buffer中去,来快速读取
             */
            tb_stream_ref_t     stream = tb_null;
            if (tb_database_sql_value_blob(ldata))
            {
                // 获取数据和大小
                tb_byte_t const*    data = tb_database_sql_value_blob(ldata);
                tb_size             size = tb_database_sql_value_size(ldata);
                // ...

            }
            // 如果获取不到数据buffer,说明数据量很大,尝试获取数据流来处理
            else if ((stream = tb_database_sql_value_blob_stream(ldata)))
            {
                // 进行stream的数据读取,注:这个流不支持写操作,只能用来读
                // ...

            }
        }
        
        // 获取int32数据,如果是int8, int16 或者float类型的数据,会自动进行强转
        tb_database_sql_value_t const* number = tb_iterator_item(row, 5);
        tb_assert_and_check_break(number);
        tb_tracet_i("[%s:%d] ", tb_database_sql_value_name(number), tb_database_sql_value_int32(number));
        
    }
    
    // 退出结果集
    tb_database_sql_result_exit(database, result);
}

本文转载自:http://tboox.org/cn/2016/09/18/database-usage/

ruki

ruki

粉丝 63
博文 103
码字总数 23669
作品 7
松江
高级程序员
私信 提问
如何在django中使用多个数据库

手动选择数据库 Django 也提供一个可以让你通过代码完全控制数据库使用的 API 。手动定义数据库分配 优先于路由。 为一个 查询集 手动选择一个数据库 你可以在 查询集 “链”中的任何点为 查...

飞儿飞
2016/11/16
8
0
Flask 插件系列 - Flask-SQLAlchemy

简介 Web 开发中,一个重要的组成部分便是数据库了。Web 程序中最常用的莫过于关系型数据库了,也称 SQL 数据库。另外,文档数据库(如 mongodb)、键值对数据库(如 redis)近几年也逐渐在 ...

funhacks
2017/11/29
0
0
EXCHANGE 2010 之RDB恢复单个用户邮箱

接上一篇: 使用SCDPM2010备份还原Exchange2010邮箱数据库 http://bbs.winos.cn/thread-90947-1-1.html 上篇内容写到了对整个数据库做恢复,但生产大环境中大部分是对单个邮箱做恢复,在Exc...

tanzhi
2010/05/22
0
0
解决Android中的SQLite数据库并发访问

假设你已经有一个自己的SQLiteOpenHelper。 现在你想要在不同的线程中向数据库写数据 在你的logcat中将会得到下面的输出信息,并且有一个写操作将不会成功 发生这种情况是因为你每次都创建了...

xingjm8511
2016/06/09
102
0
Azure 文档 (SQL 数据仓库, Azure SQL 数据库文档)

Azure 文档: https://docs.azure.cn/zh-cn/#pivot=products&panel=databases SQL 数据仓库文档: https://docs.azure.cn/zh-cn/sql-data-warehouse/ 了解如何使用 SQL 数据仓库,其结合了 SQ......

chenhao_asd
2018/04/18
0
0

没有更多内容

加载失败,请刷新页面

加载更多

vue预渲染

prerender-spa-plugin 安装prerender-spa-plugin (插件使用见npm官网)[https://www.npmjs.com/package/prerender-spa-plugin] npm install prerender-spa-plugin --save-dev 配置prerender-s......

莫西摩西
29分钟前
0
0
Command模式

https://www.cnblogs.com/devinzhang/archive/2012/01/06/2315235.html

南桥北木
今天
1
0
由于PostgreSQL9.x二进制输出格式默认值改变导致的读取图片错误

今天从社区邮件看到一个这样的问题,感觉很有意思,在这分享给大家~具体如下: 问题现象: 作者有一个很老的Java应用,当时后端采用的PostgreSQL数据库版本为8.x,该系统除了正常的数据增删...

闻术苑
今天
2
0
导入sql时出现Invalid default value for 'create_time'报错处理方法

当运行SQL会出现:[Err] 1067 - Invalid default value for 'create_time',是因为Mysql版本不同,如果版本不 < 5.6请去的话报错的处理方法如下: 方法 :alter table table_name modify cre......

writeademo
今天
1
0
对ssm(spring,springmvc,mybatis)的了解总结

ssm框架现在是java web开发的三个主流框架 ,其实严格来算只算是两个框架,因为springmvc属于spring框架 ,是spring的一个mvc子框架 那么我们下面就来了解一下三大框架把 一 .Spring spring...

咸鱼-李y
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部