包com.tanglei.test1;
进口java.sql。*;
公共类Testsql {
公共静态void main (String [] args) {
mysql mysql=new mysql ();
}
}
类mysql {
//mysql的JDBC URL编写方式:JDBC: mysql://主机名称:连接端口/数据库的名称?参数=值
,,//避免中文乱码要指定useUnicode和characterEncoding
,,//执行数据库操作之前要在数据库管理系统上创建一个数据库,名字自己定,
,,//下面语句之前就要先创建javademo数据库
连接cnn=零;
字符串sql;
字符串url=" jdbc: mysql://localhost: 3306/测试? useSSL=false”;
公共mysql () {
尝试{
//之所以要使用下面这条语句,是因为要使用mysql的驱动,所以我们要把它驱动起来,
,,,,//可以通过forname把它加载进去,也可以通过初始化来驱动起来
//1。添加驱动
forname (“com.mysql.jdbc.Driver”);
//2。建立连接
//一个连接代表一个数据库连接
cnn=DriverManager.getConnection (url、“测试人员”、“pass1234”);
cnn.setAutoCommit(假);
//3。创建声明
//声明里面带有很多方法,比如executeUpdate可以实现插入,更新和删除等
=声明支撑cnn.createStatement ();
sql=按唇ū砣绻淮嬖谘?没有varchar(20),名字varchar(20),主键(无))”,
int res=stmt.executeUpdate (sql);
cnn.commit ();
//System.out.println (res);
如果(res !=1) {
System.out.println(“数据库创建成功!”);
sql=安迦胙?不,名字)值(‘S001’,‘雷’)”,
stmt.executeUpdate (sql);
sql=安迦胙?不,名字)值(‘S002’,‘Swead’)”,
stmt.executeUpdate (sql);
sql=安迦胙?不,名字)值(“S003”,“否认”)”,
stmt.executeUpdate (sql);
sql=皊elect * from学生”;
ResultSet rs=stmt.executeQuery (sql);
System.out.println(“学号\ t姓名”);
, (rs.next ()) {
System.out.println (rs.getString (1) + " \ t”+ rs.getString (2)),
}
sql=吧境硌?
stmt.executeUpdate (sql);}
}捕捉(异常e) {
e.printStackTrace ();
尝试{
cnn.rollback ();
}捕捉(SQLException e1) {
e1.printStackTrace ();}
}最后{
尝试{
cnn.close ();
}捕捉(SQLException e) {
e.printStackTrace ();}
}
}
}
