1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

import console;

import mysql.client;

console.log("正在连接数据库服务器...");

var mysqlDb,err = mysql.client(

     server = "localhost"; //数据库服务器,可省略默认为localhost

     uid = "root";//用户名,可省略默认为root

     pwd = "用户密码";

);

if(!mysqlDb){

    console.log("连接数据库失败",err)

    return;

}

//如果数据库不存在创建数据库，并自动选择数据库

mysqlDb.createDb("testAAutoMySqlClient")

sql = /*

CREATE TABLE `library` (

`name` varchar(100) NOT NULL,

`auditing` tinyint(1) DEFAULT '0',

`bytes` BLOB,

PRIMARY KEY (`name`),

UNIQUE KEY `name` (`name`)

) ENGINE=MyISAM DEFAULT CHARSET=gb2312;

*/

mysqlDb.exec(sql);//执行SQL语句

var ret,err = mysqlDb.listTables()

for tbl in ret.each(){

    console.log("发现数据表:",tbl);

}

//增 -  使用命名参数

mysqlDb.exec("REPLACE INTO `library` values('名字1',@num,@str)

,('名字2',@num,@str)

,('名字3',@num,@str)

", {

num = 123;

//删 - 使用format格式化参数

mysqlDb.exec("DELETE FROM `%s` where name='%s';","library",'名字3')

//改

mysqlDb.exec("UPDATE `library` SET auditing = 111  WHERE name = '名字2';" );

//查询数据并返回记录集,limit指定返回记录集索引

var result = mysqlDb.query("select * from `library` limit 0,10");

for name,auditing,bytes in result.each(){

    io.print( name,auditing,bytes ); //逐行输出所有记录

}

//移除数据库

mysqlDb.dropDb("testAAutoMySqlClient");