fumiama/fumidb
1
0
Fork 0
mirror of https://github.com/fumiama/fumidb.git synced 2026-06-05 00:32:44 +08:00
Code Activity

add table api

Browse Source
This commit is contained in:
源文雨
2022-05-03 17:36:09 +08:00
parent 05f6c7a3c4
commit 19e09bc630
5 changed files with 251 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
include/binary.h
View File

@@ -46,61 +46,68 @@
#endif
#endif
#ifdef _WIN64
#ifdef WORDS_BIGENDIAN
#define putle16(buf, x) (*(uint16_t*)(buf) = _byteswap_ushort((uint16_t)(x)))
#define putle32(buf, x) (*(uint32_t*)(buf) = _byteswap_ulong((uint32_t)(x)))
#define putle64(buf, x) (*(uint64_t*)(buf) = _byteswap_uint64((uint64_t)(x)))
#ifdef WORDS_BIGENDIAN
#ifdef _WIN64
# define le16toh(x) _byteswap_ushort(x)
# define le32toh(x) _byteswap_ulong(x)
# define le64toh(x) _byteswap_uint64(x)
# define htole16(x) _byteswap_ushort(x)
# define htole32(x) _byteswap_ulong(x)
# define htole64(x) _byteswap_uint64(x)
#define readle16(fd, num) ((~read((fd), &(num), 2))?((num)=_byteswap_ushort((uint16_t)(num))):EOF)
#define readle32(fd, num) ((~read((fd), &(num), 4))?((num)=_byteswap_ulong((uint32_t)(num))):EOF)
#define readle64(fd, num) ((~read((fd), &(num), 8))?((num)=_byteswap_uint64((uint64_t)(num))):EOF)
# define putle16(buf, x) (*(uint16_t*)(buf) = _byteswap_ushort((uint16_t)(x)))
# define putle32(buf, x) (*(uint32_t*)(buf) = _byteswap_ulong((uint32_t)(x)))
# define putle64(buf, x) (*(uint64_t*)(buf) = _byteswap_uint64((uint64_t)(x)))
#define le16(buf) _byteswap_ushort(*(uint16_t*)(buf))
#define le32(buf) _byteswap_ulong(*(uint32_t*)(buf))
#define le64(buf) _byteswap_uint64(*(uint64_t*)(buf))
# define readle16(fd, num) (read((fd), &(num), 2),((num)=_byteswap_ushort((uint16_t)(num))))
# define readle32(fd, num) (read((fd), &(num), 4),((num)=_byteswap_ulong((uint32_t)(num))))
# define readle64(fd, num) (read((fd), &(num), 8),((num)=_byteswap_uint64((uint64_t)(num))))
# define le16(buf) _byteswap_ushort(*(uint16_t*)(buf))
# define le32(buf) _byteswap_ulong(*(uint32_t*)(buf))
# define le64(buf) _byteswap_uint64(*(uint64_t*)(buf))
#else
#define putle16(buf, x) (*(uint16_t*)(buf) = (uint16_t)(x))
#define putle32(buf, x) (*(uint32_t*)(buf) = (uint32_t)(x))
#define putle64(buf, x) (*(uint64_t*)(buf) = (uint64_t)(x))
# define le16toh(x) __builtin_bswap16(x)
# define le32toh(x) __builtin_bswap32(x)
# define le64toh(x) __builtin_bswap64(x)
# define htole16(x) __builtin_bswap16(x)
# define htole32(x) __builtin_bswap32(x)
# define htole64(x) __builtin_bswap64(x)
#define readle16(fd, num) read((fd), &(num), 2)
#define readle32(fd, num) read((fd), &(num), 4)
#define readle64(fd, num) read((fd), &(num), 8)
# define putle16(buf, x) (*(uint16_t*)(buf) = __builtin_bswap16((uint16_t)(x)))
# define putle32(buf, x) (*(uint32_t*)(buf) = __builtin_bswap32((uint32_t)(x)))
# define putle64(buf, x) (*(uint64_t*)(buf) = __builtin_bswap64((uint64_t)(x)))
#define le16(buf) (*(uint16_t*)(buf))
#define le32(buf) (*(uint32_t*)(buf))
#define le64(buf) (*(uint64_t*)(buf))
# define readle16(fd, num) (read((fd), &(num), 2),((num)=__builtin_bswap16((uint16_t)(num))))
# define readle32(fd, num) (read((fd), &(num), 4),((num)=__builtin_bswap32((uint32_t)(num))))
# define readle64(fd, num) (read((fd), &(num), 8),((num)=__builtin_bswap64((uint64_t)(num))))
# define le16(buf) __builtin_bswap16(*(uint16_t*)(buf))
# define le32(buf) __builtin_bswap32(*(uint32_t*)(buf))
# define le64(buf) __builtin_bswap64(*(uint64_t*)(buf))
#endif
#else
#ifdef WORDS_BIGENDIAN
#define putle16(buf, x) (*(uint16_t*)(buf) = __builtin_bswap16((uint16_t)(x)))
#define putle32(buf, x) (*(uint32_t*)(buf) = __builtin_bswap32((uint32_t)(x)))
#define putle64(buf, x) (*(uint64_t*)(buf) = __builtin_bswap64((uint64_t)(x)))
# define le16toh(x) (x)
# define le32toh(x) (x)
# define le64toh(x) (x)
# define htole16(x) (x)
# define htole32(x) (x)
# define htole64(x) (x)
#define readle16(fd, num) ((~read((fd), &(num), 2))?((num)=__builtin_bswap16((uint16_t)(num))):EOF)
#define readle32(fd, num) ((~read((fd), &(num), 4))?((num)=__builtin_bswap32((uint32_t)(num))):EOF)
#define readle64(fd, num) ((~read((fd), &(num), 8))?((num)=__builtin_bswap64((uint64_t)(num))):EOF)
# define putle16(buf, x) (*(uint16_t*)(buf) = (uint16_t)(x))
# define putle32(buf, x) (*(uint32_t*)(buf) = (uint32_t)(x))
# define putle64(buf, x) (*(uint64_t*)(buf) = (uint64_t)(x))
#define le16(buf) __builtin_bswap16(*(uint16_t*)(buf))
#define le32(buf) __builtin_bswap32(*(uint32_t*)(buf))
#define le64(buf) __builtin_bswap64(*(uint64_t*)(buf))
#else
#define putle16(buf, x) (*(uint16_t*)(buf) = (uint16_t)(x))
#define putle32(buf, x) (*(uint32_t*)(buf) = (uint32_t)(x))
#define putle64(buf, x) (*(uint64_t*)(buf) = (uint64_t)(x))
# define readle16(fd, num) read((fd), &(num), 2)
# define readle32(fd, num) read((fd), &(num), 4)
# define readle64(fd, num) read((fd), &(num), 8)
#define readle16(fd, num) read((fd), &(num), 2)
#define readle32(fd, num) read((fd), &(num), 4)
#define readle64(fd, num) read((fd), &(num), 8)
#define le16(buf) (*(uint16_t*)(buf))
#define le32(buf) (*(uint32_t*)(buf))
#define le64(buf) (*(uint64_t*)(buf))
#endif
# define le16(buf) (*(uint16_t*)(buf))
# define le32(buf) (*(uint32_t*)(buf))
# define le64(buf) (*(uint64_t*)(buf))
#endif
# define likely(x) __builtin_expect(!!(x), 1)
# define unlikely(x) __builtin_expect(!!(x), 0)
# define likely(x) __builtin_expect(!!(x), 1)
# define unlikely(x) __builtin_expect(!!(x), 0)
#endif

