44 lines
1.1 KiB
JavaScript
44 lines
1.1 KiB
JavaScript
const expect = (is) => {
|
|
if(!is)
|
|
throw new Error('expected not done');
|
|
}
|
|
const {pool} = require('../src/background/mysql')
|
|
const forBigTable = require('../src/background/forBigTable')
|
|
|
|
describe("big table for check", () => {
|
|
let sphinx;
|
|
|
|
it("init", async function() {
|
|
sphinx = await pool()
|
|
expect(sphinx)
|
|
})
|
|
|
|
it("insert 13 records for big table check", async function() {
|
|
for(let i = 1; i < 14; i++)
|
|
await sphinx.query(`insert into feed(id, data) values(${i}, 'a')`)
|
|
})
|
|
|
|
it("for each 3 records of big table", async function() {
|
|
const records = []
|
|
await forBigTable(sphinx, 'feed', record => records.push(record), null, 3)
|
|
expect(records.length === 13)
|
|
})
|
|
|
|
it("for each 13 records of big table", async function() {
|
|
const records = []
|
|
await forBigTable(sphinx, 'feed', record => records.push(record), null, 13)
|
|
expect(records.length === 13)
|
|
expect(records[1].id === 2)
|
|
})
|
|
|
|
it("for each 15 records of big table", async function() {
|
|
const records = []
|
|
await forBigTable(sphinx, 'feed', record => records.push(record), null, 15)
|
|
expect(records.length === 13)
|
|
})
|
|
|
|
it("close", async function() {
|
|
await sphinx.end()
|
|
})
|
|
});
|