首页 > 代码库 > Node.js ORM框架Sequlize之表间关系
Node.js ORM框架Sequlize之表间关系
Sequelize模型之间存在关联关系，这些关系代表了数据库中对应表之间的主/外键关系。基于模型关系可以实现关联表之间的连接查询、更新、删除等操作。本文将通过一个示例，介绍模型的定义，创建模型关联关系，模型与关联关系同步数据库，及关系模型的增、删、改、查操作。数据库中的表之间存在一定的关联关系，表之间的关系基于
主/外键进行关联、创建约束等。关系表中的数据分为1对1(1:1)、1对多(1:M)、多对多(N:M)三种关联关系。在
Sequelize中建立关联关系，通过调用模型(源模型)的belongsTo、hasOne、hasMany、belongsToMany方法，再将要建立关系的模型(目标模型)做为参数传入即可。这些方法会按以下规则创建关联关系:
hasOne- 与目标模型建立1:1关联关系，关联关系(外键)存在于目标模型中。belongsTo- 与目标模型建立1:1关联关系，关联关系(外键)存在于源模型中。hasMany- 与目标模型建立1:N关联关系，关联关系(外键)存在于目标模型中。belongsToMany- 与目标模型建立N:M关联关系，会通过sourceId和targetId创建交叉表。
为了能够清楚说明模型关系的定义及关系模型的使用，我们定义如下4个模型对象：
用户(User)－与其它模型存在1:1、1:N、N:M用户登录信息(UserCheckin)－与User存在1:1关系用户地址(UserAddress)－与User存在N:1关系角色(Role)－与User存在N:M关系这几个模型的
E-R结构如下：
接下来上代码，代码和瓷土不符，请注意！
代码写的有点low，没办法，！
1 /** 2 * 大家就按照我的步骤来，一点一点，要有耐心哦 3 * 我相信，最后肯定有你想要的！加油 4 */ 5 //引入框架 6 const Sequelize = require(‘sequelize‘); 7 //创建ORM实例 8 const sequelize = new Sequelize(‘sequlizedb‘, ‘root‘, ‘guoguo‘, 9 { 10 ‘dialect‘: ‘mysql‘, // 数据库使用mysql 11 } 12 ); 13 //验证连接 14 sequelize 15 .authenticate() 16 .then(() => { 17 console.log(‘链接成功‘); 18 }) 19 .catch((error) => { 20 console.log(‘链接失败‘ + error); 21 }) 22 //模型的创建 23 24 const User = sequelize.define(‘user‘, { 25 name: Sequelize.STRING, 26 age: Sequelize.INTEGER, 27 }, { 28 freezeTableName: true, 29 }); 30 31 // User.create({ 32 // name: ‘guo‘, 33 // age: 25 34 // }) 35 // .then((result) => { 36 // console.log(‘=======添加成功===================‘); 37 // console.log(result); 38 // console.log(‘==========================‘); 39 40 // }) 41 // .catch((error) => { 42 // console.log(‘==========================‘); 43 // console.log(‘添加失败‘ + error); 44 // console.log(‘==========================‘); 45 46 // }); 47 48 // const Role=sequelize.define(‘role‘,{ 49 // name:{ 50 // type:sequelize.STRING, 51 // } 52 // }, 53 // {freezeTableName:true}); 54 55 56 const Message = sequelize.define(‘message‘, { 57 text: Sequelize.STRING, 58 }, { 59 freezeTableName: true, 60 }); 61 62 const Image = sequelize.define(‘image‘, { 63 url: Sequelize.STRING, 64 }, { 65 freezeTableName: true, 66 }); 67 //删除表 68 // sequelize.drop() 69 // .then((logging)=>{ 70 // console.log(‘==========================‘); 71 // console.log(‘删除成功！‘+logging); 72 // console.log(‘==========================‘); 73 74 // }) 75 // .catch((error)=>{ 76 // console.log(‘==========================‘); 77 // console.log(‘删除失败‘+error); 78 // console.log(‘==========================‘); 79 80 // }); 81 82 //建立关系 83 // Message.belongsTo(User); 84 // Message.hasMany(Image); 85 //同步到数据库 86 // sequelize.sync({ 87 // force: true, 88 // }).then(() => { 89 // console.log(‘==========================‘); 90 // console.log(‘同步成功‘); 91 // console.log(‘==========================‘); 92 93 // }).catch(() => { 94 // console.log(‘==========================‘); 95 // console.log(‘同步失败‘); 96 // console.log(‘==========================‘); 97 98 // }); 99 100 //cudr 101 function addUers(name, age) { 102 User.create({ 103 name: name, 104 age: age, 105 }).then((log) => { 106 log = JSON.stringify(log); 107 console.log(‘==========================‘); 108 console.log(‘增加用户成功‘ + log); 109 console.log(‘==========================‘); 110 111 }).catch((error) => { 112 console.log(‘==========================‘); 113 console.log(‘增加用户失败‘ + error); 114 console.log(‘==========================‘); 115 116 }); 117 118 } 119 function addMessage(userId, text) { 120 Message.create({ 121 text: text, 122 userId: userId, 123 }).then((log) => { 124 log = JSON.stringify(log); 125 console.log(‘==========================‘); 126 console.log(‘增加成功！‘ + log); 127 console.log(‘==========================‘); 128 129 }).catch((error) => { 130 console.log(‘==========================‘); 131 console.log(‘增加失败！‘ + error); 132 console.log(‘==========================‘); 133 134 }); 135 } 136 function addImage(messageId, imageUrl) { 137 Image.create({ 138 url: imageUrl, 139 messageId: messageId, 140 }).then((log) => { 141 log = JSON.stringify(log); 142 console.log(‘==========================‘); 143 console.log(‘添加图片成功‘ + log); 144 console.log(‘==========================‘); 145 146 }).catch((error) => { 147 console.log(‘==========================‘); 148 console.log(‘添加图片失败‘ + error); 149 console.log(‘==========================‘); 150 151 }); 152 } 153 //测试 154 //addUers(‘杨雪娇‘,22); 155 //addMessage(2, ‘杨雪娇发来的消息3‘); 156 157 // addImage(5,‘http://3.png‘); 158 // addImage(6,‘http://4.png‘); 159 // addImage(2,‘http://2.png‘); 160 // // 161 function getAllMessage() { 162 Message.findAll({ 163 where: { 164 userId: 2 165 }, 166 include: [ 167 { 168 model: User, 169 attributes: [ 170 ‘id‘, 171 ‘name‘, 172 ], 173 }, 174 { 175 model: Image, 176 attributes: [ 177 ‘id‘, 178 ‘url‘ 179 ] 180 } 181 ], 182 }).then((result) => { 183 result = JSON.stringify(result); 184 console.log(‘==========================‘); 185 console.log(result); 186 console.log(‘==========================‘); 187 188 189 }).catch((error) => { 190 console.log(‘==========================‘); 191 console.log(‘查询失败‘ + error); 192 console.log(‘==========================‘); 193 194 }); 195 } 196 //测试 197 //getAllMessage(); 198 //删除消息 199 function delMessage(userId, messageId) { 200 Message.destroy({ 201 where: { 202 userId: userId, 203 id: messageId, 204 }, 205 206 }).then((log) => { 207 log = JSON.stringify(log); 208 console.log(‘==========================‘); 209 console.log(‘删除消息成功！‘ + log); 210 console.log(‘==========================‘); 211 212 }).catch((error) => { 213 console.log(‘==========================‘); 214 console.log(‘删除消息失败！‘ + error); 215 console.log(‘==========================‘); 216 217 }); 218 } 219 //测试 220 //测试发现问题 如果不设置级联 则，从属message表的image表记录不会删除，而只是出现对应messageId 为NULL的现象 221 //delMessage(2,4); 222 223 const Role = sequelize.define(‘role‘, { 224 name: { 225 type: Sequelize.STRING, allowNull: true, 226 } 227 }, { 228 freezeTableName: true, 229 }); 230 231 232 //对于单个模型的同步 233 // Role.sync().then((log) => { 234 // log = JSON.stringify(log); 235 // console.log(‘==========================‘); 236 // console.log(‘Role表数据同步成功‘ + log); 237 // console.log(‘==========================‘); 238 // Role.create({ 239 // name: ‘管理员‘ 240 // }).then((log) => { 241 // log = JSON.stringify(log); 242 // console.log(‘==========================‘); 243 // console.log(‘添加的数据为‘ + log); 244 // console.log(‘==========================‘); 245 246 // }).catch((error) => { 247 // console.log(‘==========================‘); 248 // console.log(‘添加数据失败‘ + error); 249 // console.log(‘==========================‘); 250 251 // }); 252 253 // }).catch((error) => { 254 // console.log(‘==========================‘); 255 // console.log(‘Role模型与表数据同步失败‘ + error); 256 // console.log(‘==========================‘); 257 258 // }); 259 260 //定义User1模型 261 const User1 = sequelize.define(‘user1‘, { 262 name: { 263 type: Sequelize.STRING, 264 validate: { 265 notEmpty: true, 266 len: [2, 30], 267 } 268 }, 269 age: { 270 type: Sequelize.STRING, 271 defaultValue: 21, 272 validate: { 273 isInt: { 274 msg: ‘年龄必须是整数！‘, 275 } 276 } 277 278 }, 279 email: { 280 type: Sequelize.STRING, 281 validate: { 282 isEmail: true, 283 } 284 }, 285 userpicture: Sequelize.STRING, 286 }, { 287 freezeTableName: true, 288 }); 289 // 290 //同步User1模型 291 // User1.sync().then((log) => { 292 // log = JSON.stringify(log); 293 // console.log(‘==========================‘); 294 // console.log(‘User1表数据同步成功‘ + log); 295 // console.log(‘==========================‘); 296 // }).catch((error) => { 297 // console.log(‘==========================‘); 298 // console.log(‘User1模型与表数据同步失败‘ + error); 299 // console.log(‘==========================‘); 300 // }); 301 302 function addUser1(userInfo) { 303 User1.create({ 304 name: userInfo.name, 305 age:userInfo.age, 306 email:userInfo.email, 307 }).then((log) => { 308 log = JSON.stringify(log); 309 console.log(‘==========================‘); 310 console.log(‘添加的数据为‘ + log); 311 console.log(‘==========================‘); 312 313 }).catch((error) => { 314 console.log(‘==========================‘); 315 console.log(‘添加数据失败‘ + error); 316 console.log(‘==========================‘); 317 318 }); 319 } 320 const userInfo={ 321 name:‘郭东生‘, 322 //age:0.1,//Validation error: 年龄必须是整数！ 323 age:22, 324 email:‘7758@qq.com‘, 325 //email:‘7758‘,//Validation error: Validation isEmail on email failed 326 } 327 addUser1(userInfo);
Node.js ORM框架Sequlize之表间关系
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。