import { expect } from 'chai';
import { getOssTableSql } from '../../src/generate-table-sql/oss';

describe('generate-table-sql/oss', () => {
  beforeEach(() => {
  });

  afterEach(async () => {
  });

  it('生成单个OSS建表语句', () => {
    const str = getOssTableSql({
      databaseName: 'sample',
      tableName: 'oss_table_origin_user_whole',
      endpoint: 'oss-cn-beijing-internal.aliyuncs.com',
      url: 'oss://project-tdd/sample/user_whole.csv',
      accessId: 'xx',
      accessKey: 'xx',
      columns: [
        {
          name: 'user_id',
          type: 'VARCHAR(32)',
        },
        {
          name: 'register_time',
          type: 'INT',
        },
      ],
    });
    expect(str).to.be.equal([
      'DROP TABLE IF EXISTS sample.oss_table_origin_user_whole;',
      'CREATE TABLE IF NOT EXISTS sample.oss_table_origin_user_whole (',
      '  user_id VARCHAR(32),',
      '  register_time INT',
      ')',
      'ENGINE = \'OSS\'',
      'TABLE_PROPERTIES = \'{',
      '  "endpoint":"oss-cn-beijing-internal.aliyuncs.com",',
      '  "url":"oss://project-tdd/sample/user_whole.csv",',
      '  "accessid":"xx",',
      '  "accesskey":"xx",',
      '  "delimiter":",",',
      '  "skip_header_line_count":0',
      '}\';',
    ].join('\n'));
  });
});