79
include/table.h
View File

@@ -1,6 +1,85 @@
#ifndef _TABLE_H_
#define _TABLE_H_
#include <stdint.h>
#include "types.h"
// 创建表，可变参数为本表的一行的 types，详见 types.h
// 如果 types 为外键，需要紧跟一个 uint64_t ptr
// 指示外键链接到的表位置
// 返回：
// NULL 失败，详见 errno
// table 指向表头的指针
void* create_table(int fd, const char* name, ...);
// 加载 ptr 位置的表
// 返回：
// NULL 失败，详见 errno
// table 指向表头的指针
void* load_table(int fd, uint64_t ptr);
// 获得表名长度，包含结尾0
uint16_t get_table_name_length(void* table);
// 获得表名，写入buf，len(buf) >= len(name)
// 返回：buf
char* get_table_name(void* table, char* buf);
// 为 pos 位置的列创建索引。不可用于 0 列，即 pk 列，因为 pk 必有索引
// 返回：
// NULL 失败，详见 errno
// index 指向索引头的指针
void* add_table_index(int fd, void* table, uint16_t pos);
// 删除 pos 位置的列的索引。不可用于 0 列，即 pk 列，因为 pk 必有索引
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int remove_table_index(int fd, void* table, uint16_t pos);
// 插入一行，如果 pk 有值则替换
// 如果当前项有 nullable 属性，需要在此项之前
// 加一个 int isavailable，标记本项是否有值
// 如果 isavailable==0，后面不再跟有本项数据
// 如果 isavailable!=0，则在后面附加数据
// 返回：
// 0 失败，详见 errno
// ptr 本行插入的位置
uint64_t insert_row(int fd, void* table, ...);
// 根据主键的匹配值查找行
// 如果主键不为 string，k 直接装填其值
// 否则，k 是指向 string 的指针 (const char*)
// 返回：
// 0 失败，详见 errno
// ptr 行所在位置
uint64_t find_row_by_pk(int fd, void* table, key_t k);
// 根据任意匹配值遍历查找行
// 可变参数两两成对，uint16_t pos + key_t val
// 如果 val 不为 string，直接装填其值
// 否则，值是指向 string 的指针 (const char*)
// f 为遍历函数，入参为本行 ptr，返回非 0 值中断遍历
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int find_row_by(int fd, void* table, int (*f)(uint64_t), ...);
// 根据主键的匹配值删除行
// 如果主键不为 string，k 直接装填其值
// 否则，k 是指向 string 的指针 (const char*)
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int remove_row_by_pk(int fd, void* table, key_t k);
// 根据任意匹配值删除行
// 可变参数两两成对，uint16_t pos + key_t val
// 如果 val 不为 string，直接装填其值
// 否则，值是指向 string 的指针 (const char*)
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int remove_row_by(int fd, void* table, ...);
#endif

