jdbc:mysql://ip:端口/数据库名称, 用户名,密码
ljdbc程序中的statement对象用于向数据库发送sql语句， statement对象常用方法： executequery(string sql) ：用于向数据发送查询语句。 executeupdate(string sql)：用于向数据库发送insert、update或delete语句 execute(string sql)：用于向数据库发送任意sql语句 addbatch(string sql) ：把多条sql语句放到一个批处理中。 executebatch()：向数据库发送一批sql语句执行。
package cn.outofmemory.test;import java.sql.connection;import java.sql.drivermanager;public class mysql { public static void main(string arg[]) { try { connection con = null; //定义一个mysql链接对象 class.forname(com.mysql.jdbc.driver).newinstance(); //mysql驱动 con = drivermanager.getconnection(jdbc:mysql://127.0.0.1:3306/test, root, root); //链接本地mysql system.out.print(yes); } catch (exception e) { system.out.print(mysql error: + e.getmessage()); } }}
//插入一条语句mport java.sql.connection;import java.sql.drivermanager;import java.sql.resultset;import java.sql.statement;public class mysql { /** * 入口函数 * @param arg */ public static void main(string arg[]) { try { connection con = null; //定义一个mysql链接对象 class.forname(com.mysql.jdbc.driver).newinstance(); //mysql驱动 con = drivermanager.getconnection(jdbc:mysql://127.0.0.1:3306/test, root, root); //链接本地mysql statement stmt; //创建声明 stmt = con.createstatement(); //新增一条数据 stmt.executeupdate(insert into user (username, password) values ('init', '123456')); resultset res = stmt.executequery(select last_insert_id()); int ret_id; if (res.next()) { ret_id = res.getint(1); system.out.print(ret_id); } } catch (exception e) { system.out.print(mysql error: + e.getmessage()); } }}
//删除和更新数据import java.sql.connection;import java.sql.drivermanager;import java.sql.resultset;import java.sql.statement;public class mysql { /** * 入口函数 * @param arg */ public static void main(string arg[]) { try { connection con = null; //定义一个mysql链接对象 class.forname(com.mysql.jdbc.driver).newinstance(); //mysql驱动 con = drivermanager.getconnection(jdbc:mysql://127.0.0.1:3306/test, root, root); //链接本地mysql statement stmt; //创建声明 stmt = con.createstatement(); //新增一条数据 stmt.executeupdate(insert into user (username, password) values ('init', '123456')); resultset res = stmt.executequery(select last_insert_id()); int ret_id; if (res.next()) { ret_id = res.getint(1); system.out.print(ret_id); } //删除一条数据 string sql = delete from user where id = 1; long deleteres = stmt.executeupdate(sql); //如果为0则没有进行删除操作，如果大于0，则记录删除的条数 system.out.print(delete: + deleteres); //更新一条数据 string updatesql = update user set username = 'xxxx' where id = 2; long updateres = stmt.executeupdate(updatesql); system.out.print(update: + updateres); } catch (exception e) { system.out.print(mysql error: + e.getmessage()); } }}
//查询数据import java.sql.connection;import java.sql.drivermanager;import java.sql.resultset;import java.sql.resultsetmetadata;import java.sql.statement;public class mysql { /** * 入口函数 * @param arg */ public static void main(string arg[]) { try { connection con = null; //定义一个mysql链接对象 class.forname(com.mysql.jdbc.driver).newinstance(); //mysql驱动 con = drivermanager.getconnection(jdbc:mysql://127.0.0.1:3306/test, root, root); //链接本地mysql statement stmt; //创建声明 stmt = con.createstatement(); //新增一条数据 stmt.executeupdate(insert into user (username, password) values ('init', '123456')); resultset res = stmt.executequery(select last_insert_id()); int ret_id; if (res.next()) { ret_id = res.getint(1); system.out.print(ret_id); } //删除一条数据 string sql = delete from user where id = 1; long deleteres = stmt.executeupdate(sql); //如果为0则没有进行删除操作，如果大于0，则记录删除的条数 system.out.print(delete: + deleteres); //更新一条数据 string updatesql = update user set username = 'xxxx' where id = 2; long updateres = stmt.executeupdate(updatesql); system.out.print(update: + updateres); //查询数据并输出 string selectsql = select * from user; resultset selectres = stmt.executequery(selectsql); while (selectres.next()) { //循环输出结果集 string username = selectres.getstring(username); string password = selectres.getstring(password); system.out.print(/r/n/r/n); system.out.print(username: + username + password: + password); } } catch (exception e) { system.out.print(mysql error: + e.getmessage()); } }}