import lrapi.lr; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet; public class Actions {
//定义用户名,密码,连接的URL
String username = "root";
String password = "";
String url = "jdbc:mysql://127.0.0.1:3306/hk";
//String sql = "select * from teach where id = ?";
String sql = "update teach set name = ? where id = 2";
Connection conn = null;
PreparedStatement ps;
ResultSet set = null;
//所有的并发只执行一次的操作,放在static代码块里
static{ //1注册mysql驱动
try{
Class.forName("com.mysql.jdbc.Driver");
}catch(ClassNotFoundException e){
e.printStackTrace();
}
}
public int init() throws Throwable { //2连接mysql,导入java.sql.Connection
conn = DriverManager.getConnection(url,username,password);
//3获取sql执行器的类,导入java.sql.preparedstatement
ps = conn.prepareStatement(sql);
return ;
}// end of init public int action() throws Throwable { //字符串转换成整形
//Integer.parseInt("<id>");
//对sql语句中的?做赋值的操作,为了做参数化
//ps.setInt(1, Integer.parseInt("<id>"));
ps.setInt(,);//详细参数详见页底图片 lr.start_transaction("shiwu");//事务开始 //4执行sql语句,获取到执行结果对象ResultSet(导入)
//set = ps.executeQuery();//executeQuery方法只适用于查询操作 //如果是insert,update,delete。使用executeUpdate方法。定义的rows为影响多少行,如果大于0事务成功
int rows = ps.executeUpdate();
if(rows > ){
lr.end_transaction("shiwu", lr.PASS);
}else{
lr.end_transaction("shiwu", lr.FAIL);
} //if(set.next() == true ){ // lr.end_transaction("shiwu", lr.PASS); //}else{ // lr.end_transaction("shiwu", lr.FAIL); // }
//查询时打印获取到的数据
// while(set.next()){
// int id = set.getInt("id");
// System.out.println("id"+id);
// }
return ;
}// end of action public int end() throws Throwable {
//关闭掉ResultSet,PreparedStatement,Connection
//set.close();//更新,删除和插入用不到set.close()把它去掉
ps.close();
conn.close();
return ;
}// end of end /* //程序去执行的入口,在LR中不用写
public static void main(String[] args) throws Throwable{
Actions actions = new Actions();
actions.init();
actions.action();
actions.end();
}
*/ }
以上为java vuser增删改查的脚本,其中明确写出来 查和改 的示例。
注释:
1、运行时 设置Run-time Settings看下是否存在java的classpath
2、设置运行所需要的JDBC包并添加进来
3、附一张截图说明,如下图所示: