JDBC MySQL函数

说明

jdbc模块函数主要是用于操作MYSQL或者ORACLE等数据库
jdbc模块的对象前缀是jdbc，例如 jdbc.init()这样调用

jdbc.init 初始化JDBC链接

初始化JDBC链接
@param jdbcDriver JDBC得驱动，mysql填写: com.mysql.jdbc.Driver
@param dbUrl JDBC链接得URL,例如 jdbc:mysql://{ip}:{port}/{db}?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
@param user 数据库用户名
@param password 数据库密码
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6
    let conn = jdbc.connect()
7
    logd("connect " + conn);
8
    if (!conn) {
9
        logd(jdbc.getLastError());
10
        exit()
11
    }
12
    //查询语句
13
    let q = "Select * from table1 where id=1"
14
    let qur = jdbc.query(q)
15
    logd(qur);
16
    jdbc.connectionClose()
17
}
18

19
main();

jdbc.getLastError 获取最近的错误

获取最近的错误
@return {string} 错误字符串,null 代表没错误

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6
    let conn = jdbc.connect()
7
    logd("connect " + conn);
8
    if (!conn) {
9
        logd(jdbc.getLastError());
10
        exit()
11
    }
12
    //查询语句
13
    let q = "Select * from table1 where id=1"
14
    let qur = jdbc.query(q)
15
    logd(qur);
16
    jdbc.connectionClose()
17
}
18

19
main();

jdbc.connect 链接数据库

链接数据库，该方法在init函数执行后调用
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6
    //链接数据库
7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13
    //查询语句
14
    let q = "Select * from table1 where id=1"
15
    let qur = jdbc.query(q)
16
    logd(qur);
17
    jdbc.connectionClose()
18
}
19

20
main();

jdbc.query 查询数据

查询数据
@param sql sql语句
@return JSON | 数据集合对象

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6
    let conn = jdbc.connect()
7
    logd("connect " + conn);
8
    if (!conn) {
9
        logd(jdbc.getLastError());
10
        exit()
11
    }
12
    //查询语句
13
    let q = "select * from table1 where id=1"
14
    let qur = jdbc.query(q)
15
    logd(qur);
16
    jdbc.connectionClose()
17
}
18

19
main();

jdbc.createPreparedStatement 创建一个预处理SQL语

创建一个预处理SQL语句
@param sql 预处理语句
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31

32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置时间戳
41
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.connectionClose()
49
}
50

51
main();

jdbc.psqlQuery 执行预处理语句

执行之前创建得预处理语句
@return {string} JSON字符串

1
function main() {
2
    //mysql 的地址  ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31
    //插入数据
32
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
33
    qur = jdbc.createPreparedStatement(q)
34
    if (qur) {
35
        //设置第一个索引的参数
36
        jdbc.psqlSetString(1, "我是名称")
37
        //设置第二个索引参数
38
        jdbc.psqlSetString(2, '我是内容')
39
        //设置时间戳
40
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
41
    }
42
    rowcount = jdbc.psqlExecuteUpdate();
43
    logi("插入语句执行影响行数 -" + rowcount);
44
    if (rowcount <= 0) {
45
        loge("插入错误: " + jdbc.getLastError())
46
    }
47
    jdbc.connectionClose()
48
}
49

50
main();

jdbc.psqlSetString 设置字符串参数

预处理语句设置字符串条件参数
@param index 条件索引
@param input 字符串
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31

32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置时间戳
41
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.connectionClose()
49
}
50

51
main();

jdbc.psqlSetLong 设置long条件参数

预处理语句设置long条件参数
@param index 条件索引
@param input long数据
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    jdbc.psqlSetLong(1, 1000);
3
}
4

5
main();

jdbc.psqlSetInt 设置int条件参数

@param index 条件索引
@param input int数据
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31

32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置时间戳
41
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.connectionClose()
49
}
50

51
main();

jdbc.psqlSetFloat 设置float条件参数

预处理语句设置float条件参数
@param index 条件索引
@param input float数据
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    jdbc.psqlSetFloat(1, 1.0)
3
}
4

5
main();

jdbc.psqlSetBoolean 设置boolean条件参数

设置boolean条件参数
@param index 条件索引
@param input boolean数据
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    jdbc.psqlSetBoolean(1, true)
3
}
4

5
main();

jdbc.psqlSetDate 设置日期条件参数

预处理语句设置日期条件参数
@param index 条件索引
@param dataFormat 日期格式，例如 yyyy-MM-dd
@param input 日期字符串
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31

32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置日期
41
        jdbc.psqlSetDate(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.connectionClose()
49
}
50

51
main();

jdbc.psqlSetTimestamp 设置时间戳条件参数

