🗄️ ADODB · 数据库连接类

// 核心类结构 class godking.conn { — connection (ADODB.Connection), catalog (ADOX.Catalog) — open, close, getError — exec, query, getTable, getRows, rs, each — createCommand, beginTrans, commitTrans, rollbackTrans — getTableNames, existsTable, truncateTable, dropTempTable — findTableObject, findProcedureObject, eachTableObject — insertByTable (批量插入) — format, escape, escapeId (SQL 格式化工具) } class conn.myrs { — rs_object (ADODB.RecordSet) — Eof, Bof, RecordCount, PageCount, PageSize, Position — Move, MoveFirst, MoveNext, MovePrevious, MoveLast — getValue, setValue, getType, getName, getDefinedSize — getTable, getPageTable, getNextRecordset — AddNew, UpDate, GetRows, Close } class conn.Command { — commandText, commandType, parameters — exec, executeNoRecords, executeStream — getTable, getRows, query, each — addParameter, bind }

// 连接 SQLite 数据库 var conn = godking.conn.openSqlite3("data.db"); // 创建表 conn.exec("CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)"); // 使用格式化占位符插入 conn.exec("INSERT INTO users(name, age) VALUES(?, ?)", "张三", 25); // 命名参数 + 批量键值占位 conn.exec("INSERT INTO users(@keys) VALUES(@values)", { name="李四", age=30 }); // 查询并返回数组 var data = conn.query("SELECT * FROM users WHERE age > ?", 20); for i,row in data { io.print(row.name, row.age); } // 记录集操作 var rs = conn.rs("SELECT * FROM users"); while(!rs.Eof) { io.print(rs.getValue("name"), rs.getValue("age")); rs.MoveNext(); } rs.close(); // 批量插入 var list = { {name="王五", age=28}, {name="赵六", age=32} }; list.fields = {"name", "age"}; conn.insertByTable("users", null, list); // 事务 conn.beginTrans(); conn.exec("UPDATE users SET age = age + 1"); conn.commitTrans(); conn.close();