本文档适用于完成单节点安装后,通DolphinDB GUI连接到节点上,进行DolphinDB database操作。单节点安装请参考单节点安装教程。
db = database("dfs://DolphinDB");
DolphinDB
创建的表及相关文件,则会打开该数据库。DolphinDB
创建的表及相关文件,则数据库创建失败。需要清空"dfs://DolphinDB"目录再次尝试。dropDatabase("dfs://DolphinDB");
dropDatabase
以数据库的路径作为参数。有三种创建数据表的方法:使用table
函数创建内存表;使用loadTable
函数从数据库中加载数据表;使用loadText
函数将磁盘上的文本文件加载为数据表。
table
函数创建内存表t1 = table(take(1..10, 100) as id, rand(10, 100) as x, rand(10.0, 100) as y);
使用table
函数建立内存表,包含id、x、y 三列,共100行。
将内存表保存到分布式数据库中:
db = database("dfs://DolphinDB",VALUE,1..10)
pt=createPartitionedTable(db,t1,`pt,`id).append!(t1)
createPartitionedTable
函数将内存表t1追加到数据库db中的分区表pt中。loadTable
函数从数据库中加载表db = database("dfs://DolphinDB");
t = loadTable(db, "pt");
typestr
函数查看表的类型为"SEGMENTED DFS TABLE",即分布式分区表。typestr(t);
loadText
函数将磁盘上的文本文件转换为数据表将一个文本文件test.csv加载到内存中:
t = loadText(C:/test.csv);
loadText
把文本文件转换为内存表。默认列以逗号(,)分隔。dropTable
删除数据库中的表db = database("dfs://DolphinDB")
dropTable(db, "tableName");
按照标准的SQL语言操作
select * from t
insert into t values (5, 6, 2.5)
append!
函数进行批量插入。ta = loadTable(db, "t1")
tb = loadTable(db, "t1")
select count(*) from ta
select count(*) from tb
ta.append!(tb)
select count(*) from ta
update t set y = 1000.1 where x = 5
delete from t where id=3
内存表操作结果没有被记录到磁盘上。若需要对修改的表进行持久化,使用saveTable
,或使用 createPartitionedTable
函数创建分区表,再使用 append!
函数或 tableInsert
函数把数据保存至分区表中。
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Опубликовать ( 0 )