iBoxDB .net core java embedded document NoSQL database storage engines Download

Project Description

iBoxDB is a fast transactional table style document NoSQL Application Database, easily store, process objects and documents, traditional table with unstructured data, zero configuration, pure JAVA and DotNET engines, no dependencies.

iBoxDB has a well designed interface with great performance and capability for agile development. You can create applications with database services embedded and deploy it on mobiles, desktops, servers, to persist your data from anywhere.

Green, low carbon emission!

Dual Core Application Database
For   JAVA   C#   Android   Unity   Xamarin   Mono   Linux   Windows

Features

• CRUD and Forward CRUD
• KeyValue and KeyOnly tables
• Unique and non-unique indexes
• Unique and non-unique composite indexes
• SQL like query language
• Transactions support
• Concurrency control, thread safe
• Multiple applications supported
• Memory management
• Scalable hot MasterMaster and MasterSlave replications
• On disk and in memory databases supported
• Automatically create databases
• Zero configuration, copy and run, purely managed code
• Dynamic columns
• Different types with different indexes can be stored in same table
• Persistence + ORM + Cache + Embeddable, ONE STOP solution
• Ason, Array Script Object Notation
• ResultSet compatible with LINQ
• High performance, no dependencies
• Update Increment
• Selecting Tracer
• Snapshot-Serializable Isolation
• JAVA6+   .NET2+

Download

Examples

import iBoxDB.LocalServer.*;

public class App{
   public static AutoBox auto;
   public static Box cube(){
     return auto.cube();
   }
}                
synchronized static void onApplicationStart() { 
  DB.root(path);
  DB db = new DB(1); 

  db.getConfig()
    .ensureTable(Member.class, "Table", "Id") 
    .ensureIndex(Member.class, "Table", "Name"); 

  //Tree->Parts 
  db.getConfig()
    .ensureTable(Node.class, "Node", "Id") 
    .ensureIndex(Node.class, "Node", "Parent"); 

  db.getConfig()
    .ensureTable(Part.class, "Part", "Id") 
    .ensureIndex(Part.class, "Part", "Node");

  DatabaseConfig cfg = db.getConfig();
  cfg.CacheLength = cfg.mb(512L);
  cfg.FileIncSize = (int)cfg.mb(4);

  App.auto = db.open(); 
}        
                         
void anywhere1() { 
  App.auto.insert("Table", new Member()); 
} 

void anywhere2() { 
  try (Box box = App.cube()) { 
    box.d("Table").insert(new Member()); 
    CommitResult cr = box.commit(); 
  } 
} 

boolean exists(Box box) { 
  return box.selectCount("from Table limit 0,1") > 0; 
} 

<V> Iterable<V> startsWith(Box box, Class<V> vClass, String prefix) { 
  String begin = prefix; 
  char[] cs = prefix.toCharArray(); 
  cs[cs.length - 1] = (char) ((short) cs[cs.length - 1] + 1); 
  String end = new String(cs); 
  return box.select(vClass,"from Table where Name>=? & Name<?",begin,end); 
}

void treeJoin(Box box, long nodeRoot, int maxLevel, StringBuilder result) {
  for (Node node : 
         box.select(Node.class, "from Node where Parent==?", nodeRoot)) { 
           result.append(" NODE:").append(node.Id); 
    for (Part part : 
       	   box.select(Part.class, "from Part where Node==?", node.Id)) { 
      	     result.append(" PART:").append(part.Id); 
    } 
    treeJoin(box, node.Id, maxLevel + 1, result); 
  } 
}

synchronized static void onApplicationClose() { 
  App.auto.getDatabase().close(); 
} 

using iBoxDB.LocalServer;
using iBoxDB.LocalServer.IO;

public class AppServer : LocalDatabaseServer 
{ 
  private static AppServer server = new AppServer(); 
  public static IDatabase DB(long address) 
  { 
    return server.GetInstance(address); 
  }

  abstract class Config : BoxFileStreamConfig 
  { 
    public Config() : base() 
    { 
      CacheLength = MB(512); //1024L*1024L*512L
      FileIncSize = (int)MB(4); 
      //Thread, default is 4
      ReadStreamCount = 8; 
      //set equal to 1 in small device.
      //ReadStreamCount = 1; 
    } 
  } 
                
  class MainConfig : Config 
  { 
    public MainConfig() : base() 
    { 
      EnsureTable<Member>("Member", "Id"); 
      //set Max-Length = 20, String default is 32
      EnsureIndex<Member>("Member", "Name(20)");
      EnsureTable<Product>("Product", "Type", "UID"); 
    }
  }
  
  class InventoryConfig : Config 
  { 
    public InventoryConfig() : base() 
    { 
      EnsureTable<Item>("Item", "Id"); 
    } 
  } 
                
  protected override DatabaseConfig BuildDatabaseConfig(long address) 
  { 
    switch (address) 
    { 
      case 1L: return new MainConfig(); 
      case 2L: return new InventoryConfig(); 
      default: return null; 
    } 
  } 
} 
                