24
include/types.h
View File

@@ -4,19 +4,19 @@
#include <stdint.h>
#include <errno.h>
#define TYPE_INT8 0
#define TYPE_INT16 1
#define TYPE_INT32 2
#define TYPE_INT64 3
#define TYPE_FLOAT 4
#define TYPE_DOUBLE 5
#define TYPE_STRING 6
#define TYPE_BINARY 7
#define TYPE_INT8 ((uint8_t)0)
#define TYPE_INT16 ((uint8_t)1)
#define TYPE_INT32 ((uint8_t)2)
#define TYPE_INT64 ((uint8_t)3)
#define TYPE_FLOAT ((uint8_t)4)
#define TYPE_DOUBLE ((uint8_t)5)
#define TYPE_STRING ((uint8_t)6)
#define TYPE_BINARY ((uint8_t)7)
#define EXTYPE_NULL 0x00
#define EXTYPE_UNIQUE 0x40
#define EXTYPE_NONNULL 0x80
#define EXTYPE_FOREIGNKEY 0xc0
#define EXTYPE_NULL ((uint8_t)0x00)
#define EXTYPE_UNIQUE ((uint8_t)0x40)
#define EXTYPE_NONNULL ((uint8_t)0x80)
#define EXTYPE_FOREIGNKEY ((uint8_t)0xc0)
typedef uint8_t type_t;
typedef uint64_t key_t;