预处理语句设置时间戳条件参数
@param index 条件索引
@param dataFormat 日期格式，例如 yyyy-MM-dd
@param input 日期字符串
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31

32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置时间戳
41
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.psqlClose()
49
    jdbc.connectionClose()
50
}
51

52
main();

jdbc.psqlAddBatch 批量提交

是否设定为批量提交
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址 ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14

15
    //插入数据
16
    let q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
17
    let qur = jdbc.createPreparedStatement(q)
18

19

20
    if (qur) {
21

22
        for (var i = 0; i < 10; i++) {
23
            //设置第一个索引的参数
24
            jdbc.psqlSetString(1, "我是名称")
25
            //设置第二个索引参数
26
            jdbc.psqlSetString(2, '我是内容')
27
            //设置时间戳
28
            jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
29
            r = jdbc.psqlAddBatch()
30
            if (!r) {
31
                logd(jdbc.getLastError());
32
            }
33
        }
34
    }
35

36
    rowcount = jdbc.psqlExecuteUpdate();
37
    logi("插入语句执行影响行数 -" + rowcount);
38
    if (rowcount <= 0) {
39
        loge("插入错误: " + jdbc.getLastError())
40
    }
41
    jdbc.psqlClose()
42
    jdbc.connectionClose()
43

44
}
45

46
main();

jdbc.psqlExecuteUpdate 执行更新操作

执行更新操作
@return {int} 更新影响到行数量

1
function main() {
2
    //mysql 的地址  ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //更新数据
15
    let q = "update table1 set uname=?,ucontent=?,create_time=? where id=?;"
16
    let qur = jdbc.createPreparedStatement(q)
17
    if (qur) {
18
        //设置第一个索引的参数
19
        jdbc.psqlSetString(1, "我是名称")
20
        //设置第二个索引参数
21
        jdbc.psqlSetString(2, '我是内容')
22
        //设置时间戳
23
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
24
        //设置id
25
        jdbc.psqlSetInt(4, 1)
26
    }
27
    let rowcount = jdbc.psqlExecuteUpdate();
28
    logi("插入语句执行影响行数 -" + rowcount);
29
    if (rowcount <= 0) {
30
        loge("插入错误: " + jdbc.getLastError())
31
    }
32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置时间戳
41
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.psqlClose()
49
    jdbc.connectionClose()
50
}
51

52
main();

jdbc.psqlClose 结束预处理语句

结束预处理语句
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    jdbc.psqlClose()
3
}
4

5
main();

jdbc.connectionClose 关闭数据库链接

关闭数据库链接
@return {bool} true 代表成功 false 代表失败

1
function main() {
2
    //mysql 的地址  ip:端口/数据库名
3
    let mysqlUrl = "jdbc:mysql://192.168.0.3:3306/test?characterEncoding=utf8&autoReconnect=true"
4
    let inited = jdbc.init("com.mysql.cj.jdbc.Driver", mysqlUrl, "root", "root123456");
5
    logd("inited " + inited);
6

7
    let conn = jdbc.connect()
8
    logd("connect " + conn);
9
    if (!conn) {
10
        logd(jdbc.getLastError());
11
        exit()
12
    }
13

14
    //查询语句
15
    let q = "select * from table1 where id=? or uname=?"
16
    //创建一个查询
17
    let qur = jdbc.createPreparedStatement(q)
18
    if (qur) {
19
        //设置第一个索引的参数
20
        jdbc.psqlSetInt(1, 1)
21
        //设置第二个索引参数
22
        jdbc.psqlSetString(2, 'test')
23

24
    }
25
    //预处理查询
26
    let data = jdbc.psqlQuery()
27
    logd(data);
28

29
    //关闭预处理语句
30
    jdbc.psqlClose()
31

32
    //插入数据
33
    q = "insert table1(`uname`,`ucontent`,`create_time`)values(?,?,?);"
34
    qur = jdbc.createPreparedStatement(q)
35
    if (qur) {
36
        //设置第一个索引的参数
37
        jdbc.psqlSetString(1, "我是名称")
38
        //设置第二个索引参数
39
        jdbc.psqlSetString(2, '我是内容')
40
        //设置时间戳
41
        jdbc.psqlSetTimestamp(3, "yyyy-MM-dd hh:mm:ss", "2020-10-02 12:02:11")
42
    }
43
    rowcount = jdbc.psqlExecuteUpdate();
44
    logi("插入语句执行影响行数 -" + rowcount);
45
    if (rowcount <= 0) {
46
        loge("插入错误: " + jdbc.getLastError())
47
    }
48
    jdbc.psqlClose()
49
    jdbc.connectionClose()
50
}
51

52
main();