void Anywhere1() 
{ 
  var auto = AppServer.DB(1L).Get(); 
  auto.Insert("Member", new Member()); 
} 
                
void Anywhere2() 
{ 
  var db = AppServer.DB(2L); 
  using (var box = db.Cube()) 
  { 
    box["Item"].Insert(new Item()); 
    CommitResult cr = box.Commit(); 
  } 
}

void OnApplicationClose() 
{ 
  AppServer.server.Dispose(); 
}

//db.jsp
<%@page contentType="text/html" pageEncoding="UTF-8" session="false" %>
<%@page import="iBoxDB.LocalServer.*" %>
<%!
    public static AutoBox auto() {
        synchronized (DB.class) {
            if (DB.Tag != null) {
                return (AutoBox) DB.Tag;
            }

            String root = System.getProperty("user.home") + "/jsp_data/";
            new java.io.File(root).mkdirs();
            DB.root(root);
            DB db = new DB(1);
            db.getConfig().ensureTable(JSPUser.class, "JSPUser", "id");

            DB.Tag = db.open();
            return (AutoBox) DB.Tag;
        }
    }

    public static class JSPUser {
        public long id;
        public String name;
    }
%>

//index.jsp
<%@page contentType="text/html" pageEncoding="UTF-8" session="false"%>
<%@include file="db.jsp" %>

<%
    long id = auto().newId();

    JSPUser user = new JSPUser();
    user.id = id;
    user.name = "iBoxDB on JSP -" + user.id;
    auto().insert("JSPUser", user);
%>
<html>
    <body>
        <h1><%=auto().get(JSPUser.class, "JSPUser", id).name%> </h1>
    </body>
</html>

Start(){
    byte[] data = Convert.FromBase64String(PlayerPrefs.GetString("DB","")); 
    db = new DB(data);
    db.MinConfig().FileIncSize = 1; 
    ...
    auto = db.Open();
}  
Save() { 
    byte[] data = db.GetBuffer(); 
    //data = Zip(data); = 1/5
    PlayerPrefs.SetString("DB",Convert.ToBase64String(data)); 
    PlayerPrefs.Save(); 
}

if (GUI.Button(new Rect(0, 50, Screen.width / 2, 50), "Save")) { 
   Application.ExternalEval("FS.syncfs(false, function (err) {});"); 
}

DB db = new DB(DB.CacheOnlyArg);

//Using Thread to heat engine up Before Application.Start()
//System.Threading.Tasks.Task.Run((Action)Hot);
new Thread(() => { Hot(); }).Start();
static AutoBox auto;
public static void Hot() { 
  var db = new DB(); 
  db.GetConfig().EnsureTable<Item>("Item", "Time", "Gid"); 
  auto = db.Open(); 
  auto.Insert("Item", new Item()); 
  auto.Select("from Item");  
}

//use a simple query to control search region
box.Select<User>("from User where Version>? limit 0,1000", last) 
   //with a complex query to filter data
   .Where((u) => { 
       if ( u... )
        if ( u... )
          return u.Time > dt ;
   });

using iBoxDB.LocalServer.Replication;
DB db = new DB();
db.SetBoxRecycler(
  (Socket socket, BoxData outBox, bool normalPoweroff) => {
    if (socket.Actions > 0) {
      foreach (var e in outBox.GetActions()) {
        var actionType = e.ActionType;
        var key = e.Key;
        if (actionType == ActionType.Begin) {
	      continue;
        }

        var tableName = e.TableName;
        var value = e.Select();
        Log (actionType + " '" + tableName + "' at key '" + key 
          + "' \r\n" + DB.ToString (value));
}}});

static DB db = new DB(db_id);
//for LockFile Supported Platform only
db.WaitAnotherApp(1000 * 60 * 5);

using (var auto = db.Open()){
   ...
   //auto.Cube(); Insert(), Update()...
}

try (Box box = auto.cube()) { 
   // forward Update()
   Member m = box.d("Table", 100L).update(Member.class); 
   m.setName("Name"); 
   m.setAmount(BigDecimal.TEN); 
   CommitResult cr = box.commit(); 
}

//Strongly typed
box.select("from Table where Id > ?" , 1L);
//Weak Object
box.select("from Table where Id > ?" , new Variant("1"));             

 DatabaseConfig cfg = db.getConfig();
 cfg.CacheLength = cfg.mb(1024L*3L);
 //or
 cfg.CacheLength = 1024L*1024L*1024L*3L
 //Overflow int
 //1024*1024*1024*3

for 8G+ RAM Machine
use DatabaseConfig.CacheLength to Control Memory, turn off virtual memory.

Linux:
 # free -h
 # sudo swapoff -a

Windows:
System Properties(Win+Pause) - Advanced system settings - Advanced
- Performance Settings - Advanced - Virtual Memory Change -
uncheck Automatically manage paging file - select No paging file - 
click Set - OK restart

auto.getDatabase().getSchemata() 

 sn -k kp.snk 
 ildasm A.dll /out:A.il 
 rename A.dll A.bak
 ilasm  A.il  /dll /key=kp.snk

Links

Benchmark Code

License