107
src/table.c
View File

@@ -0,0 +1,107 @@
#include <stdlib.h>
#include <string.h>
#include "../include/binary.h"
#include "../include/table.h"
// 创建表，可变参数为本表的一行的 types，详见 types.h
// 如果 types 为外键，需要紧跟一个 uint64_t ptr
// 指示外键链接到的表位置
// 返回：
// NULL 失败，详见 errno
// table 指向表头的指针
void* create_table(int fd, const char* name, ...) {
return NULL;
}
// 加载 ptr 位置的表
// 返回：
// NULL 失败，详见 errno
// table 指向表头的指针
void* load_table(int fd, uint64_t ptr) {
return NULL;
}
// 获得表名长度，包含结尾0
uint16_t get_table_name_length(void* table) {
return le16(table+8)+1;
}
// 获得表名，写入buf，len(buf) >= len(name)
// 返回：buf
char* get_table_name(void* table, char* buf) {
uint16_t len = le16(table+8);
memcpy(buf, table+10, len);
buf[len] = 0;
return buf;
}
// 为 pos 位置的列创建索引。不可用于 0 列，即 pk 列，因为 pk 必有索引
// 返回：
// NULL 失败，详见 errno
// index 指向索引头的指针
void* add_table_index(int fd, void* table, uint16_t pos) {
return NULL;
}
// 删除 pos 位置的列的索引。不可用于 0 列，即 pk 列，因为 pk 必有索引
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int remove_table_index(int fd, void* table, uint16_t pos) {
return 0;
}
// 插入一行，如果 pk 有值则替换
// 如果当前项有 nullable 属性，需要在此项之前
// 加一个 int isavailable，标记本项是否有值
// 如果 isavailable==0，后面不再跟有本项数据
// 如果 isavailable!=0，则在后面附加数据
// 返回：
// 0 失败，详见 errno
// ptr 本行插入的位置
uint64_t insert_row(int fd, void* table, ...) {
return 0;
}
// 根据主键的匹配值查找行
// 如果主键不为 string，k 直接装填其值
// 否则，k 是指向 string 的指针 (const char*)
// 返回：
// 0 失败，详见 errno
// ptr 行所在位置
uint64_t find_row_by_pk(int fd, void* table, key_t k) {
return 0;
}
// 根据任意匹配值遍历查找行
// 可变参数两两成对，uint16_t pos + key_t val
// 如果 val 不为 string，直接装填其值
// 否则，值是指向 string 的指针 (const char*)
// f 为遍历函数，入参为本行 ptr，返回非 0 值中断遍历
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int find_row_by(int fd, void* table, int (*f)(uint64_t), ...) {
return 1;
}
// 根据主键的匹配值删除行
// 如果主键不为 string，k 直接装填其值
// 否则，k 是指向 string 的指针 (const char*)
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int remove_row_by_pk(int fd, void* table, key_t k) {
return 1;
}
// 根据任意匹配值删除行
// 可变参数两两成对，uint16_t pos + key_t val
// 如果 val 不为 string，直接装填其值
// 否则，值是指向 string 的指针 (const char*)
// 返回：
// 非 0 失败，详见 errno
// 0 成功
int remove_row_by(int fd, void* table, ...) {
return 1;
}

4
src/types.c
View File

@@ -32,7 +32,7 @@ static void* load_not_impl_index(int fd, uint64_t ptr, void* buf) {
// Function not implemented
static int remove_not_impl_index(int fd, void* index) {
errno = ENOSYS;
return 0;
return -2;
}
// Function not implemented
@@ -44,7 +44,7 @@ static uint64_t count_not_impl_items(int fd, void* index) {
// Function not implemented
static int insert_not_impl_item(int fd, void* index, key_t k, uint64_t ptr) {
errno = ENOSYS;
return 0;
return -2;
}
// Function not implemented