设为首页 收藏本站
查看: 1100|回复: 0

[经验分享] MyBatis+mysql查询和添加数据

[复制链接]

尚未签到

发表于 2018-10-10 07:02:53 | 显示全部楼层 |阅读模式
  项目结构:
DSC0000.jpg

  Menu
  packagecom.mstf.dao;
  importjava.util.Scanner;
  importorg.apache.ibatis.session.SqlSession;
  importcom.mstf.util.MyBatisUtil;
  publicclassMenu {
  privatestaticScanner sc =newScanner(System.in);
  publicstaticvoidmain(String[] args) {
  SqlSession session=MyBatisUtil.getSession();
  System.out.println("请输入菜单选项:");
  System.err.println("1.根据订单ID查询信息");
  System.err.println("2.添加客户订单信息");

  String>  if("1".equals(id)) {
  Table.table1();
  }elseif("2".equals(id)) {
  Table.table2();
  }else{
  System.err.println("非法操作:没有此选项!");
  session.close();
  }
  }
  }
  Table
  63packagecom.mstf.dao;
  importjava.util.List;
  importjava.util.Scanner;
  importorg.apache.ibatis.session.SqlSession;
  importcom.mstf.entity.T_customer;
  importcom.mstf.entity.T_order;
  importcom.mstf.util.MyBatisUtil;
  publicclassTable {
  privatestaticScanner sc =newScanner(System.in);
  staticSqlSession session=MyBatisUtil.getSession();
  /**

  * 根据订单>  * @author wangzheng
  */
  publicstaticvoidtable1(){
  System.err.println("请输入订单ID:");
  String bug=sc.next();
  try{
  List list = session.selectList("getT_customerT_order",bug);
  for(T_order t_order : list) {
  System.out.println(t_order);
  }
  }finally{
  session.commit();
  session.close();
  System.out.println("查询一条数据成功!如果没有数据显示,则为无此订单ID!");
  }
  }
  /**
  * 添加一条新数据
  * @author wangzheng
  */
  publicstaticvoidtable2(){
  intcustomer_id=0;
  System.out.println("请输入客户姓名:");
  String name=sc.next();
  System.out.println("请输入客户年龄:");
  String age=sc.next();
  System.out.println("请输入客户电话:");
  String tel=sc.next();
  System.out.println("请输入订单编号:");
  String order_number=sc.next();
  System.out.println("请输入订单价格:");
  String order_price=sc.next();
  try{
  T_customer t_customer =newT_customer(0,name,age,tel);
  T_order t_order =newT_order(0,order_number,order_price,customer_id);
  session.insert("insert_T_customer",t_customer);
  session.insert("insert_T_order",t_order);
  }finally{
  session.commit();
  session.close();
  System.out.println("添加数据成功!");
  }
  }
  }
  T_customer
  47packagecom.mstf.entity;
  publicclassT_customer {
  privateintid;
  privateString name;
  privateString age;
  privateString tel;
  publicintgetId() {
  returnid;
  }
  publicvoidsetId(intid) {

  this.id =>  }
  publicString getName() {
  returnname;
  }
  publicvoidsetName(String name) {
  this.name = name;
  }
  publicString getAge() {
  returnage;
  }
  publicvoidsetAge(String age) {
  this.age = age;
  }
  publicString getTel() {
  returntel;
  }
  publicvoidsetTel(String tel) {
  this.tel = tel;
  }
  publicT_customer(intid, String name, String age, String tel) {
  super();

  this.id =>  this.name = name;
  this.age = age;
  this.tel = tel;
  }
  publicT_customer() {
  super();
  }
  @Override
  publicString toString() {

  return"订单客户:[客户ID:"+>  }
  }
  T_order
  58packagecom.mstf.entity;
  publicclassT_order {
  privateintid;
  privateString order_number;
  privateString order_price;
  privateT_customer t_customer;
  privateintcustomer_id;
  publicintgetCustomer_id() {
  returncustomer_id;
  }
  publicvoidsetCustomer_id(intcustomer_id) {
  this.customer_id = customer_id;
  }
  publicT_customer getT_customer() {
  returnt_customer;
  }
  publicvoidsetT_customer(T_customer t_customer) {
  this.t_customer = t_customer;
  }
  publicintgetId() {
  returnid;
  }
  publicvoidsetId(intid) {

  this.id =>  }
  publicString getOrder_number() {
  returnorder_number;
  }
  publicvoidsetOrder_number(String order_number) {
  this.order_number = order_number;
  }
  publicString getOrder_price() {
  returnorder_price;
  }
  publicvoidsetOrder_price(String order_price) {
  this.order_price = order_price;
  }
  publicT_order(intid, String order_number, String order_price,intcustomer_id) {
  super();

  this.id =>  this.order_number = order_number;
  this.order_price = order_price;
  this.customer_id = customer_id;
  }
  publicT_order() {
  super();
  }
  @Override
  publicString toString() {

  return"系统订单:[订单ID:"+>  +"];\n"+ t_customer +"\n";
  }
  }
  T_customer.xml
  PUBLIC"-//mybatis.org//DTD Mapper 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  SELECT * FROM t_customer tc,t_order t WHERE tc.id=t.customer_id and t.customer_id =#{t.customer_id}
  T_order.xml
  PUBLIC"-//mybatis.org//DTD Mapper 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  insert into t_customer (name, age, tel) values (#{name}, #{age}, #{tel})
  insert into t_order (order_number, order_price, customer_id) VALUES (#{order_number},#{order_price},(SELECT MAX(`id`) FROM `t_customer`))
  MyBatisUtil
  24packagecom.mstf.util;
  importjava.io.Reader;
  importorg.apache.ibatis.io.Resources;
  importorg.apache.ibatis.session.SqlSession;
  importorg.apache.ibatis.session.SqlSessionFactory;
  importorg.apache.ibatis.session.SqlSessionFactoryBuilder;
  publicclassMyBatisUtil {
  // 去读取编写的 mybatis_config.xml 文件加载文件中的映射
  publicstaticSqlSession getSession() {
  SqlSessionFactory ssf=null;
  String url="mybatis_config.xml";
  Reader reader=null;
  try{
  reader=Resources.getResourceAsReader(url);
  }catch(Exception e) {
  e.printStackTrace();
  }
  ssf=newSqlSessionFactoryBuilder().build(reader);
  returnssf.openSession();
  }
  }
  db.properties
  driver=com.mysql.jdbc.Driver
  url=jdbc:mysql://127.0.0.1/demo
  username=root
  password=root
  log4j.properties
  # 全局的日志配置
  log4j.rootLogger = ERROR,stdout
  # MyBatis 的日志配置
  log4j.logger.org.fkit.mapper.UserMapper=DEBUG
  # 控制台输出
  log4j.appender.stdout = org.apache.log4j.ConsoleAppender
  log4j.appender.stdout.layout = org.apache.log4j.PatternLayout
  log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n
  mybatis_config.xml
  PUBLIC"-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-config.dtd">
  欢迎加入技术QQ群:364595326
  ="mysql">


运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-619685-1-1.html 上篇帖子: MySQL 设计规范(续) 下篇帖子: MySQL 高可用性之keepalived+mysql双主
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表