Java连接Mysql 实例
1 package com.jdbc;2
3 import java.sql.Connection;
4 import java.sql.DriverManager;
5 import java.sql.ResultSet;
6 import java.sql.Statement;
7 import java.util.Scanner;
8
9 public class Atm{
10 static Statement sc=null;
11 static Scanner sca=new Scanner(System.in);
12 static String username;
13 public static void main(String[] args) throws Exception {
14 //该方法是 得到数据库的操作平台的。
15 getStatement();
16 System.out.println("欢迎来到J18银行");
17 System.out.println("请登录：");
18 System.out.println("用户名：");
19 username=sca.next();
20 System.out.println("密码：");
21 String password=sca.next();
22 //调用查询账户方法，需要传入 用户名 和密码 返回int类型的值
23 int num=queryJ18(username,password);
24 //num==1 表示 数据库中有对应的用户名和密码
25
if(num==1){26 System.out.println("登录成功");
27 //使用for死循环 进行操作
28 for(;;){
29 System.out.println("请选择交易类型：");
30 System.out.println("1、存钱 2、取钱 3、查询余额");
31 int cz=sca.nextInt();//输入操作类型
32 if(cz==1){
33 cun(); //调用存钱方法
34 }else if(cz==2){
35 qu();//调用取钱方法
36 }else if(cz==3){
37 query();//调用查询余额方法
38 }else{
39 System.out.println("谢谢使用！");
40 break;
41 }
42 }
43 }
44
else{45 System.out.println("登录失败！");
46 }
47 }
48 /**
49 * 取钱方法
50 * @throws Exception
51 */
52
public static void qu() throws Exception{53 System.out.println("请输入你的取款金额：");
54 double money=sca.nextDouble();
55 String sql="update J18 set money=money-"+money;
56 System.out.println(sql);
57 boolean a =sc.execute(sql);
58
if(!a){59 System.out.println("取款成功！");
60 }
61 }
62 /**
63 * 存钱方法
64 */
65
public static void cun() throws Exception{66
67 System.out.println("请输入你的存款金额：");
68 double money=sca.nextDouble();//输入存款金额
69 //拼接 修改sql
70 String sql="update J18 set money=money+"+money;
71 //在 操作平台中 执行 sql语句
72 boolean a =sc.execute(sql);
73 //判断是否成功
74 if(!a){
75 System.out.println("存款成功！");
76 }
77 }
78 public static int queryJ18(String username,String password) throws Exception{
79 //拼接查询sql 注意： 在拼接的时候，，字符串需要在前后加\'（单引号）
80 String sql="select * from J18 where Sname=\'"+username+"\' and pwd=\'"+password+"\'";
81 //在平台中执行查询sql ,并把查询的内容放在 ResultSet rs 里面
82 ResultSet rs=sc.executeQuery(sql);
83 //声明一个int 类型的变量 初始值 0
84 int num=0;
85 //如果查询的结果里面有值得话，就进入循环里面
86 while(rs.next()){ //rs.next() 是判断当前位置是否有数据，有就进入 没有就跳过
87 num++;
88 }
89 return num;
90 }
91 /*
92 * 查询方法
93 */
94
public static void query() throws Exception{95 //拼接查询sql 注意： 在拼接的时候，，字符串需要在前后加\'（单引号）
96 String sql="select money from J18 where Sname=\'"+username+"\'";
97 //在平台中执行查询sql ,并把查询的内容放在 ResultSet rs 里面
98 ResultSet rs=sc.executeQuery(sql);
99 //声明一个double类型的变量 赋值 0
100 double money=0;
101 //rs.next() 是判断当前位置是否有数据，有就进入 没有就跳过
102 while(rs.next()){
103 //把查询出来的数据赋值给money 变量
104 money=rs.getDouble(1);
105 }
106 System.out.println("你的账户余额："+money);
107 }
108
109 /**
110 * 得到数据库操作平台方法
111 * @throws Exception
112 */
113 public static void getStatement() throws Exception{
114 //1\加载驱动
115 Class.forName("com.mysql.jdbc.Driver");
116 /**
117 * 数据库连接URL
118 * jdbc:mysql://IP:port/数据库名
119 * jdbc:mysql://localhost:3306/score
120 */
121 String url="jdbc:mysql://localhost:3306/atm";
122 //数据库用户名
123 String username="root";
124 //数据库密码
125 String password="root";
126 //使用驱动得到数据库连接，需要传入 url username password
127 Connection c=DriverManager.getConnection(url, username, password);
128 //得到数据库操作平台，平台
129 sc=c.createStatement();
130 }
131 }
以上是 Java连接Mysql 实例 的全部内容， 来源链接： utcz.com/z/392150.html
